#include <topology_config.h>

Inheritance diagram for google_dataflow_api::TopologyConfig:

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

	TopologyConfig (Json::Value *storage)

virtual	~TopologyConfig ()

const StringPiece	GetTypeName () const

bool	has_computations () const

void	clear_computations ()

const client::JsonCppArray< ComputationTopology >	get_computations () const

client::JsonCppArray< ComputationTopology >	mutable_computations ()

bool	has_data_disk_assignments () const

void	clear_data_disk_assignments ()

const client::JsonCppArray< DataDiskAssignment >	get_data_disk_assignments () const

client::JsonCppArray< DataDiskAssignment >	mutable_dataDiskAssignments ()

bool	has_forwarding_key_bits () const

void	clear_forwarding_key_bits ()

int32	get_forwarding_key_bits () const

void	set_forwarding_key_bits (int32 value)

bool	has_persistent_state_version () const

void	clear_persistent_state_version ()

int32	get_persistent_state_version () const

void	set_persistent_state_version (int32 value)

bool	has_user_stage_to_computation_name_map () const

void	clear_user_stage_to_computation_name_map ()

const client::JsonCppAssociativeArray< string >	get_user_stage_to_computation_name_map () const

client::JsonCppAssociativeArray< string >	mutable_userStageToComputationNameMap ()

Static Public Member Functions
static TopologyConfig *	New ()

Detailed Description

Global topology of the streaming Dataflow job, including all computations and their sharded locations.

Constructor & Destructor Documentation

◆ TopologyConfig() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

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

◆ TopologyConfig() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

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

◆ ~TopologyConfig()

google_dataflow_api::TopologyConfig::~TopologyConfig ( )

virtual

Standard destructor.

Member Function Documentation

◆ clear_computations()

void google_dataflow_api::TopologyConfig::clear_computations ( )

inline

Clears the 'computations' attribute.

◆ clear_data_disk_assignments()

void google_dataflow_api::TopologyConfig::clear_data_disk_assignments ( )

inline

Clears the 'dataDiskAssignments' attribute.

◆ clear_forwarding_key_bits()

void google_dataflow_api::TopologyConfig::clear_forwarding_key_bits ( )

inline

Clears the 'forwardingKeyBits' attribute.

◆ clear_persistent_state_version()

void google_dataflow_api::TopologyConfig::clear_persistent_state_version ( )

inline

Clears the 'persistentStateVersion' attribute.

◆ clear_user_stage_to_computation_name_map()

void google_dataflow_api::TopologyConfig::clear_user_stage_to_computation_name_map ( )

inline

Clears the 'userStageToComputationNameMap' attribute.

◆ get_computations()

const client::JsonCppArray<ComputationTopology > google_dataflow_api::TopologyConfig::get_computations ( ) const

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

◆ get_data_disk_assignments()

const client::JsonCppArray<DataDiskAssignment > google_dataflow_api::TopologyConfig::get_data_disk_assignments ( ) const

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

◆ get_forwarding_key_bits()

int32 google_dataflow_api::TopologyConfig::get_forwarding_key_bits ( ) const

inline

Get the value of the 'forwardingKeyBits' attribute.

◆ get_persistent_state_version()

int32 google_dataflow_api::TopologyConfig::get_persistent_state_version ( ) const

inline

Get the value of the 'persistentStateVersion' attribute.

◆ get_user_stage_to_computation_name_map()

const client::JsonCppAssociativeArray<string > google_dataflow_api::TopologyConfig::get_user_stage_to_computation_name_map ( ) const

inline

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

◆ GetTypeName()

const StringPiece google_dataflow_api::TopologyConfig::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns: google_dataflow_api::TopologyConfig

◆ has_computations()

bool google_dataflow_api::TopologyConfig::has_computations ( ) const

inline

Determine if the 'computations' attribute was set.

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

◆ has_data_disk_assignments()

bool google_dataflow_api::TopologyConfig::has_data_disk_assignments ( ) const

inline

Determine if the 'dataDiskAssignments' attribute was set.

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

◆ has_forwarding_key_bits()

bool google_dataflow_api::TopologyConfig::has_forwarding_key_bits ( ) const

inline

Determine if the 'forwardingKeyBits' attribute was set.

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

◆ has_persistent_state_version()

bool google_dataflow_api::TopologyConfig::has_persistent_state_version ( ) const

inline

Determine if the 'persistentStateVersion' attribute was set.

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

◆ has_user_stage_to_computation_name_map()

bool google_dataflow_api::TopologyConfig::has_user_stage_to_computation_name_map ( ) const

inline

Determine if the 'userStageToComputationNameMap' attribute was set.

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

◆ mutable_computations()

client::JsonCppArray<ComputationTopology > google_dataflow_api::TopologyConfig::mutable_computations ( )

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

The computations associated with a streaming Dataflow job.

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

◆ mutable_dataDiskAssignments()

client::JsonCppArray<DataDiskAssignment > google_dataflow_api::TopologyConfig::mutable_dataDiskAssignments ( )

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

The disks assigned to a streaming Dataflow job.

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

◆ mutable_userStageToComputationNameMap()

client::JsonCppAssociativeArray<string > google_dataflow_api::TopologyConfig::mutable_userStageToComputationNameMap ( )

inline

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

Maps user stage names to stable computation names.

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

◆ New()

TopologyConfig * google_dataflow_api::TopologyConfig::New ( )

static

Creates a new default instance.

Returns: Ownership is passed back to the caller.

◆ set_forwarding_key_bits()

void google_dataflow_api::TopologyConfig::set_forwarding_key_bits ( int32 value )

inline

Change the 'forwardingKeyBits' attribute.

The size (in bits) of keys that will be assigned to source messages.

Parameters

[in] value The new value.

◆ set_persistent_state_version()

void google_dataflow_api::TopologyConfig::set_persistent_state_version ( int32 value )

inline

Change the 'persistentStateVersion' attribute.

Version number for persistent state.

Parameters

[in] value The new value.

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

google/dataflow_api/topology_config.h
google/dataflow_api/topology_config.cc

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ TopologyConfig() [1/2]

◆ TopologyConfig() [2/2]

◆ ~TopologyConfig()

Member Function Documentation

◆ clear_computations()

◆ clear_data_disk_assignments()

◆ clear_forwarding_key_bits()

◆ clear_persistent_state_version()

◆ clear_user_stage_to_computation_name_map()

◆ get_computations()

◆ get_data_disk_assignments()

◆ get_forwarding_key_bits()

◆ get_persistent_state_version()

◆ get_user_stage_to_computation_name_map()

◆ GetTypeName()

◆ has_computations()

◆ has_data_disk_assignments()

◆ has_forwarding_key_bits()

◆ has_persistent_state_version()

◆ has_user_stage_to_computation_name_map()

◆ mutable_computations()

◆ mutable_dataDiskAssignments()

◆ mutable_userStageToComputationNameMap()

◆ New()

◆ set_forwarding_key_bits()

◆ set_persistent_state_version()