30 #ifndef GOOGLE_DATAFLOW_API_SEQ_MAP_TASK_OUTPUT_INFO_H_ 31 #define GOOGLE_DATAFLOW_API_SEQ_MAP_TASK_OUTPUT_INFO_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/sink.h" 86 return StringPiece(
"google_dataflow_api::SeqMapTaskOutputInfo");
95 return Storage().isMember(
"sink");
102 MutableStorage()->removeMember(
"sink");
109 const Sink get_sink()
const;
126 return Storage().isMember(
"tag");
133 MutableStorage()->removeMember(
"tag");
141 const Json::Value& v = Storage(
"tag");
142 if (v == Json::Value::null)
return StringPiece(
"");
143 return StringPiece(v.asCString());
154 *MutableStorage(
"tag") = value.data();
161 #endif // GOOGLE_DATAFLOW_API_SEQ_MAP_TASK_OUTPUT_INFO_H_
const StringPiece get_tag() const
Definition: seq_map_task_output_info.h:140
bool has_sink() const
Definition: seq_map_task_output_info.h:94
void clear_sink()
Definition: seq_map_task_output_info.h:101
const StringPiece GetTypeName() const
Definition: seq_map_task_output_info.h:85
Definition: approximate_progress.h:40
void set_tag(const StringPiece &value)
Definition: seq_map_task_output_info.h:153
bool has_tag() const
Definition: seq_map_task_output_info.h:125
Definition: approximate_progress.cc:42
Definition: seq_map_task_output_info.h:52
void clear_tag()
Definition: seq_map_task_output_info.h:132