30 #ifndef GOOGLE_DATAFLOW_API_SOURCE_FORK_H_ 31 #define GOOGLE_DATAFLOW_API_SOURCE_FORK_H_ 33 #include "googleapis/base/macros.h" 34 #include "googleapis/client/data/jsoncpp_data.h" 35 #include "googleapis/strings/stringpiece.h" 37 #include "google/dataflow_api/derived_source.h" 38 #include "google/dataflow_api/source_split_shard.h" 66 explicit SourceFork(
const Json::Value& storage);
86 return StringPiece(
"google_dataflow_api::SourceFork");
95 return Storage().isMember(
"primary");
102 MutableStorage()->removeMember(
"primary");
128 return Storage().isMember(
"primarySource");
135 MutableStorage()->removeMember(
"primarySource");
162 return Storage().isMember(
"residual");
169 MutableStorage()->removeMember(
"residual");
196 return Storage().isMember(
"residualSource");
203 MutableStorage()->removeMember(
"residualSource");
229 #endif // GOOGLE_DATAFLOW_API_SOURCE_FORK_H_ void clear_residual()
Definition: source_fork.h:168
bool has_residual_source() const
Definition: source_fork.h:195
void clear_primary()
Definition: source_fork.h:101
void clear_primary_source()
Definition: source_fork.h:134
Definition: source_split_shard.h:52
const StringPiece GetTypeName() const
Definition: source_fork.h:85
bool has_residual() const
Definition: source_fork.h:161
Definition: derived_source.h:55
Definition: approximate_progress.h:40
bool has_primary_source() const
Definition: source_fork.h:127
Definition: approximate_progress.cc:42
Definition: source_fork.h:52
bool has_primary() const
Definition: source_fork.h:94
void clear_residual_source()
Definition: source_fork.h:202