dataflow  v1b3
partial_group_by_key_instruction.h
1 // Copyright 2010 Google Inc.
2 //
3 // Licensed under the Apache License, Version 2.0 (the "License"); you may not
4 // use this file except in compliance with the License. You may obtain a copy of
5 // the License at
6 //
7 // http://www.apache.org/licenses/LICENSE-2.0
8 //
9 // Unless required by applicable law or agreed to in writing, software
10 // distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
11 // WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
12 // License for the specific language governing permissions and limitations under
13 // the License.
14 
15 // This code was generated by google-apis-code-generator 1.5.1
16 // Build date: 2018-10-08 17:45:39 UTC
17 // on: 2020-03-19, 02:23:49 UTC
18 // C++ generator version: 0.1.4
19 
20 // ----------------------------------------------------------------------------
21 // NOTE: This file is generated from Google APIs Discovery Service.
22 // Service:
23 // Dataflow API (dataflow/v1b3)
24 // Generated from:
25 // Version: v1b3
26 // Revision: 302
27 // Generated by:
28 // Tool: google-apis-code-generator 1.5.1
29 // C++: 0.1.4
30 #ifndef GOOGLE_DATAFLOW_API_PARTIAL_GROUP_BY_KEY_INSTRUCTION_H_
31 #define GOOGLE_DATAFLOW_API_PARTIAL_GROUP_BY_KEY_INSTRUCTION_H_
32 
33 #include <string>
34 #include "googleapis/base/macros.h"
35 #include "googleapis/client/data/jsoncpp_data.h"
36 #include "googleapis/strings/stringpiece.h"
37 
38 #include "google/dataflow_api/instruction_input.h"
39 #include "google/dataflow_api/side_input_info.h"
40 
41 namespace Json {
42 class Value;
43 } // namespace Json
44 
45 namespace google_dataflow_api {
46 using namespace googleapis;
47 
54 class PartialGroupByKeyInstruction : public client::JsonCppData {
55  public:
61  static PartialGroupByKeyInstruction* New();
62 
68  explicit PartialGroupByKeyInstruction(const Json::Value& storage);
69 
75  explicit PartialGroupByKeyInstruction(Json::Value* storage);
76 
81 
87  const StringPiece GetTypeName() const {
88  return StringPiece("google_dataflow_api::PartialGroupByKeyInstruction");
89  }
90 
96  bool has_input() const {
97  return Storage().isMember("input");
98  }
99 
103  void clear_input() {
104  MutableStorage()->removeMember("input");
105  }
106 
107 
111  const InstructionInput get_input() const;
112 
120  InstructionInput mutable_input();
121 
127  bool has_input_element_codec() const {
128  return Storage().isMember("inputElementCodec");
129  }
130 
135  MutableStorage()->removeMember("inputElementCodec");
136  }
137 
138 
143  const client::JsonCppAssociativeArray<client::JsonCppData > get_input_element_codec() const {
144  const Json::Value& storage = Storage("inputElementCodec");
145  return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
146  }
147 
156  client::JsonCppAssociativeArray<client::JsonCppData > mutable_inputElementCodec() {
157  Json::Value* storage = MutableStorage("inputElementCodec");
158  return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
159  }
160 
169  return Storage().isMember("originalCombineValuesInputStoreName");
170  }
171 
176  MutableStorage()->removeMember("originalCombineValuesInputStoreName");
177  }
178 
179 
185  const Json::Value& v = Storage("originalCombineValuesInputStoreName");
186  if (v == Json::Value::null) return StringPiece("");
187  return StringPiece(v.asCString());
188  }
189 
198  void set_original_combine_values_input_store_name(const StringPiece& value) {
199  *MutableStorage("originalCombineValuesInputStoreName") = value.data();
200  }
201 
210  return Storage().isMember("originalCombineValuesStepName");
211  }
212 
217  MutableStorage()->removeMember("originalCombineValuesStepName");
218  }
219 
220 
225  const StringPiece get_original_combine_values_step_name() const {
226  const Json::Value& v = Storage("originalCombineValuesStepName");
227  if (v == Json::Value::null) return StringPiece("");
228  return StringPiece(v.asCString());
229  }
230 
239  void set_original_combine_values_step_name(const StringPiece& value) {
240  *MutableStorage("originalCombineValuesStepName") = value.data();
241  }
242 
248  bool has_side_inputs() const {
249  return Storage().isMember("sideInputs");
250  }
251 
256  MutableStorage()->removeMember("sideInputs");
257  }
258 
259 
263  const client::JsonCppArray<SideInputInfo > get_side_inputs() const;
264 
273  client::JsonCppArray<SideInputInfo > mutable_sideInputs();
274 
280  bool has_value_combining_fn() const {
281  return Storage().isMember("valueCombiningFn");
282  }
283 
288  MutableStorage()->removeMember("valueCombiningFn");
289  }
290 
291 
296  const client::JsonCppAssociativeArray<client::JsonCppData > get_value_combining_fn() const {
297  const Json::Value& storage = Storage("valueCombiningFn");
298  return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
299  }
300 
309  client::JsonCppAssociativeArray<client::JsonCppData > mutable_valueCombiningFn() {
310  Json::Value* storage = MutableStorage("valueCombiningFn");
311  return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
312  }
313 
314  private:
315  void operator=(const PartialGroupByKeyInstruction&);
316 }; // PartialGroupByKeyInstruction
317 } // namespace google_dataflow_api
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: instruction_input.h:51
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