30 #ifndef GOOGLE_DATAFLOW_API_PARALLEL_INSTRUCTION_H_ 31 #define GOOGLE_DATAFLOW_API_PARALLEL_INSTRUCTION_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/flatten_instruction.h" 39 #include "google/dataflow_api/instruction_output.h" 40 #include "google/dataflow_api/par_do_instruction.h" 41 #include "google/dataflow_api/partial_group_by_key_instruction.h" 42 #include "google/dataflow_api/read_instruction.h" 43 #include "google/dataflow_api/write_instruction.h" 91 return StringPiece(
"google_dataflow_api::ParallelInstruction");
100 return Storage().isMember(
"flatten");
107 MutableStorage()->removeMember(
"flatten");
131 return Storage().isMember(
"name");
138 MutableStorage()->removeMember(
"name");
146 const Json::Value& v = Storage(
"name");
147 if (v == Json::Value::null)
return StringPiece(
"");
148 return StringPiece(v.asCString());
159 *MutableStorage(
"name") = value.data();
168 return Storage().isMember(
"originalName");
175 MutableStorage()->removeMember(
"originalName");
183 const Json::Value& v = Storage(
"originalName");
184 if (v == Json::Value::null)
return StringPiece(
"");
185 return StringPiece(v.asCString());
196 *MutableStorage(
"originalName") = value.data();
205 return Storage().isMember(
"outputs");
212 MutableStorage()->removeMember(
"outputs");
219 const client::JsonCppArray<InstructionOutput > get_outputs()
const;
228 client::JsonCppArray<InstructionOutput > mutable_outputs();
236 return Storage().isMember(
"parDo");
243 MutableStorage()->removeMember(
"parDo");
267 return Storage().isMember(
"partialGroupByKey");
274 MutableStorage()->removeMember(
"partialGroupByKey");
300 return Storage().isMember(
"read");
307 MutableStorage()->removeMember(
"read");
331 return Storage().isMember(
"systemName");
338 MutableStorage()->removeMember(
"systemName");
346 const Json::Value& v = Storage(
"systemName");
347 if (v == Json::Value::null)
return StringPiece(
"");
348 return StringPiece(v.asCString());
360 *MutableStorage(
"systemName") = value.data();
369 return Storage().isMember(
"write");
376 MutableStorage()->removeMember(
"write");
398 #endif // GOOGLE_DATAFLOW_API_PARALLEL_INSTRUCTION_H_ void clear_par_do()
Definition: parallel_instruction.h:242
bool has_partial_group_by_key() const
Definition: parallel_instruction.h:266
void set_name(const StringPiece &value)
Definition: parallel_instruction.h:158
void clear_system_name()
Definition: parallel_instruction.h:337
void clear_outputs()
Definition: parallel_instruction.h:211
void clear_partial_group_by_key()
Definition: parallel_instruction.h:273
void set_original_name(const StringPiece &value)
Definition: parallel_instruction.h:195
const StringPiece get_name() const
Definition: parallel_instruction.h:145
void clear_write()
Definition: parallel_instruction.h:375
void set_system_name(const StringPiece &value)
Definition: parallel_instruction.h:359
const StringPiece GetTypeName() const
Definition: parallel_instruction.h:90
void clear_read()
Definition: parallel_instruction.h:306
void clear_name()
Definition: parallel_instruction.h:137
bool has_name() const
Definition: parallel_instruction.h:130
Definition: approximate_progress.h:40
void clear_original_name()
Definition: parallel_instruction.h:174
bool has_original_name() const
Definition: parallel_instruction.h:167
Definition: read_instruction.h:52
bool has_write() const
Definition: parallel_instruction.h:368
void clear_flatten()
Definition: parallel_instruction.h:106
Definition: partial_group_by_key_instruction.h:54
const StringPiece get_original_name() const
Definition: parallel_instruction.h:182
bool has_par_do() const
Definition: parallel_instruction.h:235
bool has_system_name() const
Definition: parallel_instruction.h:330
Definition: par_do_instruction.h:57
bool has_outputs() const
Definition: parallel_instruction.h:204
Definition: approximate_progress.cc:42
Definition: flatten_instruction.h:51
const StringPiece get_system_name() const
Definition: parallel_instruction.h:345
bool has_read() const
Definition: parallel_instruction.h:299
bool has_flatten() const
Definition: parallel_instruction.h:99
Definition: parallel_instruction.h:57
Definition: write_instruction.h:53