Class: Google::Apis::DataflowV1b3::StreamingConfigTask

Inherits:
Object
  • Object
show all
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

Instance Method Summary collapse

Methods included from Core::JsonObjectSupport

#to_json

Methods included from Core::Hashable

process_value, #to_h

Constructor Details

#initialize(**args) ⇒ StreamingConfigTask

Returns a new instance of StreamingConfigTask



3180
3181
3182
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3180

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

Returns:



3159
3160
3161
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3159

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

Returns:

  • (Hash<String,String>) 


3171
3172
3173
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3171

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

Returns:

  • (String) 


3166
3167
3168
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3166

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

Returns:

  • (Fixnum) 


3178
3179
3180
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3178

def windmill_service_port
  @windmill_service_port
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



3185
3186
3187
3188
3189
3190
 
# File 'generated/google/apis/dataflow_v1b3/classes.rb', line 3185

def update!(**args)
  @streaming_computation_configs = args[:streaming_computation_configs] if args.key?(:streaming_computation_configs)
  @windmill_service_endpoint = args[:windmill_service_endpoint] if args.key?(:windmill_service_endpoint)
  @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_port = args[:windmill_service_port] if args.key?(:windmill_service_port)
end