30 #ifndef GOOGLE_DATAFLOW_API_STREAM_LOCATION_H_ 31 #define GOOGLE_DATAFLOW_API_STREAM_LOCATION_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/custom_source_location.h" 38 #include "google/dataflow_api/pubsub_location.h" 39 #include "google/dataflow_api/streaming_side_input_location.h" 40 #include "google/dataflow_api/streaming_stage_location.h" 89 return StringPiece(
"google_dataflow_api::StreamLocation");
98 return Storage().isMember(
"customSourceLocation");
105 MutableStorage()->removeMember(
"customSourceLocation");
131 return Storage().isMember(
"pubsubLocation");
138 MutableStorage()->removeMember(
"pubsubLocation");
164 return Storage().isMember(
"sideInputLocation");
171 MutableStorage()->removeMember(
"sideInputLocation");
198 return Storage().isMember(
"streamingStageLocation");
205 MutableStorage()->removeMember(
"streamingStageLocation");
230 #endif // GOOGLE_DATAFLOW_API_STREAM_LOCATION_H_
bool has_custom_source_location() const
Definition: stream_location.h:97
void clear_streaming_stage_location()
Definition: stream_location.h:204
Definition: custom_source_location.h:49
void clear_side_input_location()
Definition: stream_location.h:170
const StringPiece GetTypeName() const
Definition: stream_location.h:88
void clear_custom_source_location()
Definition: stream_location.h:104
Definition: approximate_progress.h:40
Definition: streaming_stage_location.h:51
Definition: stream_location.h:55
Definition: approximate_progress.cc:42
bool has_pubsub_location() const
Definition: stream_location.h:130
Definition: pubsub_location.h:51
void clear_pubsub_location()
Definition: stream_location.h:137
bool has_side_input_location() const
Definition: stream_location.h:163
bool has_streaming_stage_location() const
Definition: stream_location.h:197