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
-
#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
4599 4600 4601 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4599 def initialize(**args) update!(**args) end |
Instance Attribute Details
#max_work_item_commit_bytes ⇒ Fixnum
Maximum size for work item commit supported windmill storage layer.
Corresponds to the JSON property maxWorkItemCommitBytes
4573 4574 4575 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4573 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
4578 4579 4580 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4578 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
4583 4584 4585 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4583 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
4590 4591 4592 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4590 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
4597 4598 4599 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4597 def windmill_service_port @windmill_service_port end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
4604 4605 4606 4607 4608 4609 4610 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4604 def update!(**args) @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 |