30 #ifndef GOOGLE_DATAFLOW_API_SINK_H_ 31 #define GOOGLE_DATAFLOW_API_SINK_H_ 33 #include "googleapis/base/macros.h" 34 #include "googleapis/client/data/jsoncpp_data.h" 35 #include "googleapis/strings/stringpiece.h" 49 class Sink :
public client::JsonCppData {
63 explicit Sink(
const Json::Value& storage);
70 explicit Sink(Json::Value* storage);
83 return StringPiece(
"google_dataflow_api::Sink");
92 return Storage().isMember(
"codec");
99 MutableStorage()->removeMember(
"codec");
106 const client::JsonCppAssociativeArray<client::JsonCppData >
get_codec()
const {
107 const Json::Value& storage = Storage(
"codec");
108 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
119 Json::Value* storage = MutableStorage(
"codec");
120 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
129 return Storage().isMember(
"spec");
136 MutableStorage()->removeMember(
"spec");
143 const client::JsonCppAssociativeArray<client::JsonCppData >
get_spec()
const {
144 const Json::Value& storage = Storage(
"spec");
145 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
156 Json::Value* storage = MutableStorage(
"spec");
157 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<client::JsonCppData > >(storage);
161 void operator=(
const Sink&);
164 #endif // GOOGLE_DATAFLOW_API_SINK_H_
void clear_codec()
Definition: sink.h:98
client::JsonCppAssociativeArray< client::JsonCppData > mutable_spec()
Definition: sink.h:155
bool has_spec() const
Definition: sink.h:128
bool has_codec() const
Definition: sink.h:91
const client::JsonCppAssociativeArray< client::JsonCppData > get_spec() const
Definition: sink.h:143
const client::JsonCppAssociativeArray< client::JsonCppData > get_codec() const
Definition: sink.h:106
const StringPiece GetTypeName() const
Definition: sink.h:82
Definition: approximate_progress.h:40
void clear_spec()
Definition: sink.h:135
Definition: approximate_progress.cc:42
client::JsonCppAssociativeArray< client::JsonCppData > mutable_codec()
Definition: sink.h:118