30 #ifndef GOOGLE_DATAFLOW_API_SOURCE_SPLIT_SHARD_H_ 31 #define GOOGLE_DATAFLOW_API_SOURCE_SPLIT_SHARD_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.h" 86 return StringPiece(
"google_dataflow_api::SourceSplitShard");
95 return Storage().isMember(
"derivationMode");
102 MutableStorage()->removeMember(
"derivationMode");
110 const Json::Value& v = Storage(
"derivationMode");
111 if (v == Json::Value::null)
return StringPiece(
"");
112 return StringPiece(v.asCString());
125 *MutableStorage(
"derivationMode") = value.data();
134 return Storage().isMember(
"source");
141 MutableStorage()->removeMember(
"source");
148 const Source get_source()
const;
165 #endif // GOOGLE_DATAFLOW_API_SOURCE_SPLIT_SHARD_H_ const StringPiece get_derivation_mode() const
Definition: source_split_shard.h:109
bool has_derivation_mode() const
Definition: source_split_shard.h:94
void set_derivation_mode(const StringPiece &value)
Definition: source_split_shard.h:124
bool has_source() const
Definition: source_split_shard.h:133
Definition: source_split_shard.h:52
void clear_source()
Definition: source_split_shard.h:140
Definition: approximate_progress.h:40
void clear_derivation_mode()
Definition: source_split_shard.h:101
Definition: approximate_progress.cc:42
const StringPiece GetTypeName() const
Definition: source_split_shard.h:85