google_dataflow_api::MapTask Class Reference

#include <map_task.h>

Inheritance diagram for google_dataflow_api::MapTask:

Public Member Functions
	MapTask (const Json::Value &storage)
	MapTask (Json::Value *storage)
virtual	~MapTask ()
const StringPiece	GetTypeName () const
bool	has_counter_prefix () const
void	clear_counter_prefix ()
const StringPiece	get_counter_prefix () const
void	set_counter_prefix (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)

Static Public Member Functions
static MapTask *	New ()

Detailed Description

MapTask consists of an ordered set of instructions, each of which describes one particular low-level operation for the worker to perform in order to accomplish the MapTask's WorkItem.

Each instruction must appear in the list before any instructions which depends on its output.

Constructor & Destructor Documentation

MapTask() [1/2]

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

explicit

Standard constructor for an immutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

MapTask() [2/2]

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

explicit

Standard constructor for a mutable data object instance.

Parameters

[in]

storage

The underlying data storage for this instance.

~MapTask()

google_dataflow_api::MapTask::~MapTask ( )

virtual

Standard destructor.

Member Function Documentation

clear_counter_prefix()

void google_dataflow_api::MapTask::clear_counter_prefix ( )

inline

Clears the 'counterPrefix' attribute.

clear_instructions()

void google_dataflow_api::MapTask::clear_instructions ( )

inline

Clears the 'instructions' attribute.

clear_stage_name()

void google_dataflow_api::MapTask::clear_stage_name ( )

inline

Clears the 'stageName' attribute.

clear_system_name()

void google_dataflow_api::MapTask::clear_system_name ( )

inline

Clears the 'systemName' attribute.

get_counter_prefix()

const StringPiece google_dataflow_api::MapTask::get_counter_prefix ( ) const

inline

Get the value of the 'counterPrefix' attribute.

get_instructions()

const client::JsonCppArray<ParallelInstruction > google_dataflow_api::MapTask::get_instructions

(

)

const

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

get_stage_name()

const StringPiece google_dataflow_api::MapTask::get_stage_name ( ) const

inline

Get the value of the 'stageName' attribute.

get_system_name()

const StringPiece google_dataflow_api::MapTask::get_system_name ( ) const

inline

Get the value of the 'systemName' attribute.

GetTypeName()

const StringPiece google_dataflow_api::MapTask::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns

google_dataflow_api::MapTask

has_counter_prefix()

bool google_dataflow_api::MapTask::has_counter_prefix ( ) const

inline

Determine if the 'counterPrefix' attribute was set.

Returns

true if the 'counterPrefix' attribute was set.

has_instructions()

bool google_dataflow_api::MapTask::has_instructions ( ) const

inline

Determine if the 'instructions' attribute was set.

Returns

true if the 'instructions' attribute was set.

has_stage_name()

bool google_dataflow_api::MapTask::has_stage_name ( ) const

inline

Determine if the 'stageName' attribute was set.

Returns

true if the 'stageName' attribute was set.

has_system_name()

bool google_dataflow_api::MapTask::has_system_name ( ) const

inline

Determine if the 'systemName' attribute was set.

Returns

true if the 'systemName' attribute was set.

mutable_instructions()

client::JsonCppArray<ParallelInstruction > google_dataflow_api::MapTask::mutable_instructions

(

)

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

The instructions in the MapTask.

Returns

The result can be modified to change the attribute value.

New()

MapTask * google_dataflow_api::MapTask::New ( )

static

Creates a new default instance.

Returns

Ownership is passed back to the caller.

set_counter_prefix()

void google_dataflow_api::MapTask::set_counter_prefix ( const StringPiece &  value )

inline

Change the 'counterPrefix' attribute.

Counter prefix that can be used to prefix counters. Not currently used in Dataflow.

Parameters

[in]

value

The new value.

set_stage_name()

void google_dataflow_api::MapTask::set_stage_name ( const StringPiece &  value )

inline

Change the 'stageName' attribute.

System-defined name of the stage containing this MapTask. Unique across the workflow.

Parameters

[in]

value

The new value.

set_system_name()

void google_dataflow_api::MapTask::set_system_name ( const StringPiece &  value )

inline

Change the 'systemName' attribute.

System-defined name of this MapTask. Unique across the workflow.

Parameters

[in]

value

The new value.

---

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

• google/dataflow_api/map_task.h
• google/dataflow_api/map_task.cc