dataflow
v1b3
|
#include <streaming_computation_config.h>
Public Member Functions | |
StreamingComputationConfig (const Json::Value &storage) | |
StreamingComputationConfig (Json::Value *storage) | |
virtual | ~StreamingComputationConfig () |
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_instructions () const |
void | clear_instructions () |
const client::JsonCppArray< ParallelInstruction > | get_instructions () const |
client::JsonCppArray< ParallelInstruction > | mutable_instructions () |
bool | has_stage_name () const |
void | clear_stage_name () |
const StringPiece | get_stage_name () const |
void | set_stage_name (const StringPiece &value) |
bool | has_system_name () const |
void | clear_system_name () |
const StringPiece | get_system_name () const |
void | set_system_name (const StringPiece &value) |
bool | has_transform_user_name_to_state_family () const |
void | clear_transform_user_name_to_state_family () |
const client::JsonCppAssociativeArray< string > | get_transform_user_name_to_state_family () const |
client::JsonCppAssociativeArray< string > | mutable_transformUserNameToStateFamily () |
Static Public Member Functions | |
static StreamingComputationConfig * | New () |
Configuration information for a single streaming computation.
|
explicit |
Standard constructor for an immutable data object instance.
[in] | storage | The underlying data storage for this instance. |
|
explicit |
Standard constructor for a mutable data object instance.
[in] | storage | The underlying data storage for this instance. |
|
virtual |
Standard destructor.
|
inline |
Clears the 'computationId
' attribute.
|
inline |
Clears the 'instructions
' attribute.
|
inline |
Clears the 'stageName
' attribute.
|
inline |
Clears the 'systemName
' attribute.
|
inline |
Clears the 'transformUserNameToStateFamily
' attribute.
|
inline |
Get the value of the 'computationId
' attribute.
const client::JsonCppArray<ParallelInstruction > google_dataflow_api::StreamingComputationConfig::get_instructions | ( | ) | const |
Get a reference to the value of the 'instructions
' attribute.
|
inline |
Get the value of the 'stageName
' attribute.
|
inline |
Get the value of the 'systemName
' attribute.
|
inline |
Get a reference to the value of the 'transformUserNameToStateFamily
' attribute.
|
inline |
Returns a string denoting the type of this data object.
|
inline |
Determine if the 'computationId
' attribute was set.
computationId
' attribute was set.
|
inline |
Determine if the 'instructions
' attribute was set.
instructions
' attribute was set.
|
inline |
Determine if the 'stageName
' attribute was set.
stageName
' attribute was set.
|
inline |
Determine if the 'systemName
' attribute was set.
systemName
' attribute was set.
|
inline |
Determine if the 'transformUserNameToStateFamily
' attribute was set.
transformUserNameToStateFamily
' attribute was set. client::JsonCppArray<ParallelInstruction > google_dataflow_api::StreamingComputationConfig::mutable_instructions | ( | ) |
Gets a reference to a mutable value of the 'instructions
' property.
Instructions that comprise the computation.
|
inline |
Gets a reference to a mutable value of the 'transformUserNameToStateFamily
' property.
Map from user name of stateful transforms in this stage to their state family.
|
static |
Creates a new default instance.
|
inline |
Change the 'computationId
' attribute.
Unique identifier for this computation.
[in] | value | The new value. |
|
inline |
Change the 'stageName
' attribute.
Stage name of this computation.
[in] | value | The new value. |
|
inline |
Change the 'systemName
' attribute.
System defined name for this computation.
[in] | value | The new value. |