30 #ifndef GOOGLE_DATAFLOW_API_REPORTED_PARALLELISM_H_ 31 #define GOOGLE_DATAFLOW_API_REPORTED_PARALLELISM_H_ 33 #include "googleapis/base/macros.h" 34 #include "googleapis/client/data/jsoncpp_data.h" 35 #include "googleapis/strings/stringpiece.h" 84 return StringPiece(
"google_dataflow_api::ReportedParallelism");
93 return Storage().isMember(
"isInfinite");
100 MutableStorage()->removeMember(
"isInfinite");
108 const Json::Value& storage = Storage(
"isInfinite");
109 return client::JsonValueToCppValueHelper<bool >(storage);
125 client::SetJsonValueFromCppValueHelper<bool >(
126 value, MutableStorage(
"isInfinite"));
135 return Storage().isMember(
"value");
142 MutableStorage()->removeMember(
"value");
150 const Json::Value& storage = Storage(
"value");
151 return client::JsonValueToCppValueHelper<double >(storage);
162 client::SetJsonValueFromCppValueHelper<double >(
163 value, MutableStorage(
"value"));
170 #endif // GOOGLE_DATAFLOW_API_REPORTED_PARALLELISM_H_ void clear_value()
Definition: reported_parallelism.h:141
bool has_value() const
Definition: reported_parallelism.h:134
Definition: reported_parallelism.h:50
void set_value(double value)
Definition: reported_parallelism.h:161
Definition: approximate_progress.h:40
bool get_is_infinite() const
Definition: reported_parallelism.h:107
const StringPiece GetTypeName() const
Definition: reported_parallelism.h:83
double get_value() const
Definition: reported_parallelism.h:149
Definition: approximate_progress.cc:42
void set_is_infinite(bool value)
Definition: reported_parallelism.h:124
void clear_is_infinite()
Definition: reported_parallelism.h:99
bool has_is_infinite() const
Definition: reported_parallelism.h:92