#include <streaming_setup_task.h>

Inheritance diagram for google_dataflow_api::StreamingSetupTask:

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

	StreamingSetupTask (Json::Value *storage)

virtual	~StreamingSetupTask ()

const StringPiece	GetTypeName () const

bool	has_drain () const

void	clear_drain ()

bool	get_drain () const

void	set_drain (bool value)

bool	has_receive_work_port () const

void	clear_receive_work_port ()

int32	get_receive_work_port () const

void	set_receive_work_port (int32 value)

bool	has_snapshot_config () const

void	clear_snapshot_config ()

const StreamingApplianceSnapshotConfig	get_snapshot_config () const

StreamingApplianceSnapshotConfig	mutable_snapshotConfig ()

bool	has_streaming_computation_topology () const

void	clear_streaming_computation_topology ()

const TopologyConfig	get_streaming_computation_topology () const

TopologyConfig	mutable_streamingComputationTopology ()

bool	has_worker_harness_port () const

void	clear_worker_harness_port ()

int32	get_worker_harness_port () const

void	set_worker_harness_port (int32 value)

Static Public Member Functions
static StreamingSetupTask *	New ()

Detailed Description

A task which initializes part of a streaming Dataflow job.

Constructor & Destructor Documentation

◆ StreamingSetupTask() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

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

◆ StreamingSetupTask() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

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

◆ ~StreamingSetupTask()

google_dataflow_api::StreamingSetupTask::~StreamingSetupTask ( )

virtual

Standard destructor.

Member Function Documentation

◆ clear_drain()

void google_dataflow_api::StreamingSetupTask::clear_drain ( )

inline

Clears the 'drain' attribute.

◆ clear_receive_work_port()

void google_dataflow_api::StreamingSetupTask::clear_receive_work_port ( )

inline

Clears the 'receiveWorkPort' attribute.

◆ clear_snapshot_config()

void google_dataflow_api::StreamingSetupTask::clear_snapshot_config ( )

inline

Clears the 'snapshotConfig' attribute.

◆ clear_streaming_computation_topology()

void google_dataflow_api::StreamingSetupTask::clear_streaming_computation_topology ( )

inline

Clears the 'streamingComputationTopology' attribute.

◆ clear_worker_harness_port()

void google_dataflow_api::StreamingSetupTask::clear_worker_harness_port ( )

inline

Clears the 'workerHarnessPort' attribute.

◆ get_drain()

bool google_dataflow_api::StreamingSetupTask::get_drain ( ) const

inline

Get the value of the 'drain' attribute.

◆ get_receive_work_port()

int32 google_dataflow_api::StreamingSetupTask::get_receive_work_port ( ) const

inline

Get the value of the 'receiveWorkPort' attribute.

◆ get_snapshot_config()

const StreamingApplianceSnapshotConfig google_dataflow_api::StreamingSetupTask::get_snapshot_config ( ) const

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

◆ get_streaming_computation_topology()

const TopologyConfig google_dataflow_api::StreamingSetupTask::get_streaming_computation_topology ( ) const

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

◆ get_worker_harness_port()

int32 google_dataflow_api::StreamingSetupTask::get_worker_harness_port ( ) const

inline

Get the value of the 'workerHarnessPort' attribute.

◆ GetTypeName()

const StringPiece google_dataflow_api::StreamingSetupTask::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns: google_dataflow_api::StreamingSetupTask

◆ has_drain()

bool google_dataflow_api::StreamingSetupTask::has_drain ( ) const

inline

Determine if the 'drain' attribute was set.

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

◆ has_receive_work_port()

bool google_dataflow_api::StreamingSetupTask::has_receive_work_port ( ) const

inline

Determine if the 'receiveWorkPort' attribute was set.

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

◆ has_snapshot_config()

bool google_dataflow_api::StreamingSetupTask::has_snapshot_config ( ) const

inline

Determine if the 'snapshotConfig' attribute was set.

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

◆ has_streaming_computation_topology()

bool google_dataflow_api::StreamingSetupTask::has_streaming_computation_topology ( ) const

inline

Determine if the 'streamingComputationTopology' attribute was set.

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

◆ has_worker_harness_port()

bool google_dataflow_api::StreamingSetupTask::has_worker_harness_port ( ) const

inline

Determine if the 'workerHarnessPort' attribute was set.

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

◆ mutable_snapshotConfig()

StreamingApplianceSnapshotConfig google_dataflow_api::StreamingSetupTask::mutable_snapshotConfig ( )

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

Configures streaming appliance snapshot.

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

◆ mutable_streamingComputationTopology()

TopologyConfig google_dataflow_api::StreamingSetupTask::mutable_streamingComputationTopology ( )

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

The global topology of the streaming Dataflow job.

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

◆ New()

StreamingSetupTask * google_dataflow_api::StreamingSetupTask::New ( )

static

Creates a new default instance.

Returns: Ownership is passed back to the caller.

◆ set_drain()

void google_dataflow_api::StreamingSetupTask::set_drain ( bool value )

inline

Change the 'drain' attribute.

The user has requested drain.

Parameters

[in] value The new value.

◆ set_receive_work_port()

void google_dataflow_api::StreamingSetupTask::set_receive_work_port ( int32 value )

inline

Change the 'receiveWorkPort' attribute.

The TCP port on which the worker should listen for messages from other streaming computation workers.

Parameters

[in] value The new value.

◆ set_worker_harness_port()

void google_dataflow_api::StreamingSetupTask::set_worker_harness_port ( int32 value )

inline

Change the 'workerHarnessPort' attribute.

The TCP port used by the worker to communicate with the Dataflow worker harness.

Parameters

[in] value The new value.

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

google/dataflow_api/streaming_setup_task.h
google/dataflow_api/streaming_setup_task.cc

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ StreamingSetupTask() [1/2]

◆ StreamingSetupTask() [2/2]

◆ ~StreamingSetupTask()

Member Function Documentation

◆ clear_drain()

◆ clear_receive_work_port()

◆ clear_snapshot_config()

◆ clear_streaming_computation_topology()

◆ clear_worker_harness_port()

◆ get_drain()

◆ get_receive_work_port()

◆ get_snapshot_config()

◆ get_streaming_computation_topology()

◆ get_worker_harness_port()

◆ GetTypeName()

◆ has_drain()

◆ has_receive_work_port()

◆ has_snapshot_config()

◆ has_streaming_computation_topology()

◆ has_worker_harness_port()

◆ mutable_snapshotConfig()

◆ mutable_streamingComputationTopology()

◆ New()

◆ set_drain()

◆ set_receive_work_port()

◆ set_worker_harness_port()