google_dataflow_api::StreamLocation Class Reference

#include <stream_location.h>

Inheritance diagram for google_dataflow_api::StreamLocation:

Public Member Functions
	StreamLocation (const Json::Value &storage)
	StreamLocation (Json::Value *storage)
virtual	~StreamLocation ()
const StringPiece	GetTypeName () const
bool	has_custom_source_location () const
void	clear_custom_source_location ()
const CustomSourceLocation	get_custom_source_location () const
CustomSourceLocation	mutable_customSourceLocation ()
bool	has_pubsub_location () const
void	clear_pubsub_location ()
const PubsubLocation	get_pubsub_location () const
PubsubLocation	mutable_pubsubLocation ()
bool	has_side_input_location () const
void	clear_side_input_location ()
const StreamingSideInputLocation	get_side_input_location () const
StreamingSideInputLocation	mutable_sideInputLocation ()
bool	has_streaming_stage_location () const
void	clear_streaming_stage_location ()
const StreamingStageLocation	get_streaming_stage_location () const
StreamingStageLocation	mutable_streamingStageLocation ()

Static Public Member Functions
static StreamLocation *	New ()

Detailed Description

Describes a stream of data, either as input to be processed or as output of a streaming Dataflow job.

Constructor & Destructor Documentation

StreamLocation() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

StreamLocation() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

~StreamLocation()

google_dataflow_api::StreamLocation::~StreamLocation ( )

virtual

Standard destructor.

Member Function Documentation

clear_custom_source_location()

void google_dataflow_api::StreamLocation::clear_custom_source_location ( )

inline

Clears the 'customSourceLocation' attribute.

clear_pubsub_location()

void google_dataflow_api::StreamLocation::clear_pubsub_location ( )

inline

Clears the 'pubsubLocation' attribute.

clear_side_input_location()

void google_dataflow_api::StreamLocation::clear_side_input_location ( )

inline

Clears the 'sideInputLocation' attribute.

clear_streaming_stage_location()

void google_dataflow_api::StreamLocation::clear_streaming_stage_location ( )

inline

Clears the 'streamingStageLocation' attribute.

get_custom_source_location()

const CustomSourceLocation google_dataflow_api::StreamLocation::get_custom_source_location

(

)

const

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

get_pubsub_location()

const PubsubLocation google_dataflow_api::StreamLocation::get_pubsub_location

(

)

const

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

get_side_input_location()

const StreamingSideInputLocation google_dataflow_api::StreamLocation::get_side_input_location

(

)

const

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

get_streaming_stage_location()

const StreamingStageLocation google_dataflow_api::StreamLocation::get_streaming_stage_location

(

)

const

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

GetTypeName()

const StringPiece google_dataflow_api::StreamLocation::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns

google_dataflow_api::StreamLocation

has_custom_source_location()

bool google_dataflow_api::StreamLocation::has_custom_source_location ( ) const

inline

Determine if the 'customSourceLocation' attribute was set.

Returns

true if the 'customSourceLocation' attribute was set.

has_pubsub_location()

bool google_dataflow_api::StreamLocation::has_pubsub_location ( ) const

inline

Determine if the 'pubsubLocation' attribute was set.

Returns

true if the 'pubsubLocation' attribute was set.

has_side_input_location()

bool google_dataflow_api::StreamLocation::has_side_input_location ( ) const

inline

Determine if the 'sideInputLocation' attribute was set.

Returns

true if the 'sideInputLocation' attribute was set.

has_streaming_stage_location()

bool google_dataflow_api::StreamLocation::has_streaming_stage_location ( ) const

inline

Determine if the 'streamingStageLocation' attribute was set.

Returns

true if the 'streamingStageLocation' attribute was set.

mutable_customSourceLocation()

CustomSourceLocation google_dataflow_api::StreamLocation::mutable_customSourceLocation

(

)

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

The stream is a custom source.

Returns

The result can be modified to change the attribute value.

mutable_pubsubLocation()

PubsubLocation google_dataflow_api::StreamLocation::mutable_pubsubLocation

(

)

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

The stream is a pubsub stream.

Returns

The result can be modified to change the attribute value.

mutable_sideInputLocation()

StreamingSideInputLocation google_dataflow_api::StreamLocation::mutable_sideInputLocation

(

)

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

The stream is a streaming side input.

Returns

The result can be modified to change the attribute value.

mutable_streamingStageLocation()

StreamingStageLocation google_dataflow_api::StreamLocation::mutable_streamingStageLocation

(

)

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

The stream is part of another computation within the current streaming Dataflow job.

Returns

The result can be modified to change the attribute value.

New()

StreamLocation * google_dataflow_api::StreamLocation::New ( )

static

Creates a new default instance.

Returns

Ownership is passed back to the caller.

---

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

• google/dataflow_api/stream_location.h
• google/dataflow_api/stream_location.cc