#include <par_do_instruction.h>

Inheritance diagram for google_dataflow_api::ParDoInstruction:

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

	ParDoInstruction (Json::Value *storage)

virtual	~ParDoInstruction ()

const StringPiece	GetTypeName () const

bool	has_input () const

void	clear_input ()

const InstructionInput	get_input () const

InstructionInput	mutable_input ()

bool	has_multi_output_infos () const

void	clear_multi_output_infos ()

const client::JsonCppArray< MultiOutputInfo >	get_multi_output_infos () const

client::JsonCppArray< MultiOutputInfo >	mutable_multiOutputInfos ()

bool	has_num_outputs () const

void	clear_num_outputs ()

int32	get_num_outputs () const

void	set_num_outputs (int32 value)

bool	has_side_inputs () const

void	clear_side_inputs ()

const client::JsonCppArray< SideInputInfo >	get_side_inputs () const

client::JsonCppArray< SideInputInfo >	mutable_sideInputs ()

bool	has_user_fn () const

void	clear_user_fn ()

const client::JsonCppAssociativeArray< client::JsonCppData >	get_user_fn () const

client::JsonCppAssociativeArray< client::JsonCppData >	mutable_userFn ()

Static Public Member Functions
static ParDoInstruction *	New ()

Detailed Description

An instruction that does a ParDo operation. Takes one main input and zero or more side inputs, and produces zero or more outputs. Runs user code.

Constructor & Destructor Documentation

◆ ParDoInstruction() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

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

◆ ParDoInstruction() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

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

◆ ~ParDoInstruction()

google_dataflow_api::ParDoInstruction::~ParDoInstruction ( )

virtual

Standard destructor.

Member Function Documentation

◆ clear_input()

void google_dataflow_api::ParDoInstruction::clear_input ( )

inline

Clears the 'input' attribute.

◆ clear_multi_output_infos()

void google_dataflow_api::ParDoInstruction::clear_multi_output_infos ( )

inline

Clears the 'multiOutputInfos' attribute.

◆ clear_num_outputs()

void google_dataflow_api::ParDoInstruction::clear_num_outputs ( )

inline

Clears the 'numOutputs' attribute.

◆ clear_side_inputs()

void google_dataflow_api::ParDoInstruction::clear_side_inputs ( )

inline

Clears the 'sideInputs' attribute.

◆ clear_user_fn()

void google_dataflow_api::ParDoInstruction::clear_user_fn ( )

inline

Clears the 'userFn' attribute.

◆ get_input()

const InstructionInput google_dataflow_api::ParDoInstruction::get_input ( ) const

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

◆ get_multi_output_infos()

const client::JsonCppArray<MultiOutputInfo > google_dataflow_api::ParDoInstruction::get_multi_output_infos ( ) const

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

◆ get_num_outputs()

int32 google_dataflow_api::ParDoInstruction::get_num_outputs ( ) const

inline

Get the value of the 'numOutputs' attribute.

◆ get_side_inputs()

const client::JsonCppArray<SideInputInfo > google_dataflow_api::ParDoInstruction::get_side_inputs ( ) const

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

◆ get_user_fn()

const client::JsonCppAssociativeArray<client::JsonCppData > google_dataflow_api::ParDoInstruction::get_user_fn ( ) const

inline

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

◆ GetTypeName()

const StringPiece google_dataflow_api::ParDoInstruction::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns: google_dataflow_api::ParDoInstruction

◆ has_input()

bool google_dataflow_api::ParDoInstruction::has_input ( ) const

inline

Determine if the 'input' attribute was set.

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

◆ has_multi_output_infos()

bool google_dataflow_api::ParDoInstruction::has_multi_output_infos ( ) const

inline

Determine if the 'multiOutputInfos' attribute was set.

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

◆ has_num_outputs()

bool google_dataflow_api::ParDoInstruction::has_num_outputs ( ) const

inline

Determine if the 'numOutputs' attribute was set.

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

◆ has_side_inputs()

bool google_dataflow_api::ParDoInstruction::has_side_inputs ( ) const

inline

Determine if the 'sideInputs' attribute was set.

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

◆ has_user_fn()

bool google_dataflow_api::ParDoInstruction::has_user_fn ( ) const

inline

Determine if the 'userFn' attribute was set.

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

◆ mutable_input()

InstructionInput google_dataflow_api::ParDoInstruction::mutable_input ( )

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

The input.

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

◆ mutable_multiOutputInfos()

client::JsonCppArray<MultiOutputInfo > google_dataflow_api::ParDoInstruction::mutable_multiOutputInfos ( )

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

Information about each of the outputs, if user_fn is a MultiDoFn.

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

◆ mutable_sideInputs()

client::JsonCppArray<SideInputInfo > google_dataflow_api::ParDoInstruction::mutable_sideInputs ( )

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

Zero or more side inputs.

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

◆ mutable_userFn()

client::JsonCppAssociativeArray<client::JsonCppData > google_dataflow_api::ParDoInstruction::mutable_userFn ( )

inline

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

The user function to invoke.

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

◆ New()

ParDoInstruction * google_dataflow_api::ParDoInstruction::New ( )

static

Creates a new default instance.

Returns: Ownership is passed back to the caller.

◆ set_num_outputs()

void google_dataflow_api::ParDoInstruction::set_num_outputs ( int32 value )

inline

Change the 'numOutputs' attribute.

The number of outputs.

Parameters

[in] value The new value.

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

google/dataflow_api/par_do_instruction.h
google/dataflow_api/par_do_instruction.cc

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ ParDoInstruction() [1/2]

◆ ParDoInstruction() [2/2]

◆ ~ParDoInstruction()

Member Function Documentation

◆ clear_input()

◆ clear_multi_output_infos()

◆ clear_num_outputs()

◆ clear_side_inputs()

◆ clear_user_fn()

◆ get_input()

◆ get_multi_output_infos()

◆ get_num_outputs()

◆ get_side_inputs()

◆ get_user_fn()

◆ GetTypeName()

◆ has_input()

◆ has_multi_output_infos()

◆ has_num_outputs()

◆ has_side_inputs()

◆ has_user_fn()

◆ mutable_input()

◆ mutable_multiOutputInfos()

◆ mutable_sideInputs()

◆ mutable_userFn()

◆ New()

◆ set_num_outputs()