30 #ifndef GOOGLE_DATAFLOW_API_SOURCE_OPERATION_REQUEST_H_ 31 #define GOOGLE_DATAFLOW_API_SOURCE_OPERATION_REQUEST_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/source_get_metadata_request.h" 39 #include "google/dataflow_api/source_split_request.h" 88 return StringPiece(
"google_dataflow_api::SourceOperationRequest");
97 return Storage().isMember(
"getMetadata");
104 MutableStorage()->removeMember(
"getMetadata");
129 return Storage().isMember(
"name");
136 MutableStorage()->removeMember(
"name");
144 const Json::Value& v = Storage(
"name");
145 if (v == Json::Value::null)
return StringPiece(
"");
146 return StringPiece(v.asCString());
157 *MutableStorage(
"name") = value.data();
166 return Storage().isMember(
"originalName");
173 MutableStorage()->removeMember(
"originalName");
181 const Json::Value& v = Storage(
"originalName");
182 if (v == Json::Value::null)
return StringPiece(
"");
183 return StringPiece(v.asCString());
195 *MutableStorage(
"originalName") = value.data();
204 return Storage().isMember(
"split");
211 MutableStorage()->removeMember(
"split");
235 return Storage().isMember(
"stageName");
242 MutableStorage()->removeMember(
"stageName");
250 const Json::Value& v = Storage(
"stageName");
251 if (v == Json::Value::null)
return StringPiece(
"");
252 return StringPiece(v.asCString());
264 *MutableStorage(
"stageName") = value.data();
273 return Storage().isMember(
"systemName");
280 MutableStorage()->removeMember(
"systemName");
288 const Json::Value& v = Storage(
"systemName");
289 if (v == Json::Value::null)
return StringPiece(
"");
290 return StringPiece(v.asCString());
302 *MutableStorage(
"systemName") = value.data();
309 #endif // GOOGLE_DATAFLOW_API_SOURCE_OPERATION_REQUEST_H_ void clear_split()
Definition: source_operation_request.h:210
Definition: source_operation_request.h:54
bool has_system_name() const
Definition: source_operation_request.h:272
void clear_stage_name()
Definition: source_operation_request.h:241
Definition: source_split_request.h:65
void clear_original_name()
Definition: source_operation_request.h:172
const StringPiece get_system_name() const
Definition: source_operation_request.h:287
bool has_split() const
Definition: source_operation_request.h:203
const StringPiece get_original_name() const
Definition: source_operation_request.h:180
bool has_get_metadata() const
Definition: source_operation_request.h:96
void clear_name()
Definition: source_operation_request.h:135
void set_name(const StringPiece &value)
Definition: source_operation_request.h:156
bool has_original_name() const
Definition: source_operation_request.h:165
void set_system_name(const StringPiece &value)
Definition: source_operation_request.h:301
Definition: approximate_progress.h:40
bool has_name() const
Definition: source_operation_request.h:128
void set_original_name(const StringPiece &value)
Definition: source_operation_request.h:194
void clear_get_metadata()
Definition: source_operation_request.h:103
void set_stage_name(const StringPiece &value)
Definition: source_operation_request.h:263
const StringPiece get_name() const
Definition: source_operation_request.h:143
const StringPiece GetTypeName() const
Definition: source_operation_request.h:87
bool has_stage_name() const
Definition: source_operation_request.h:234
void clear_system_name()
Definition: source_operation_request.h:279
Definition: approximate_progress.cc:42
const StringPiece get_stage_name() const
Definition: source_operation_request.h:249