dataflow  v1b3
parallel_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_PARALLEL_INSTRUCTION_H_
31 #define GOOGLE_DATAFLOW_API_PARALLEL_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/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"
44 
45 namespace Json {
46 class Value;
47 } // namespace Json
48 
49 namespace google_dataflow_api {
50 using namespace googleapis;
51 
57 class ParallelInstruction : public client::JsonCppData {
58  public:
64  static ParallelInstruction* New();
65 
71  explicit ParallelInstruction(const Json::Value& storage);
72 
78  explicit ParallelInstruction(Json::Value* storage);
79 
83  virtual ~ParallelInstruction();
84 
90  const StringPiece GetTypeName() const {
91  return StringPiece("google_dataflow_api::ParallelInstruction");
92  }
93 
99  bool has_flatten() const {
100  return Storage().isMember("flatten");
101  }
102 
106  void clear_flatten() {
107  MutableStorage()->removeMember("flatten");
108  }
109 
110 
114  const FlattenInstruction get_flatten() const;
115 
123  FlattenInstruction mutable_flatten();
124 
130  bool has_name() const {
131  return Storage().isMember("name");
132  }
133 
137  void clear_name() {
138  MutableStorage()->removeMember("name");
139  }
140 
141 
145  const StringPiece get_name() const {
146  const Json::Value& v = Storage("name");
147  if (v == Json::Value::null) return StringPiece("");
148  return StringPiece(v.asCString());
149  }
150 
158  void set_name(const StringPiece& value) {
159  *MutableStorage("name") = value.data();
160  }
161 
167  bool has_original_name() const {
168  return Storage().isMember("originalName");
169  }
170 
175  MutableStorage()->removeMember("originalName");
176  }
177 
178 
182  const StringPiece get_original_name() const {
183  const Json::Value& v = Storage("originalName");
184  if (v == Json::Value::null) return StringPiece("");
185  return StringPiece(v.asCString());
186  }
187 
195  void set_original_name(const StringPiece& value) {
196  *MutableStorage("originalName") = value.data();
197  }
198 
204  bool has_outputs() const {
205  return Storage().isMember("outputs");
206  }
207 
211  void clear_outputs() {
212  MutableStorage()->removeMember("outputs");
213  }
214 
215 
219  const client::JsonCppArray<InstructionOutput > get_outputs() const;
220 
228  client::JsonCppArray<InstructionOutput > mutable_outputs();
229 
235  bool has_par_do() const {
236  return Storage().isMember("parDo");
237  }
238 
242  void clear_par_do() {
243  MutableStorage()->removeMember("parDo");
244  }
245 
246 
250  const ParDoInstruction get_par_do() const;
251 
259  ParDoInstruction mutable_parDo();
260 
267  return Storage().isMember("partialGroupByKey");
268  }
269 
274  MutableStorage()->removeMember("partialGroupByKey");
275  }
276 
277 
282  const PartialGroupByKeyInstruction get_partial_group_by_key() const;
283 
292  PartialGroupByKeyInstruction mutable_partialGroupByKey();
293 
299  bool has_read() const {
300  return Storage().isMember("read");
301  }
302 
306  void clear_read() {
307  MutableStorage()->removeMember("read");
308  }
309 
310 
314  const ReadInstruction get_read() const;
315 
323  ReadInstruction mutable_read();
324 
330  bool has_system_name() const {
331  return Storage().isMember("systemName");
332  }
333 
338  MutableStorage()->removeMember("systemName");
339  }
340 
341 
345  const StringPiece get_system_name() const {
346  const Json::Value& v = Storage("systemName");
347  if (v == Json::Value::null) return StringPiece("");
348  return StringPiece(v.asCString());
349  }
350 
359  void set_system_name(const StringPiece& value) {
360  *MutableStorage("systemName") = value.data();
361  }
362 
368  bool has_write() const {
369  return Storage().isMember("write");
370  }
371 
375  void clear_write() {
376  MutableStorage()->removeMember("write");
377  }
378 
379 
383  const WriteInstruction get_write() const;
384 
392  WriteInstruction mutable_write();
393 
394  private:
395  void operator=(const ParallelInstruction&);
396 }; // ParallelInstruction
397 } // namespace google_dataflow_api
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