google_dataflow_api::ReportedParallelism Class Reference

#include <reported_parallelism.h>

Inheritance diagram for google_dataflow_api::ReportedParallelism:

Public Member Functions
	ReportedParallelism (const Json::Value &storage)
	ReportedParallelism (Json::Value *storage)
virtual	~ReportedParallelism ()
const StringPiece	GetTypeName () const
bool	has_is_infinite () const
void	clear_is_infinite ()
bool	get_is_infinite () const
void	set_is_infinite (bool value)
bool	has_value () const
void	clear_value ()
double	get_value () const
void	set_value (double value)

Static Public Member Functions
static ReportedParallelism *	New ()

Detailed Description

Represents the level of parallelism in a WorkItem's input, reported by the worker.

Constructor & Destructor Documentation

ReportedParallelism() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

ReportedParallelism() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

~ReportedParallelism()

google_dataflow_api::ReportedParallelism::~ReportedParallelism ( )

virtual

Standard destructor.

Member Function Documentation

clear_is_infinite()

void google_dataflow_api::ReportedParallelism::clear_is_infinite ( )

inline

Clears the 'isInfinite' attribute.

clear_value()

void google_dataflow_api::ReportedParallelism::clear_value ( )

inline

Clears the 'value' attribute.

get_is_infinite()

bool google_dataflow_api::ReportedParallelism::get_is_infinite ( ) const

inline

Get the value of the 'isInfinite' attribute.

get_value()

double google_dataflow_api::ReportedParallelism::get_value ( ) const

inline

Get the value of the 'value' attribute.

GetTypeName()

const StringPiece google_dataflow_api::ReportedParallelism::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns

google_dataflow_api::ReportedParallelism

has_is_infinite()

bool google_dataflow_api::ReportedParallelism::has_is_infinite ( ) const

inline

Determine if the 'isInfinite' attribute was set.

Returns

true if the 'isInfinite' attribute was set.

has_value()

bool google_dataflow_api::ReportedParallelism::has_value ( ) const

inline

Determine if the 'value' attribute was set.

Returns

true if the 'value' attribute was set.

New()

ReportedParallelism * google_dataflow_api::ReportedParallelism::New ( )

static

Creates a new default instance.

Returns

Ownership is passed back to the caller.

set_is_infinite()

void google_dataflow_api::ReportedParallelism::set_is_infinite ( bool  value )

inline

Change the 'isInfinite' attribute.

Specifies whether the parallelism is infinite. If true, "value" is ignored. Infinite parallelism means the service will assume that the work item can always be split into more non-empty work items by dynamic splitting. This is a work-around for lack of support for infinity by the current JSON-based Java RPC stack.

Parameters

[in]

value

The new value.

set_value()

void google_dataflow_api::ReportedParallelism::set_value ( double  value )

inline

Change the 'value' attribute.

Specifies the level of parallelism in case it is finite.

Parameters

[in]

value

The new value.

---

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

• google/dataflow_api/reported_parallelism.h
• google/dataflow_api/reported_parallelism.cc