30 #ifndef GOOGLE_DATAFLOW_API_SEQ_MAP_TASK_H_ 31 #define GOOGLE_DATAFLOW_API_SEQ_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/seq_map_task_output_info.h" 39 #include "google/dataflow_api/side_input_info.h" 67 explicit SeqMapTask(
const Json::Value& storage);
87 return StringPiece(
"google_dataflow_api::SeqMapTask");
96 return Storage().isMember(
"inputs");
103 MutableStorage()->removeMember(
"inputs");
110 const client::JsonCppArray<SideInputInfo > get_inputs()
const;
119 client::JsonCppArray<SideInputInfo > mutable_inputs();
127 return Storage().isMember(
"name");
134 MutableStorage()->removeMember(
"name");
142 const Json::Value& v = Storage(
"name");
143 if (v == Json::Value::null)
return StringPiece(
"");
144 return StringPiece(v.asCString());
155 *MutableStorage(
"name") = value.data();
164 return Storage().isMember(
"outputInfos");
171 MutableStorage()->removeMember(
"outputInfos");
178 const client::JsonCppArray<SeqMapTaskOutputInfo > get_output_infos()
const;
188 client::JsonCppArray<SeqMapTaskOutputInfo > mutable_outputInfos();
196 return Storage().isMember(
"stageName");
203 MutableStorage()->removeMember(
"stageName");
211 const Json::Value& v = Storage(
"stageName");
212 if (v == Json::Value::null)
return StringPiece(
"");
213 return StringPiece(v.asCString());
225 *MutableStorage(
"stageName") = value.data();
234 return Storage().isMember(
"systemName");
241 MutableStorage()->removeMember(
"systemName");
249 const Json::Value& v = Storage(
"systemName");
250 if (v == Json::Value::null)
return StringPiece(
"");
251 return StringPiece(v.asCString());
263 *MutableStorage(
"systemName") = value.data();
272 return Storage().isMember(
"userFn");
279 MutableStorage()->removeMember(
"userFn");
286 const client::JsonCppAssociativeArray<client::JsonCppData >
get_user_fn()
const {
287 const Json::Value& storage = Storage(
"userFn");
288 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
299 Json::Value* storage = MutableStorage(
"userFn");
300 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
307 #endif // GOOGLE_DATAFLOW_API_SEQ_MAP_TASK_H_ client::JsonCppAssociativeArray< client::JsonCppData > mutable_userFn()
Definition: seq_map_task.h:298
bool has_system_name() const
Definition: seq_map_task.h:233
Definition: seq_map_task.h:53
const client::JsonCppAssociativeArray< client::JsonCppData > get_user_fn() const
Definition: seq_map_task.h:286
void clear_output_infos()
Definition: seq_map_task.h:170
void set_name(const StringPiece &value)
Definition: seq_map_task.h:154
bool has_output_infos() const
Definition: seq_map_task.h:163
bool has_inputs() const
Definition: seq_map_task.h:95
const StringPiece get_system_name() const
Definition: seq_map_task.h:248
bool has_name() const
Definition: seq_map_task.h:126
void clear_name()
Definition: seq_map_task.h:133
void clear_system_name()
Definition: seq_map_task.h:240
bool has_stage_name() const
Definition: seq_map_task.h:195
void set_stage_name(const StringPiece &value)
Definition: seq_map_task.h:224
const StringPiece get_name() const
Definition: seq_map_task.h:141
bool has_user_fn() const
Definition: seq_map_task.h:271
Definition: approximate_progress.h:40
void clear_stage_name()
Definition: seq_map_task.h:202
const StringPiece get_stage_name() const
Definition: seq_map_task.h:210
void set_system_name(const StringPiece &value)
Definition: seq_map_task.h:262
const StringPiece GetTypeName() const
Definition: seq_map_task.h:86
Definition: approximate_progress.cc:42
void clear_user_fn()
Definition: seq_map_task.h:278
void clear_inputs()
Definition: seq_map_task.h:102