30 #ifndef GOOGLE_DATAFLOW_API_SOURCE_SPLIT_RESPONSE_H_ 31 #define GOOGLE_DATAFLOW_API_SOURCE_SPLIT_RESPONSE_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/derived_source.h" 39 #include "google/dataflow_api/source_split_shard.h" 87 return StringPiece(
"google_dataflow_api::SourceSplitResponse");
96 return Storage().isMember(
"bundles");
103 MutableStorage()->removeMember(
"bundles");
110 const client::JsonCppArray<DerivedSource > get_bundles()
const;
121 client::JsonCppArray<DerivedSource > mutable_bundles();
129 return Storage().isMember(
"outcome");
136 MutableStorage()->removeMember(
"outcome");
144 const Json::Value& v = Storage(
"outcome");
145 if (v == Json::Value::null)
return StringPiece(
"");
146 return StringPiece(v.asCString());
161 *MutableStorage(
"outcome") = value.data();
170 return Storage().isMember(
"shards");
177 MutableStorage()->removeMember(
"shards");
184 const client::JsonCppArray<SourceSplitShard > get_shards()
const;
195 client::JsonCppArray<SourceSplitShard > mutable_shards();
201 #endif // GOOGLE_DATAFLOW_API_SOURCE_SPLIT_RESPONSE_H_ Definition: source_split_response.h:53
const StringPiece GetTypeName() const
Definition: source_split_response.h:86
void clear_bundles()
Definition: source_split_response.h:102
void clear_outcome()
Definition: source_split_response.h:135
bool has_outcome() const
Definition: source_split_response.h:128
const StringPiece get_outcome() const
Definition: source_split_response.h:143
Definition: approximate_progress.h:40
void clear_shards()
Definition: source_split_response.h:176
void set_outcome(const StringPiece &value)
Definition: source_split_response.h:160
bool has_bundles() const
Definition: source_split_response.h:95
bool has_shards() const
Definition: source_split_response.h:169
Definition: approximate_progress.cc:42