30 #ifndef GOOGLE_DATAFLOW_API_WRITE_INSTRUCTION_H_ 31 #define GOOGLE_DATAFLOW_API_WRITE_INSTRUCTION_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/instruction_input.h" 38 #include "google/dataflow_api/sink.h" 87 return StringPiece(
"google_dataflow_api::WriteInstruction");
96 return Storage().isMember(
"input");
103 MutableStorage()->removeMember(
"input");
127 return Storage().isMember(
"sink");
134 MutableStorage()->removeMember(
"sink");
141 const Sink get_sink()
const;
156 #endif // GOOGLE_DATAFLOW_API_WRITE_INSTRUCTION_H_
void clear_input()
Definition: write_instruction.h:102
Definition: approximate_progress.h:40
bool has_sink() const
Definition: write_instruction.h:126
bool has_input() const
Definition: write_instruction.h:95
Definition: approximate_progress.cc:42
void clear_sink()
Definition: write_instruction.h:133
const StringPiece GetTypeName() const
Definition: write_instruction.h:86
Definition: write_instruction.h:53