30 #ifndef GOOGLE_DATAFLOW_API_MAP_TASK_H_ 31 #define GOOGLE_DATAFLOW_API_MAP_TASK_H_ 34 #include "googleapis/base/macros.h" 35 #include "googleapis/client/data/jsoncpp_data.h" 36 #include "googleapis/strings/stringpiece.h" 38 #include "google/dataflow_api/parallel_instruction.h" 57 class MapTask :
public client::JsonCppData {
71 explicit MapTask(
const Json::Value& storage);
78 explicit MapTask(Json::Value* storage);
91 return StringPiece(
"google_dataflow_api::MapTask");
100 return Storage().isMember(
"counterPrefix");
107 MutableStorage()->removeMember(
"counterPrefix");
115 const Json::Value& v = Storage(
"counterPrefix");
116 if (v == Json::Value::null)
return StringPiece(
"");
117 return StringPiece(v.asCString());
129 *MutableStorage(
"counterPrefix") = value.data();
138 return Storage().isMember(
"instructions");
145 MutableStorage()->removeMember(
"instructions");
152 const client::JsonCppArray<ParallelInstruction > get_instructions()
const;
162 client::JsonCppArray<ParallelInstruction > mutable_instructions();
170 return Storage().isMember(
"stageName");
177 MutableStorage()->removeMember(
"stageName");
185 const Json::Value& v = Storage(
"stageName");
186 if (v == Json::Value::null)
return StringPiece(
"");
187 return StringPiece(v.asCString());
199 *MutableStorage(
"stageName") = value.data();
208 return Storage().isMember(
"systemName");
215 MutableStorage()->removeMember(
"systemName");
223 const Json::Value& v = Storage(
"systemName");
224 if (v == Json::Value::null)
return StringPiece(
"");
225 return StringPiece(v.asCString());
237 *MutableStorage(
"systemName") = value.data();
241 void operator=(
const MapTask&);
244 #endif // GOOGLE_DATAFLOW_API_MAP_TASK_H_ const StringPiece get_counter_prefix() const
Definition: map_task.h:114
bool has_stage_name() const
Definition: map_task.h:169
void clear_instructions()
Definition: map_task.h:144
bool has_counter_prefix() const
Definition: map_task.h:99
const StringPiece get_stage_name() const
Definition: map_task.h:184
const StringPiece get_system_name() const
Definition: map_task.h:222
Definition: map_task.h:57
bool has_instructions() const
Definition: map_task.h:137
const StringPiece GetTypeName() const
Definition: map_task.h:90
Definition: approximate_progress.h:40
void clear_counter_prefix()
Definition: map_task.h:106
void set_counter_prefix(const StringPiece &value)
Definition: map_task.h:128
void clear_stage_name()
Definition: map_task.h:176
void set_stage_name(const StringPiece &value)
Definition: map_task.h:198
Definition: approximate_progress.cc:42
bool has_system_name() const
Definition: map_task.h:207
void set_system_name(const StringPiece &value)
Definition: map_task.h:236
void clear_system_name()
Definition: map_task.h:214