class Google::Apis::DataflowV1b3::StreamingConfigTask

A task that carries configuration information for streaming computations.

Attributes

commit_stream_chunk_size_bytes[RW]

Chunk size for commit streams from the harness to windmill. Corresponds to the JSON property `commitStreamChunkSizeBytes` @return [Fixnum]

get_data_stream_chunk_size_bytes[RW]

Chunk size for get data streams from the harness to windmill. Corresponds to the JSON property `getDataStreamChunkSizeBytes` @return [Fixnum]

max_work_item_commit_bytes[RW]

Maximum size for work item commit supported windmill storage layer. Corresponds to the JSON property `maxWorkItemCommitBytes` @return [Fixnum]

streaming_computation_configs[RW]

Set of computation configuration information. Corresponds to the JSON property `streamingComputationConfigs` @return [Array<Google::Apis::DataflowV1b3::StreamingComputationConfig>]

user_step_to_state_family_name_map[RW]

Map from user step names to state families. Corresponds to the JSON property `userStepToStateFamilyNameMap` @return [Hash<String,String>]

windmill_service_endpoint[RW]

If present, the worker must use this endpoint to communicate with Windmill Service dispatchers, otherwise the worker must continue to use whatever endpoint it had been using. Corresponds to the JSON property `windmillServiceEndpoint` @return [String]

windmill_service_port[RW]

If present, the worker must use this port to communicate with Windmill Service dispatchers. Only applicable when windmill_service_endpoint is specified. Corresponds to the JSON property `windmillServicePort` @return [Fixnum]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5343
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

Update properties of this object

# File lib/google/apis/dataflow_v1b3/classes.rb, line 5348
def update!(**args)
  @commit_stream_chunk_size_bytes = args[:commit_stream_chunk_size_bytes] if args.key?(:commit_stream_chunk_size_bytes)
  @get_data_stream_chunk_size_bytes = args[:get_data_stream_chunk_size_bytes] if args.key?(:get_data_stream_chunk_size_bytes)
  @max_work_item_commit_bytes = args[:max_work_item_commit_bytes] if args.key?(:max_work_item_commit_bytes)
  @streaming_computation_configs = args[:streaming_computation_configs] if args.key?(:streaming_computation_configs)
  @user_step_to_state_family_name_map = args[:user_step_to_state_family_name_map] if args.key?(:user_step_to_state_family_name_map)
  @windmill_service_endpoint = args[:windmill_service_endpoint] if args.key?(:windmill_service_endpoint)
  @windmill_service_port = args[:windmill_service_port] if args.key?(:windmill_service_port)
end