30 #ifndef GOOGLE_DATAFLOW_API_COMPUTATION_TOPOLOGY_H_ 31 #define GOOGLE_DATAFLOW_API_COMPUTATION_TOPOLOGY_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/key_range_location.h" 39 #include "google/dataflow_api/state_family_config.h" 40 #include "google/dataflow_api/stream_location.h" 88 return StringPiece(
"google_dataflow_api::ComputationTopology");
97 return Storage().isMember(
"computationId");
104 MutableStorage()->removeMember(
"computationId");
112 const Json::Value& v = Storage(
"computationId");
113 if (v == Json::Value::null)
return StringPiece(
"");
114 return StringPiece(v.asCString());
125 *MutableStorage(
"computationId") = value.data();
134 return Storage().isMember(
"inputs");
141 MutableStorage()->removeMember(
"inputs");
148 const client::JsonCppArray<StreamLocation > get_inputs()
const;
157 client::JsonCppArray<StreamLocation > mutable_inputs();
165 return Storage().isMember(
"keyRanges");
172 MutableStorage()->removeMember(
"keyRanges");
179 const client::JsonCppArray<KeyRangeLocation > get_key_ranges()
const;
189 client::JsonCppArray<KeyRangeLocation > mutable_keyRanges();
197 return Storage().isMember(
"outputs");
204 MutableStorage()->removeMember(
"outputs");
211 const client::JsonCppArray<StreamLocation > get_outputs()
const;
220 client::JsonCppArray<StreamLocation > mutable_outputs();
228 return Storage().isMember(
"stateFamilies");
235 MutableStorage()->removeMember(
"stateFamilies");
242 const client::JsonCppArray<StateFamilyConfig > get_state_families()
const;
252 client::JsonCppArray<StateFamilyConfig > mutable_stateFamilies();
260 return Storage().isMember(
"systemStageName");
267 MutableStorage()->removeMember(
"systemStageName");
275 const Json::Value& v = Storage(
"systemStageName");
276 if (v == Json::Value::null)
return StringPiece(
"");
277 return StringPiece(v.asCString());
288 *MutableStorage(
"systemStageName") = value.data();
295 #endif // GOOGLE_DATAFLOW_API_COMPUTATION_TOPOLOGY_H_ bool has_computation_id() const
Definition: computation_topology.h:96
bool has_key_ranges() const
Definition: computation_topology.h:164
void clear_state_families()
Definition: computation_topology.h:234
const StringPiece get_computation_id() const
Definition: computation_topology.h:111
void clear_outputs()
Definition: computation_topology.h:203
void clear_computation_id()
Definition: computation_topology.h:103
bool has_inputs() const
Definition: computation_topology.h:133
bool has_state_families() const
Definition: computation_topology.h:227
void set_computation_id(const StringPiece &value)
Definition: computation_topology.h:124
Definition: approximate_progress.h:40
Definition: computation_topology.h:54
bool has_outputs() const
Definition: computation_topology.h:196
Definition: approximate_progress.cc:42
void clear_key_ranges()
Definition: computation_topology.h:171
void set_system_stage_name(const StringPiece &value)
Definition: computation_topology.h:287
void clear_inputs()
Definition: computation_topology.h:140
void clear_system_stage_name()
Definition: computation_topology.h:266
const StringPiece GetTypeName() const
Definition: computation_topology.h:87
bool has_system_stage_name() const
Definition: computation_topology.h:259
const StringPiece get_system_stage_name() const
Definition: computation_topology.h:274