Class: Google::Apis::DataflowV1b3::StreamingConfigTask
- Inherits:
-
Object
- Object
- Google::Apis::DataflowV1b3::StreamingConfigTask
- Includes:
- Core::Hashable, Core::JsonObjectSupport
- Defined in:
- generated/google/apis/dataflow_v1b3/classes.rb,
generated/google/apis/dataflow_v1b3/representations.rb,
generated/google/apis/dataflow_v1b3/representations.rb
Overview
A task that carries configuration information for streaming computations.
Instance Attribute Summary collapse
-
#commit_stream_chunk_size_bytes ⇒ Fixnum
Chunk size for commit streams from the harness to windmill.
-
#get_data_stream_chunk_size_bytes ⇒ Fixnum
Chunk size for get data streams from the harness to windmill.
-
#max_work_item_commit_bytes ⇒ Fixnum
Maximum size for work item commit supported windmill storage layer.
-
#streaming_computation_configs ⇒ Array<Google::Apis::DataflowV1b3::StreamingComputationConfig>
Set of computation configuration information.
-
#user_step_to_state_family_name_map ⇒ Hash<String,String>
Map from user step names to state families.
-
#windmill_service_endpoint ⇒ 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.
-
#windmill_service_port ⇒ Fixnum
If present, the worker must use this port to communicate with Windmill Service dispatchers.
Instance Method Summary collapse
-
#initialize(**args) ⇒ StreamingConfigTask
constructor
A new instance of StreamingConfigTask.
-
#update!(**args) ⇒ Object
Update properties of this object.
Methods included from Core::JsonObjectSupport
Methods included from Core::Hashable
Constructor Details
#initialize(**args) ⇒ StreamingConfigTask
Returns a new instance of StreamingConfigTask.
4768 4769 4770 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4768 def initialize(**args) update!(**args) end |
Instance Attribute Details
#commit_stream_chunk_size_bytes ⇒ Fixnum
Chunk size for commit streams from the harness to windmill.
Corresponds to the JSON property commitStreamChunkSizeBytes
4732 4733 4734 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4732 def commit_stream_chunk_size_bytes @commit_stream_chunk_size_bytes end |
#get_data_stream_chunk_size_bytes ⇒ Fixnum
Chunk size for get data streams from the harness to windmill.
Corresponds to the JSON property getDataStreamChunkSizeBytes
4737 4738 4739 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4737 def get_data_stream_chunk_size_bytes @get_data_stream_chunk_size_bytes end |
#max_work_item_commit_bytes ⇒ Fixnum
Maximum size for work item commit supported windmill storage layer.
Corresponds to the JSON property maxWorkItemCommitBytes
4742 4743 4744 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4742 def max_work_item_commit_bytes @max_work_item_commit_bytes end |
#streaming_computation_configs ⇒ Array<Google::Apis::DataflowV1b3::StreamingComputationConfig>
Set of computation configuration information.
Corresponds to the JSON property streamingComputationConfigs
4747 4748 4749 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4747 def streaming_computation_configs @streaming_computation_configs end |
#user_step_to_state_family_name_map ⇒ Hash<String,String>
Map from user step names to state families.
Corresponds to the JSON property userStepToStateFamilyNameMap
4752 4753 4754 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4752 def user_step_to_state_family_name_map @user_step_to_state_family_name_map end |
#windmill_service_endpoint ⇒ 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
4759 4760 4761 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4759 def windmill_service_endpoint @windmill_service_endpoint end |
#windmill_service_port ⇒ Fixnum
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
4766 4767 4768 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4766 def windmill_service_port @windmill_service_port end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
4773 4774 4775 4776 4777 4778 4779 4780 4781 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4773 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 |