dataflow  v1b3
streaming_computation_config.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_STREAMING_COMPUTATION_CONFIG_H_
31 #define GOOGLE_DATAFLOW_API_STREAMING_COMPUTATION_CONFIG_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/parallel_instruction.h"
39 
40 namespace Json {
41 class Value;
42 } // namespace Json
43 
44 namespace google_dataflow_api {
45 using namespace googleapis;
46 
52 class StreamingComputationConfig : public client::JsonCppData {
53  public:
59  static StreamingComputationConfig* New();
60 
66  explicit StreamingComputationConfig(const Json::Value& storage);
67 
73  explicit StreamingComputationConfig(Json::Value* storage);
74 
78  virtual ~StreamingComputationConfig();
79 
85  const StringPiece GetTypeName() const {
86  return StringPiece("google_dataflow_api::StreamingComputationConfig");
87  }
88 
94  bool has_computation_id() const {
95  return Storage().isMember("computationId");
96  }
97 
102  MutableStorage()->removeMember("computationId");
103  }
104 
105 
109  const StringPiece get_computation_id() const {
110  const Json::Value& v = Storage("computationId");
111  if (v == Json::Value::null) return StringPiece("");
112  return StringPiece(v.asCString());
113  }
114 
122  void set_computation_id(const StringPiece& value) {
123  *MutableStorage("computationId") = value.data();
124  }
125 
131  bool has_instructions() const {
132  return Storage().isMember("instructions");
133  }
134 
139  MutableStorage()->removeMember("instructions");
140  }
141 
142 
146  const client::JsonCppArray<ParallelInstruction > get_instructions() const;
147 
156  client::JsonCppArray<ParallelInstruction > mutable_instructions();
157 
163  bool has_stage_name() const {
164  return Storage().isMember("stageName");
165  }
166 
171  MutableStorage()->removeMember("stageName");
172  }
173 
174 
178  const StringPiece get_stage_name() const {
179  const Json::Value& v = Storage("stageName");
180  if (v == Json::Value::null) return StringPiece("");
181  return StringPiece(v.asCString());
182  }
183 
191  void set_stage_name(const StringPiece& value) {
192  *MutableStorage("stageName") = value.data();
193  }
194 
200  bool has_system_name() const {
201  return Storage().isMember("systemName");
202  }
203 
208  MutableStorage()->removeMember("systemName");
209  }
210 
211 
215  const StringPiece get_system_name() const {
216  const Json::Value& v = Storage("systemName");
217  if (v == Json::Value::null) return StringPiece("");
218  return StringPiece(v.asCString());
219  }
220 
228  void set_system_name(const StringPiece& value) {
229  *MutableStorage("systemName") = value.data();
230  }
231 
240  return Storage().isMember("transformUserNameToStateFamily");
241  }
242 
247  MutableStorage()->removeMember("transformUserNameToStateFamily");
248  }
249 
250 
255  const client::JsonCppAssociativeArray<string > get_transform_user_name_to_state_family() const {
256  const Json::Value& storage = Storage("transformUserNameToStateFamily");
257  return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
258  }
259 
269  client::JsonCppAssociativeArray<string > mutable_transformUserNameToStateFamily() {
270  Json::Value* storage = MutableStorage("transformUserNameToStateFamily");
271  return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
272  }
273 
274  private:
275  void operator=(const StreamingComputationConfig&);
276 }; // StreamingComputationConfig
277 } // namespace google_dataflow_api
278 #endif // GOOGLE_DATAFLOW_API_STREAMING_COMPUTATION_CONFIG_H_
void clear_computation_id()
Definition: streaming_computation_config.h:101
void clear_instructions()
Definition: streaming_computation_config.h:138
void set_stage_name(const StringPiece &value)
Definition: streaming_computation_config.h:191
bool has_stage_name() const
Definition: streaming_computation_config.h:163
Definition: streaming_computation_config.h:52
const StringPiece get_computation_id() const
Definition: streaming_computation_config.h:109
void set_computation_id(const StringPiece &value)
Definition: streaming_computation_config.h:122
bool has_system_name() const
Definition: streaming_computation_config.h:200
bool has_transform_user_name_to_state_family() const
Definition: streaming_computation_config.h:239
client::JsonCppAssociativeArray< string > mutable_transformUserNameToStateFamily()
Definition: streaming_computation_config.h:269
Definition: approximate_progress.h:40
void clear_stage_name()
Definition: streaming_computation_config.h:170
void clear_system_name()
Definition: streaming_computation_config.h:207
bool has_instructions() const
Definition: streaming_computation_config.h:131
void set_system_name(const StringPiece &value)
Definition: streaming_computation_config.h:228
const StringPiece GetTypeName() const
Definition: streaming_computation_config.h:85
Definition: approximate_progress.cc:42
const StringPiece get_stage_name() const
Definition: streaming_computation_config.h:178
const client::JsonCppAssociativeArray< string > get_transform_user_name_to_state_family() const
Definition: streaming_computation_config.h:255
bool has_computation_id() const
Definition: streaming_computation_config.h:94
const StringPiece get_system_name() const
Definition: streaming_computation_config.h:215
void clear_transform_user_name_to_state_family()
Definition: streaming_computation_config.h:246