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

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
lib/google/apis/dataflow_v1b3/classes.rb,
lib/google/apis/dataflow_v1b3/representations.rb,
lib/google/apis/dataflow_v1b3/representations.rb

Overview

A task that carries configuration information for streaming computations.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ StreamingConfigTask

Returns a new instance of StreamingConfigTask.



5535
5536
5537
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5535

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

Returns:

  • (Fixnum) 


5500
5501
5502
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5500

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

Returns:

  • (Fixnum) 


5505
5506
5507
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5505

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

Returns:

  • (Fixnum) 


5510
5511
5512
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5510

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

Returns:



5515
5516
5517
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5515

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>) 


5520
5521
5522
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5520

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) 


5527
5528
5529
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5527

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) 


5533
5534
5535
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5533

def windmill_service_port
  @windmill_service_port
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



5540
5541
5542
5543
5544
5545
5546
5547
5548
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 5540

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