#include <computation_topology.h>

Inheritance diagram for google_dataflow_api::ComputationTopology:

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

	ComputationTopology (Json::Value *storage)

virtual	~ComputationTopology ()

const StringPiece	GetTypeName () const

bool	has_computation_id () const

void	clear_computation_id ()

const StringPiece	get_computation_id () const

void	set_computation_id (const StringPiece &value)

bool	has_inputs () const

void	clear_inputs ()

const client::JsonCppArray< StreamLocation >	get_inputs () const

client::JsonCppArray< StreamLocation >	mutable_inputs ()

bool	has_key_ranges () const

void	clear_key_ranges ()

const client::JsonCppArray< KeyRangeLocation >	get_key_ranges () const

client::JsonCppArray< KeyRangeLocation >	mutable_keyRanges ()

bool	has_outputs () const

void	clear_outputs ()

const client::JsonCppArray< StreamLocation >	get_outputs () const

client::JsonCppArray< StreamLocation >	mutable_outputs ()

bool	has_state_families () const

void	clear_state_families ()

const client::JsonCppArray< StateFamilyConfig >	get_state_families () const

client::JsonCppArray< StateFamilyConfig >	mutable_stateFamilies ()

bool	has_system_stage_name () const

void	clear_system_stage_name ()

const StringPiece	get_system_stage_name () const

void	set_system_stage_name (const StringPiece &value)

Static Public Member Functions
static ComputationTopology *	New ()

Detailed Description

All configuration data for a particular Computation.

Constructor & Destructor Documentation

◆ ComputationTopology() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

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

◆ ComputationTopology() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

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

◆ ~ComputationTopology()

google_dataflow_api::ComputationTopology::~ComputationTopology ( )

virtual

Standard destructor.

Member Function Documentation

◆ clear_computation_id()

void google_dataflow_api::ComputationTopology::clear_computation_id ( )

inline

Clears the 'computationId' attribute.

◆ clear_inputs()

void google_dataflow_api::ComputationTopology::clear_inputs ( )

inline

Clears the 'inputs' attribute.

◆ clear_key_ranges()

void google_dataflow_api::ComputationTopology::clear_key_ranges ( )

inline

Clears the 'keyRanges' attribute.

◆ clear_outputs()

void google_dataflow_api::ComputationTopology::clear_outputs ( )

inline

Clears the 'outputs' attribute.

◆ clear_state_families()

void google_dataflow_api::ComputationTopology::clear_state_families ( )

inline

Clears the 'stateFamilies' attribute.

◆ clear_system_stage_name()

void google_dataflow_api::ComputationTopology::clear_system_stage_name ( )

inline

Clears the 'systemStageName' attribute.

◆ get_computation_id()

const StringPiece google_dataflow_api::ComputationTopology::get_computation_id ( ) const

inline

Get the value of the 'computationId' attribute.

◆ get_inputs()

const client::JsonCppArray<StreamLocation > google_dataflow_api::ComputationTopology::get_inputs ( ) const

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

◆ get_key_ranges()

const client::JsonCppArray<KeyRangeLocation > google_dataflow_api::ComputationTopology::get_key_ranges ( ) const

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

◆ get_outputs()

const client::JsonCppArray<StreamLocation > google_dataflow_api::ComputationTopology::get_outputs ( ) const

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

◆ get_state_families()

const client::JsonCppArray<StateFamilyConfig > google_dataflow_api::ComputationTopology::get_state_families ( ) const

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

◆ get_system_stage_name()

const StringPiece google_dataflow_api::ComputationTopology::get_system_stage_name ( ) const

inline

Get the value of the 'systemStageName' attribute.

◆ GetTypeName()

const StringPiece google_dataflow_api::ComputationTopology::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns: google_dataflow_api::ComputationTopology

◆ has_computation_id()

bool google_dataflow_api::ComputationTopology::has_computation_id ( ) const

inline

Determine if the 'computationId' attribute was set.

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

◆ has_inputs()

bool google_dataflow_api::ComputationTopology::has_inputs ( ) const

inline

Determine if the 'inputs' attribute was set.

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

◆ has_key_ranges()

bool google_dataflow_api::ComputationTopology::has_key_ranges ( ) const

inline

Determine if the 'keyRanges' attribute was set.

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

◆ has_outputs()

bool google_dataflow_api::ComputationTopology::has_outputs ( ) const

inline

Determine if the 'outputs' attribute was set.

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

◆ has_state_families()

bool google_dataflow_api::ComputationTopology::has_state_families ( ) const

inline

Determine if the 'stateFamilies' attribute was set.

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

◆ has_system_stage_name()

bool google_dataflow_api::ComputationTopology::has_system_stage_name ( ) const

inline

Determine if the 'systemStageName' attribute was set.

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

◆ mutable_inputs()

client::JsonCppArray<StreamLocation > google_dataflow_api::ComputationTopology::mutable_inputs ( )

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

The inputs to the computation.

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

◆ mutable_keyRanges()

client::JsonCppArray<KeyRangeLocation > google_dataflow_api::ComputationTopology::mutable_keyRanges ( )

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

The key ranges processed by the computation.

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

◆ mutable_outputs()

client::JsonCppArray<StreamLocation > google_dataflow_api::ComputationTopology::mutable_outputs ( )

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

The outputs from the computation.

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

◆ mutable_stateFamilies()

client::JsonCppArray<StateFamilyConfig > google_dataflow_api::ComputationTopology::mutable_stateFamilies ( )

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

The state family values.

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

◆ New()

ComputationTopology * google_dataflow_api::ComputationTopology::New ( )

static

Creates a new default instance.

Returns: Ownership is passed back to the caller.

◆ set_computation_id()

void google_dataflow_api::ComputationTopology::set_computation_id ( const StringPiece & value )

inline

Change the 'computationId' attribute.

The ID of the computation.

Parameters

[in] value The new value.

◆ set_system_stage_name()

void google_dataflow_api::ComputationTopology::set_system_stage_name ( const StringPiece & value )

inline

Change the 'systemStageName' attribute.

The system stage name.

Parameters

[in] value The new value.

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

google/dataflow_api/computation_topology.h
google/dataflow_api/computation_topology.cc

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ ComputationTopology() [1/2]

◆ ComputationTopology() [2/2]

◆ ~ComputationTopology()

Member Function Documentation

◆ clear_computation_id()

◆ clear_inputs()

◆ clear_key_ranges()

◆ clear_outputs()

◆ clear_state_families()

◆ clear_system_stage_name()

◆ get_computation_id()

◆ get_inputs()

◆ get_key_ranges()

◆ get_outputs()

◆ get_state_families()

◆ get_system_stage_name()

◆ GetTypeName()

◆ has_computation_id()

◆ has_inputs()

◆ has_key_ranges()

◆ has_outputs()

◆ has_state_families()

◆ has_system_stage_name()

◆ mutable_inputs()

◆ mutable_keyRanges()

◆ mutable_outputs()

◆ mutable_stateFamilies()

◆ New()

◆ set_computation_id()

◆ set_system_stage_name()