30 #ifndef GOOGLE_DATAFLOW_API_STREAMING_COMPUTATION_CONFIG_H_ 31 #define GOOGLE_DATAFLOW_API_STREAMING_COMPUTATION_CONFIG_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/parallel_instruction.h" 86 return StringPiece(
"google_dataflow_api::StreamingComputationConfig");
95 return Storage().isMember(
"computationId");
102 MutableStorage()->removeMember(
"computationId");
110 const Json::Value& v = Storage(
"computationId");
111 if (v == Json::Value::null)
return StringPiece(
"");
112 return StringPiece(v.asCString());
123 *MutableStorage(
"computationId") = value.data();
132 return Storage().isMember(
"instructions");
139 MutableStorage()->removeMember(
"instructions");
146 const client::JsonCppArray<ParallelInstruction > get_instructions()
const;
156 client::JsonCppArray<ParallelInstruction > mutable_instructions();
164 return Storage().isMember(
"stageName");
171 MutableStorage()->removeMember(
"stageName");
179 const Json::Value& v = Storage(
"stageName");
180 if (v == Json::Value::null)
return StringPiece(
"");
181 return StringPiece(v.asCString());
192 *MutableStorage(
"stageName") = value.data();
201 return Storage().isMember(
"systemName");
208 MutableStorage()->removeMember(
"systemName");
216 const Json::Value& v = Storage(
"systemName");
217 if (v == Json::Value::null)
return StringPiece(
"");
218 return StringPiece(v.asCString());
229 *MutableStorage(
"systemName") = value.data();
240 return Storage().isMember(
"transformUserNameToStateFamily");
247 MutableStorage()->removeMember(
"transformUserNameToStateFamily");
256 const Json::Value& storage = Storage(
"transformUserNameToStateFamily");
257 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
270 Json::Value* storage = MutableStorage(
"transformUserNameToStateFamily");
271 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
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