30 #ifndef GOOGLE_DATAFLOW_API_TOPOLOGY_CONFIG_H_ 31 #define GOOGLE_DATAFLOW_API_TOPOLOGY_CONFIG_H_ 34 #include "googleapis/base/integral_types.h" 35 #include "googleapis/base/macros.h" 36 #include "googleapis/client/data/jsoncpp_data.h" 37 #include "googleapis/strings/stringpiece.h" 39 #include "google/dataflow_api/computation_topology.h" 40 #include "google/dataflow_api/data_disk_assignment.h" 89 return StringPiece(
"google_dataflow_api::TopologyConfig");
98 return Storage().isMember(
"computations");
105 MutableStorage()->removeMember(
"computations");
112 const client::JsonCppArray<ComputationTopology > get_computations()
const;
122 client::JsonCppArray<ComputationTopology > mutable_computations();
130 return Storage().isMember(
"dataDiskAssignments");
137 MutableStorage()->removeMember(
"dataDiskAssignments");
145 const client::JsonCppArray<DataDiskAssignment > get_data_disk_assignments()
const;
155 client::JsonCppArray<DataDiskAssignment > mutable_dataDiskAssignments();
163 return Storage().isMember(
"forwardingKeyBits");
170 MutableStorage()->removeMember(
"forwardingKeyBits");
178 const Json::Value& storage = Storage(
"forwardingKeyBits");
179 return client::JsonValueToCppValueHelper<int32 >(storage);
190 client::SetJsonValueFromCppValueHelper<int32 >(
191 value, MutableStorage(
"forwardingKeyBits"));
201 return Storage().isMember(
"persistentStateVersion");
208 MutableStorage()->removeMember(
"persistentStateVersion");
216 const Json::Value& storage = Storage(
"persistentStateVersion");
217 return client::JsonValueToCppValueHelper<int32 >(storage);
228 client::SetJsonValueFromCppValueHelper<int32 >(
229 value, MutableStorage(
"persistentStateVersion"));
240 return Storage().isMember(
"userStageToComputationNameMap");
247 MutableStorage()->removeMember(
"userStageToComputationNameMap");
256 const Json::Value& storage = Storage(
"userStageToComputationNameMap");
257 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
269 Json::Value* storage = MutableStorage(
"userStageToComputationNameMap");
270 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
277 #endif // GOOGLE_DATAFLOW_API_TOPOLOGY_CONFIG_H_ void clear_data_disk_assignments()
Definition: topology_config.h:136
const StringPiece GetTypeName() const
Definition: topology_config.h:88
bool has_forwarding_key_bits() const
Definition: topology_config.h:162
bool has_persistent_state_version() const
Definition: topology_config.h:200
void clear_computations()
Definition: topology_config.h:104
client::JsonCppAssociativeArray< string > mutable_userStageToComputationNameMap()
Definition: topology_config.h:268
bool has_data_disk_assignments() const
Definition: topology_config.h:129
void set_forwarding_key_bits(int32 value)
Definition: topology_config.h:189
Definition: topology_config.h:55
int32 get_forwarding_key_bits() const
Definition: topology_config.h:177
const client::JsonCppAssociativeArray< string > get_user_stage_to_computation_name_map() const
Definition: topology_config.h:255
void clear_forwarding_key_bits()
Definition: topology_config.h:169
bool has_user_stage_to_computation_name_map() const
Definition: topology_config.h:239
void clear_persistent_state_version()
Definition: topology_config.h:207
void clear_user_stage_to_computation_name_map()
Definition: topology_config.h:246
Definition: approximate_progress.h:40
void set_persistent_state_version(int32 value)
Definition: topology_config.h:227
bool has_computations() const
Definition: topology_config.h:97
Definition: approximate_progress.cc:42
int32 get_persistent_state_version() const
Definition: topology_config.h:215