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
-
#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
4353 4354 4355 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4353 def initialize(**args) update!(**args) end |
Instance Attribute Details
#streaming_computation_configs ⇒ Array<Google::Apis::DataflowV1b3::StreamingComputationConfig>
Set of computation configuration information.
Corresponds to the JSON property streamingComputationConfigs
4332 4333 4334 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4332 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
4337 4338 4339 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4337 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
4344 4345 4346 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4344 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
4351 4352 4353 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4351 def windmill_service_port @windmill_service_port end |
Instance Method Details
#update!(**args) ⇒ Object
Update properties of this object
4358 4359 4360 4361 4362 4363 |
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 4358 def update!(**args) @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 |