30 #ifndef GOOGLE_DATAFLOW_API_PAR_DO_INSTRUCTION_H_ 31 #define GOOGLE_DATAFLOW_API_PAR_DO_INSTRUCTION_H_ 33 #include "googleapis/base/integral_types.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/instruction_input.h" 39 #include "google/dataflow_api/multi_output_info.h" 40 #include "google/dataflow_api/side_input_info.h" 91 return StringPiece(
"google_dataflow_api::ParDoInstruction");
100 return Storage().isMember(
"input");
107 MutableStorage()->removeMember(
"input");
131 return Storage().isMember(
"multiOutputInfos");
138 MutableStorage()->removeMember(
"multiOutputInfos");
146 const client::JsonCppArray<MultiOutputInfo > get_multi_output_infos()
const;
156 client::JsonCppArray<MultiOutputInfo > mutable_multiOutputInfos();
164 return Storage().isMember(
"numOutputs");
171 MutableStorage()->removeMember(
"numOutputs");
179 const Json::Value& storage = Storage(
"numOutputs");
180 return client::JsonValueToCppValueHelper<int32 >(storage);
191 client::SetJsonValueFromCppValueHelper<int32 >(
192 value, MutableStorage(
"numOutputs"));
201 return Storage().isMember(
"sideInputs");
208 MutableStorage()->removeMember(
"sideInputs");
215 const client::JsonCppArray<SideInputInfo > get_side_inputs()
const;
225 client::JsonCppArray<SideInputInfo > mutable_sideInputs();
233 return Storage().isMember(
"userFn");
240 MutableStorage()->removeMember(
"userFn");
247 const client::JsonCppAssociativeArray<client::JsonCppData >
get_user_fn()
const {
248 const Json::Value& storage = Storage(
"userFn");
249 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
260 Json::Value* storage = MutableStorage(
"userFn");
261 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
268 #endif // GOOGLE_DATAFLOW_API_PAR_DO_INSTRUCTION_H_ void clear_num_outputs()
Definition: par_do_instruction.h:170
bool has_side_inputs() const
Definition: par_do_instruction.h:200
void clear_user_fn()
Definition: par_do_instruction.h:239
void clear_input()
Definition: par_do_instruction.h:106
client::JsonCppAssociativeArray< client::JsonCppData > mutable_userFn()
Definition: par_do_instruction.h:259
const client::JsonCppAssociativeArray< client::JsonCppData > get_user_fn() const
Definition: par_do_instruction.h:247
Definition: approximate_progress.h:40
void set_num_outputs(int32 value)
Definition: par_do_instruction.h:190
bool has_num_outputs() const
Definition: par_do_instruction.h:163
void clear_side_inputs()
Definition: par_do_instruction.h:207
bool has_multi_output_infos() const
Definition: par_do_instruction.h:130
Definition: par_do_instruction.h:57
Definition: approximate_progress.cc:42
void clear_multi_output_infos()
Definition: par_do_instruction.h:137
int32 get_num_outputs() const
Definition: par_do_instruction.h:178
bool has_input() const
Definition: par_do_instruction.h:99
const StringPiece GetTypeName() const
Definition: par_do_instruction.h:90
bool has_user_fn() const
Definition: par_do_instruction.h:232