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.



6531
6532
6533
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6531

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) 


6473
6474
6475
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6473

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) 


6478
6479
6480
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6478

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) 


6483
6484
6485
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6483

def max_work_item_commit_bytes
  @max_work_item_commit_bytes
end

#operational_limits ⇒ Google::Apis::DataflowV1b3::StreamingOperationalLimits

Operational limits imposed on streaming jobs by the backend. Corresponds to the JSON property operationalLimits

Returns:



6488
6489
6490
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6488

def operational_limits
  @operational_limits
end

#streaming_computation_configs ⇒ Array<Google::Apis::DataflowV1b3::StreamingComputationConfig>

Set of computation configuration information. Corresponds to the JSON property streamingComputationConfigs

Returns:



6493
6494
6495
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6493

def streaming_computation_configs
  @streaming_computation_configs
end

#streaming_engine_state_tag_encoding_version ⇒ Fixnum

Optional. The state tag encoding format version for streaming engine jobs. Corresponds to the JSON property streamingEngineStateTagEncodingVersion

Returns:

  • (Fixnum) 


6498
6499
6500
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6498

def streaming_engine_state_tag_encoding_version
  @streaming_engine_state_tag_encoding_version
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>) 


6503
6504
6505
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6503

def user_step_to_state_family_name_map
  @user_step_to_state_family_name_map
end

#user_worker_runner_v1_settings ⇒ String

Binary encoded proto to control runtime behavior of the java runner v1 user worker. Corresponds to the JSON property userWorkerRunnerV1Settings NOTE: Values are automatically base64 encoded/decoded in the client library.

Returns:

  • (String) 


6510
6511
6512
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6510

def user_worker_runner_v1_settings
  @user_worker_runner_v1_settings
end

#user_worker_runner_v2_settings ⇒ String

Binary encoded proto to control runtime behavior of the runner v2 user worker. Corresponds to the JSON property userWorkerRunnerV2Settings NOTE: Values are automatically base64 encoded/decoded in the client library.

Returns:

  • (String) 


6516
6517
6518
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6516

def user_worker_runner_v2_settings
  @user_worker_runner_v2_settings
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) 


6523
6524
6525
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6523

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) 


6529
6530
6531
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6529

def windmill_service_port
  @windmill_service_port
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



6536
6537
6538
6539
6540
6541
6542
6543
6544
6545
6546
6547
6548
 
# File 'lib/google/apis/dataflow_v1b3/classes.rb', line 6536

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)
  @operational_limits = args[:operational_limits] if args.key?(:operational_limits)
  @streaming_computation_configs = args[:streaming_computation_configs] if args.key?(:streaming_computation_configs)
  @streaming_engine_state_tag_encoding_version = args[:streaming_engine_state_tag_encoding_version] if args.key?(:streaming_engine_state_tag_encoding_version)
  @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)
  @user_worker_runner_v1_settings = args[:user_worker_runner_v1_settings] if args.key?(:user_worker_runner_v1_settings)
  @user_worker_runner_v2_settings = args[:user_worker_runner_v2_settings] if args.key?(:user_worker_runner_v2_settings)
  @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