30 #ifndef GOOGLE_DATAFLOW_API_PARTIAL_GROUP_BY_KEY_INSTRUCTION_H_ 31 #define GOOGLE_DATAFLOW_API_PARTIAL_GROUP_BY_KEY_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/instruction_input.h" 39 #include "google/dataflow_api/side_input_info.h" 88 return StringPiece(
"google_dataflow_api::PartialGroupByKeyInstruction");
97 return Storage().isMember(
"input");
104 MutableStorage()->removeMember(
"input");
128 return Storage().isMember(
"inputElementCodec");
135 MutableStorage()->removeMember(
"inputElementCodec");
144 const Json::Value& storage = Storage(
"inputElementCodec");
145 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
157 Json::Value* storage = MutableStorage(
"inputElementCodec");
158 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
169 return Storage().isMember(
"originalCombineValuesInputStoreName");
176 MutableStorage()->removeMember(
"originalCombineValuesInputStoreName");
185 const Json::Value& v = Storage(
"originalCombineValuesInputStoreName");
186 if (v == Json::Value::null)
return StringPiece(
"");
187 return StringPiece(v.asCString());
199 *MutableStorage(
"originalCombineValuesInputStoreName") = value.data();
210 return Storage().isMember(
"originalCombineValuesStepName");
217 MutableStorage()->removeMember(
"originalCombineValuesStepName");
226 const Json::Value& v = Storage(
"originalCombineValuesStepName");
227 if (v == Json::Value::null)
return StringPiece(
"");
228 return StringPiece(v.asCString());
240 *MutableStorage(
"originalCombineValuesStepName") = value.data();
249 return Storage().isMember(
"sideInputs");
256 MutableStorage()->removeMember(
"sideInputs");
263 const client::JsonCppArray<SideInputInfo > get_side_inputs()
const;
273 client::JsonCppArray<SideInputInfo > mutable_sideInputs();
281 return Storage().isMember(
"valueCombiningFn");
288 MutableStorage()->removeMember(
"valueCombiningFn");
297 const Json::Value& storage = Storage(
"valueCombiningFn");
298 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
310 Json::Value* storage = MutableStorage(
"valueCombiningFn");
311 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
318 #endif // GOOGLE_DATAFLOW_API_PARTIAL_GROUP_BY_KEY_INSTRUCTION_H_ const StringPiece get_original_combine_values_step_name() const
Definition: partial_group_by_key_instruction.h:225
bool has_input_element_codec() const
Definition: partial_group_by_key_instruction.h:127
client::JsonCppAssociativeArray< client::JsonCppData > mutable_valueCombiningFn()
Definition: partial_group_by_key_instruction.h:309
void clear_value_combining_fn()
Definition: partial_group_by_key_instruction.h:287
const client::JsonCppAssociativeArray< client::JsonCppData > get_value_combining_fn() const
Definition: partial_group_by_key_instruction.h:296
bool has_original_combine_values_input_store_name() const
Definition: partial_group_by_key_instruction.h:168
bool has_value_combining_fn() const
Definition: partial_group_by_key_instruction.h:280
void clear_original_combine_values_input_store_name()
Definition: partial_group_by_key_instruction.h:175
bool has_side_inputs() const
Definition: partial_group_by_key_instruction.h:248
void set_original_combine_values_step_name(const StringPiece &value)
Definition: partial_group_by_key_instruction.h:239
client::JsonCppAssociativeArray< client::JsonCppData > mutable_inputElementCodec()
Definition: partial_group_by_key_instruction.h:156
bool has_original_combine_values_step_name() const
Definition: partial_group_by_key_instruction.h:209
bool has_input() const
Definition: partial_group_by_key_instruction.h:96
const StringPiece get_original_combine_values_input_store_name() const
Definition: partial_group_by_key_instruction.h:184
void clear_side_inputs()
Definition: partial_group_by_key_instruction.h:255
Definition: approximate_progress.h:40
const client::JsonCppAssociativeArray< client::JsonCppData > get_input_element_codec() const
Definition: partial_group_by_key_instruction.h:143
Definition: partial_group_by_key_instruction.h:54
void clear_input()
Definition: partial_group_by_key_instruction.h:103
void clear_input_element_codec()
Definition: partial_group_by_key_instruction.h:134
void clear_original_combine_values_step_name()
Definition: partial_group_by_key_instruction.h:216
Definition: approximate_progress.cc:42
void set_original_combine_values_input_store_name(const StringPiece &value)
Definition: partial_group_by_key_instruction.h:198
const StringPiece GetTypeName() const
Definition: partial_group_by_key_instruction.h:87