google_dataflow_api::StreamingComputationTask Class Reference

#include <streaming_computation_task.h>

Inheritance diagram for google_dataflow_api::StreamingComputationTask:

Public Member Functions
	StreamingComputationTask (const Json::Value &storage)
	StreamingComputationTask (Json::Value *storage)
virtual	~StreamingComputationTask ()
const StringPiece	GetTypeName () const
bool	has_computation_ranges () const
void	clear_computation_ranges ()
const client::JsonCppArray< StreamingComputationRanges >	get_computation_ranges () const
client::JsonCppArray< StreamingComputationRanges >	mutable_computationRanges ()
bool	has_data_disks () const
void	clear_data_disks ()
const client::JsonCppArray< MountedDataDisk >	get_data_disks () const
client::JsonCppArray< MountedDataDisk >	mutable_dataDisks ()
bool	has_task_type () const
void	clear_task_type ()
const StringPiece	get_task_type () const
void	set_task_type (const StringPiece &value)

Static Public Member Functions
static StreamingComputationTask *	New ()

Detailed Description

A task which describes what action should be performed for the specified streaming computation ranges.

Constructor & Destructor Documentation

StreamingComputationTask() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

StreamingComputationTask() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

~StreamingComputationTask()

google_dataflow_api::StreamingComputationTask::~StreamingComputationTask ( )

virtual

Standard destructor.

Member Function Documentation

clear_computation_ranges()

void google_dataflow_api::StreamingComputationTask::clear_computation_ranges ( )

inline

Clears the 'computationRanges' attribute.

clear_data_disks()

void google_dataflow_api::StreamingComputationTask::clear_data_disks ( )

inline

Clears the 'dataDisks' attribute.

clear_task_type()

void google_dataflow_api::StreamingComputationTask::clear_task_type ( )

inline

Clears the 'taskType' attribute.

get_computation_ranges()

const client::JsonCppArray<StreamingComputationRanges > google_dataflow_api::StreamingComputationTask::get_computation_ranges

(

)

const

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

get_data_disks()

const client::JsonCppArray<MountedDataDisk > google_dataflow_api::StreamingComputationTask::get_data_disks

(

)

const

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

get_task_type()

const StringPiece google_dataflow_api::StreamingComputationTask::get_task_type ( ) const

inline

Get the value of the 'taskType' attribute.

GetTypeName()

const StringPiece google_dataflow_api::StreamingComputationTask::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns

google_dataflow_api::StreamingComputationTask

has_computation_ranges()

bool google_dataflow_api::StreamingComputationTask::has_computation_ranges ( ) const

inline

Determine if the 'computationRanges' attribute was set.

Returns

true if the 'computationRanges' attribute was set.

has_data_disks()

bool google_dataflow_api::StreamingComputationTask::has_data_disks ( ) const

inline

Determine if the 'dataDisks' attribute was set.

Returns

true if the 'dataDisks' attribute was set.

has_task_type()

bool google_dataflow_api::StreamingComputationTask::has_task_type ( ) const

inline

Determine if the 'taskType' attribute was set.

Returns

true if the 'taskType' attribute was set.

mutable_computationRanges()

client::JsonCppArray<StreamingComputationRanges > google_dataflow_api::StreamingComputationTask::mutable_computationRanges

(

)

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

Contains ranges of a streaming computation this task should apply to.

Returns

The result can be modified to change the attribute value.

mutable_dataDisks()

client::JsonCppArray<MountedDataDisk > google_dataflow_api::StreamingComputationTask::mutable_dataDisks

(

)

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

Describes the set of data disks this task should apply to.

Returns

The result can be modified to change the attribute value.

New()

StreamingComputationTask * google_dataflow_api::StreamingComputationTask::New ( )

static

Creates a new default instance.

Returns

Ownership is passed back to the caller.

set_task_type()

void google_dataflow_api::StreamingComputationTask::set_task_type ( const StringPiece &  value )

inline

Change the 'taskType' attribute.

A type of streaming computation task.

Parameters

[in]

value

The new value.

---

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

• google/dataflow_api/streaming_computation_task.h
• google/dataflow_api/streaming_computation_task.cc