#include <streaming_config_task.h>

Inheritance diagram for google_dataflow_api::StreamingConfigTask:

Public Member Functions
	StreamingConfigTask (const Json::Value &storage)

	StreamingConfigTask (Json::Value *storage)

virtual	~StreamingConfigTask ()

const StringPiece	GetTypeName () const

bool	has_commit_stream_chunk_size_bytes () const

void	clear_commit_stream_chunk_size_bytes ()

int64	get_commit_stream_chunk_size_bytes () const

void	set_commit_stream_chunk_size_bytes (int64 value)

bool	has_get_data_stream_chunk_size_bytes () const

void	clear_get_data_stream_chunk_size_bytes ()

int64	get_get_data_stream_chunk_size_bytes () const

void	set_get_data_stream_chunk_size_bytes (int64 value)

bool	has_max_work_item_commit_bytes () const

void	clear_max_work_item_commit_bytes ()

int64	get_max_work_item_commit_bytes () const

void	set_max_work_item_commit_bytes (int64 value)

bool	has_streaming_computation_configs () const

void	clear_streaming_computation_configs ()

const client::JsonCppArray< StreamingComputationConfig >	get_streaming_computation_configs () const

client::JsonCppArray< StreamingComputationConfig >	mutable_streamingComputationConfigs ()

bool	has_user_step_to_state_family_name_map () const

void	clear_user_step_to_state_family_name_map ()

const client::JsonCppAssociativeArray< string >	get_user_step_to_state_family_name_map () const

client::JsonCppAssociativeArray< string >	mutable_userStepToStateFamilyNameMap ()

bool	has_windmill_service_endpoint () const

void	clear_windmill_service_endpoint ()

const StringPiece	get_windmill_service_endpoint () const

void	set_windmill_service_endpoint (const StringPiece &value)

bool	has_windmill_service_port () const

void	clear_windmill_service_port ()

int64	get_windmill_service_port () const

void	set_windmill_service_port (int64 value)

Static Public Member Functions
static StreamingConfigTask *	New ()

Detailed Description

A task that carries configuration information for streaming computations.

Constructor & Destructor Documentation

◆ StreamingConfigTask() [1/2]

google_dataflow_api::StreamingConfigTask::StreamingConfigTask ( const Json::Value & storage )

explicit

Standard constructor for an immutable data object instance.

Parameters

[in] storage The underlying data storage for this instance.

◆ StreamingConfigTask() [2/2]

google_dataflow_api::StreamingConfigTask::StreamingConfigTask ( Json::Value * storage )

explicit

Standard constructor for a mutable data object instance.

Parameters

[in] storage The underlying data storage for this instance.

◆ ~StreamingConfigTask()

google_dataflow_api::StreamingConfigTask::~StreamingConfigTask ( )

virtual

Standard destructor.

Member Function Documentation

◆ clear_commit_stream_chunk_size_bytes()

void google_dataflow_api::StreamingConfigTask::clear_commit_stream_chunk_size_bytes ( )

inline

Clears the 'commitStreamChunkSizeBytes' attribute.

◆ clear_get_data_stream_chunk_size_bytes()

void google_dataflow_api::StreamingConfigTask::clear_get_data_stream_chunk_size_bytes ( )

inline

Clears the 'getDataStreamChunkSizeBytes' attribute.

◆ clear_max_work_item_commit_bytes()

void google_dataflow_api::StreamingConfigTask::clear_max_work_item_commit_bytes ( )

inline

Clears the 'maxWorkItemCommitBytes' attribute.

◆ clear_streaming_computation_configs()

void google_dataflow_api::StreamingConfigTask::clear_streaming_computation_configs ( )

inline

Clears the 'streamingComputationConfigs' attribute.

◆ clear_user_step_to_state_family_name_map()

void google_dataflow_api::StreamingConfigTask::clear_user_step_to_state_family_name_map ( )

inline

Clears the 'userStepToStateFamilyNameMap' attribute.

◆ clear_windmill_service_endpoint()

void google_dataflow_api::StreamingConfigTask::clear_windmill_service_endpoint ( )

inline

Clears the 'windmillServiceEndpoint' attribute.

◆ clear_windmill_service_port()

void google_dataflow_api::StreamingConfigTask::clear_windmill_service_port ( )

inline

Clears the 'windmillServicePort' attribute.

◆ get_commit_stream_chunk_size_bytes()

int64 google_dataflow_api::StreamingConfigTask::get_commit_stream_chunk_size_bytes ( ) const

inline

Get the value of the 'commitStreamChunkSizeBytes' attribute.

◆ get_get_data_stream_chunk_size_bytes()

int64 google_dataflow_api::StreamingConfigTask::get_get_data_stream_chunk_size_bytes ( ) const

inline

Get the value of the 'getDataStreamChunkSizeBytes' attribute.

◆ get_max_work_item_commit_bytes()

int64 google_dataflow_api::StreamingConfigTask::get_max_work_item_commit_bytes ( ) const

inline

Get the value of the 'maxWorkItemCommitBytes' attribute.

◆ get_streaming_computation_configs()

const client::JsonCppArray<StreamingComputationConfig > google_dataflow_api::StreamingConfigTask::get_streaming_computation_configs ( ) const

Get a reference to the value of the 'streamingComputationConfigs' attribute.

◆ get_user_step_to_state_family_name_map()

const client::JsonCppAssociativeArray<string > google_dataflow_api::StreamingConfigTask::get_user_step_to_state_family_name_map ( ) const

inline

Get a reference to the value of the 'userStepToStateFamilyNameMap' attribute.

◆ get_windmill_service_endpoint()

const StringPiece google_dataflow_api::StreamingConfigTask::get_windmill_service_endpoint ( ) const

inline

Get the value of the 'windmillServiceEndpoint' attribute.

◆ get_windmill_service_port()

int64 google_dataflow_api::StreamingConfigTask::get_windmill_service_port ( ) const

inline

Get the value of the 'windmillServicePort' attribute.

◆ GetTypeName()

const StringPiece google_dataflow_api::StreamingConfigTask::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns: google_dataflow_api::StreamingConfigTask

◆ has_commit_stream_chunk_size_bytes()

bool google_dataflow_api::StreamingConfigTask::has_commit_stream_chunk_size_bytes ( ) const

inline

Determine if the 'commitStreamChunkSizeBytes' attribute was set.

Returns: true if the 'commitStreamChunkSizeBytes' attribute was set.

◆ has_get_data_stream_chunk_size_bytes()

bool google_dataflow_api::StreamingConfigTask::has_get_data_stream_chunk_size_bytes ( ) const

inline

Determine if the 'getDataStreamChunkSizeBytes' attribute was set.

Returns: true if the 'getDataStreamChunkSizeBytes' attribute was set.

◆ has_max_work_item_commit_bytes()

bool google_dataflow_api::StreamingConfigTask::has_max_work_item_commit_bytes ( ) const

inline

Determine if the 'maxWorkItemCommitBytes' attribute was set.

Returns: true if the 'maxWorkItemCommitBytes' attribute was set.

◆ has_streaming_computation_configs()

bool google_dataflow_api::StreamingConfigTask::has_streaming_computation_configs ( ) const

inline

Determine if the 'streamingComputationConfigs' attribute was set.

Returns: true if the 'streamingComputationConfigs' attribute was set.

◆ has_user_step_to_state_family_name_map()

bool google_dataflow_api::StreamingConfigTask::has_user_step_to_state_family_name_map ( ) const

inline

Determine if the 'userStepToStateFamilyNameMap' attribute was set.

Returns: true if the 'userStepToStateFamilyNameMap' attribute was set.

◆ has_windmill_service_endpoint()

bool google_dataflow_api::StreamingConfigTask::has_windmill_service_endpoint ( ) const

inline

Determine if the 'windmillServiceEndpoint' attribute was set.

Returns: true if the 'windmillServiceEndpoint' attribute was set.

◆ has_windmill_service_port()

bool google_dataflow_api::StreamingConfigTask::has_windmill_service_port ( ) const

inline

Determine if the 'windmillServicePort' attribute was set.

Returns: true if the 'windmillServicePort' attribute was set.

◆ mutable_streamingComputationConfigs()

client::JsonCppArray<StreamingComputationConfig > google_dataflow_api::StreamingConfigTask::mutable_streamingComputationConfigs ( )

Gets a reference to a mutable value of the 'streamingComputationConfigs' property.

Set of computation configuration information.

Returns: The result can be modified to change the attribute value.

◆ mutable_userStepToStateFamilyNameMap()

client::JsonCppAssociativeArray<string > google_dataflow_api::StreamingConfigTask::mutable_userStepToStateFamilyNameMap ( )

inline

Gets a reference to a mutable value of the 'userStepToStateFamilyNameMap' property.

Map from user step names to state families.

Returns: The result can be modified to change the attribute value.

◆ New()

StreamingConfigTask * google_dataflow_api::StreamingConfigTask::New ( )

static

Creates a new default instance.

Returns: Ownership is passed back to the caller.

◆ set_commit_stream_chunk_size_bytes()

void google_dataflow_api::StreamingConfigTask::set_commit_stream_chunk_size_bytes ( int64 value )

inline

Change the 'commitStreamChunkSizeBytes' attribute.

Chunk size for commit streams from the harness to windmill.

Parameters

[in] value The new value.

◆ set_get_data_stream_chunk_size_bytes()

void google_dataflow_api::StreamingConfigTask::set_get_data_stream_chunk_size_bytes ( int64 value )

inline

Change the 'getDataStreamChunkSizeBytes' attribute.

Chunk size for get data streams from the harness to windmill.

Parameters

[in] value The new value.

◆ set_max_work_item_commit_bytes()

void google_dataflow_api::StreamingConfigTask::set_max_work_item_commit_bytes ( int64 value )

inline

Change the 'maxWorkItemCommitBytes' attribute.

Maximum size for work item commit supported windmill storage layer.

Parameters

[in] value The new value.

◆ set_windmill_service_endpoint()

void google_dataflow_api::StreamingConfigTask::set_windmill_service_endpoint ( const StringPiece & value )

inline

Change the 'windmillServiceEndpoint' attribute.

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.

Parameters

[in] value The new value.

◆ set_windmill_service_port()

void google_dataflow_api::StreamingConfigTask::set_windmill_service_port ( int64 value )

inline

Change the 'windmillServicePort' attribute.

If present, the worker must use this port to communicate with Windmill Service dispatchers. Only applicable when windmill_service_endpoint is specified.

Parameters

[in] value The new value.

The documentation for this class was generated from the following files:

google/dataflow_api/streaming_config_task.h
google/dataflow_api/streaming_config_task.cc

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ StreamingConfigTask() [1/2]

◆ StreamingConfigTask() [2/2]

◆ ~StreamingConfigTask()

Member Function Documentation

◆ clear_commit_stream_chunk_size_bytes()

◆ clear_get_data_stream_chunk_size_bytes()

◆ clear_max_work_item_commit_bytes()

◆ clear_streaming_computation_configs()

◆ clear_user_step_to_state_family_name_map()

◆ clear_windmill_service_endpoint()

◆ clear_windmill_service_port()

◆ get_commit_stream_chunk_size_bytes()

◆ get_get_data_stream_chunk_size_bytes()

◆ get_max_work_item_commit_bytes()

◆ get_streaming_computation_configs()

◆ get_user_step_to_state_family_name_map()

◆ get_windmill_service_endpoint()

◆ get_windmill_service_port()

◆ GetTypeName()

◆ has_commit_stream_chunk_size_bytes()

◆ has_get_data_stream_chunk_size_bytes()

◆ has_max_work_item_commit_bytes()

◆ has_streaming_computation_configs()

◆ has_user_step_to_state_family_name_map()

◆ has_windmill_service_endpoint()

◆ has_windmill_service_port()

◆ mutable_streamingComputationConfigs()

◆ mutable_userStepToStateFamilyNameMap()

◆ New()

◆ set_commit_stream_chunk_size_bytes()

◆ set_get_data_stream_chunk_size_bytes()

◆ set_max_work_item_commit_bytes()

◆ set_windmill_service_endpoint()

◆ set_windmill_service_port()