class Google::Apis::DataflowV1b3::StreamingConfigTask
A task that carries configuration information for streaming computations.
Attributes
Chunk size for commit streams from the harness to windmill. Corresponds to the JSON property `commitStreamChunkSizeBytes` @return [Fixnum]
Chunk size for get data streams from the harness to windmill. Corresponds to the JSON property `getDataStreamChunkSizeBytes` @return [Fixnum]
Maximum size for work item commit supported windmill storage layer. Corresponds to the JSON property `maxWorkItemCommitBytes` @return [Fixnum]
Set of computation configuration information. Corresponds to the JSON property `streamingComputationConfigs` @return [Array<Google::Apis::DataflowV1b3::StreamingComputationConfig>]
Map from user step names to state families. Corresponds to the JSON property `userStepToStateFamilyNameMap` @return [Hash<String,String>]
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]
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
# File lib/google/apis/dataflow_v1b3/classes.rb, line 5343 def initialize(**args) update!(**args) end
Public Instance Methods
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