30 #ifndef GOOGLE_DATAFLOW_API_JOB_H_ 31 #define GOOGLE_DATAFLOW_API_JOB_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/environment.h" 39 #include "google/dataflow_api/execution_stage_state.h" 40 #include "google/dataflow_api/job_execution_info.h" 41 #include "google/dataflow_api/job_metadata.h" 42 #include "google/dataflow_api/pipeline_description.h" 43 #include "google/dataflow_api/step.h" 57 class Job :
public client::JsonCppData {
71 explicit Job(
const Json::Value& storage);
78 explicit Job(Json::Value* storage);
91 return StringPiece(
"google_dataflow_api::Job");
100 return Storage().isMember(
"clientRequestId");
107 MutableStorage()->removeMember(
"clientRequestId");
115 const Json::Value& v = Storage(
"clientRequestId");
116 if (v == Json::Value::null)
return StringPiece(
"");
117 return StringPiece(v.asCString());
134 *MutableStorage(
"clientRequestId") = value.data();
143 return Storage().isMember(
"createTime");
150 MutableStorage()->removeMember(
"createTime");
158 const Json::Value& v = Storage(
"createTime");
159 if (v == Json::Value::null)
return StringPiece(
"");
160 return StringPiece(v.asCString());
172 *MutableStorage(
"createTime") = value.data();
181 return Storage().isMember(
"createdFromSnapshotId");
188 MutableStorage()->removeMember(
"createdFromSnapshotId");
196 const Json::Value& v = Storage(
"createdFromSnapshotId");
197 if (v == Json::Value::null)
return StringPiece(
"");
198 return StringPiece(v.asCString());
210 *MutableStorage(
"createdFromSnapshotId") = value.data();
219 return Storage().isMember(
"currentState");
226 MutableStorage()->removeMember(
"currentState");
234 const Json::Value& v = Storage(
"currentState");
235 if (v == Json::Value::null)
return StringPiece(
"");
236 return StringPiece(v.asCString());
257 *MutableStorage(
"currentState") = value.data();
266 return Storage().isMember(
"currentStateTime");
273 MutableStorage()->removeMember(
"currentStateTime");
281 const Json::Value& v = Storage(
"currentStateTime");
282 if (v == Json::Value::null)
return StringPiece(
"");
283 return StringPiece(v.asCString());
294 *MutableStorage(
"currentStateTime") = value.data();
303 return Storage().isMember(
"environment");
310 MutableStorage()->removeMember(
"environment");
335 return Storage().isMember(
"executionInfo");
342 MutableStorage()->removeMember(
"executionInfo");
369 return Storage().isMember(
"id");
376 MutableStorage()->removeMember(
"id");
384 const Json::Value& v = Storage(
"id");
385 if (v == Json::Value::null)
return StringPiece(
"");
386 return StringPiece(v.asCString());
400 *MutableStorage(
"id") = value.data();
409 return Storage().isMember(
"jobMetadata");
416 MutableStorage()->removeMember(
"jobMetadata");
443 return Storage().isMember(
"labels");
450 MutableStorage()->removeMember(
"labels");
457 const client::JsonCppAssociativeArray<string >
get_labels()
const {
458 const Json::Value& storage = Storage(
"labels");
459 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
478 Json::Value* storage = MutableStorage(
"labels");
479 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
488 return Storage().isMember(
"location");
495 MutableStorage()->removeMember(
"location");
503 const Json::Value& v = Storage(
"location");
504 if (v == Json::Value::null)
return StringPiece(
"");
505 return StringPiece(v.asCString());
518 *MutableStorage(
"location") = value.data();
527 return Storage().isMember(
"name");
534 MutableStorage()->removeMember(
"name");
542 const Json::Value& v = Storage(
"name");
543 if (v == Json::Value::null)
return StringPiece(
"");
544 return StringPiece(v.asCString());
562 *MutableStorage(
"name") = value.data();
571 return Storage().isMember(
"pipelineDescription");
578 MutableStorage()->removeMember(
"pipelineDescription");
607 return Storage().isMember(
"projectId");
614 MutableStorage()->removeMember(
"projectId");
622 const Json::Value& v = Storage(
"projectId");
623 if (v == Json::Value::null)
return StringPiece(
"");
624 return StringPiece(v.asCString());
635 *MutableStorage(
"projectId") = value.data();
644 return Storage().isMember(
"replaceJobId");
651 MutableStorage()->removeMember(
"replaceJobId");
659 const Json::Value& v = Storage(
"replaceJobId");
660 if (v == Json::Value::null)
return StringPiece(
"");
661 return StringPiece(v.asCString());
677 *MutableStorage(
"replaceJobId") = value.data();
686 return Storage().isMember(
"replacedByJobId");
693 MutableStorage()->removeMember(
"replacedByJobId");
701 const Json::Value& v = Storage(
"replacedByJobId");
702 if (v == Json::Value::null)
return StringPiece(
"");
703 return StringPiece(v.asCString());
715 *MutableStorage(
"replacedByJobId") = value.data();
724 return Storage().isMember(
"requestedState");
731 MutableStorage()->removeMember(
"requestedState");
739 const Json::Value& v = Storage(
"requestedState");
740 if (v == Json::Value::null)
return StringPiece(
"");
741 return StringPiece(v.asCString());
758 *MutableStorage(
"requestedState") = value.data();
767 return Storage().isMember(
"stageStates");
774 MutableStorage()->removeMember(
"stageStates");
781 const client::JsonCppArray<ExecutionStageState > get_stage_states()
const;
792 client::JsonCppArray<ExecutionStageState > mutable_stageStates();
800 return Storage().isMember(
"startTime");
807 MutableStorage()->removeMember(
"startTime");
815 const Json::Value& v = Storage(
"startTime");
816 if (v == Json::Value::null)
return StringPiece(
"");
817 return StringPiece(v.asCString());
833 *MutableStorage(
"startTime") = value.data();
842 return Storage().isMember(
"steps");
849 MutableStorage()->removeMember(
"steps");
856 const client::JsonCppArray<Step > get_steps()
const;
867 client::JsonCppArray<Step > mutable_steps();
875 return Storage().isMember(
"stepsLocation");
882 MutableStorage()->removeMember(
"stepsLocation");
890 const Json::Value& v = Storage(
"stepsLocation");
891 if (v == Json::Value::null)
return StringPiece(
"");
892 return StringPiece(v.asCString());
903 *MutableStorage(
"stepsLocation") = value.data();
912 return Storage().isMember(
"tempFiles");
919 MutableStorage()->removeMember(
"tempFiles");
927 const Json::Value& storage = Storage(
"tempFiles");
928 return client::JsonValueToCppValueHelper<client::JsonCppArray<string > >(storage);
951 Json::Value* storage = MutableStorage(
"tempFiles");
952 return client::JsonValueToMutableCppValueHelper<client::JsonCppArray<string > >(storage);
961 return Storage().isMember(
"transformNameMapping");
968 MutableStorage()->removeMember(
"transformNameMapping");
977 const Json::Value& storage = Storage(
"transformNameMapping");
978 return client::JsonValueToCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
991 Json::Value* storage = MutableStorage(
"transformNameMapping");
992 return client::JsonValueToMutableCppValueHelper<client::JsonCppAssociativeArray<string > >(storage);
1001 return Storage().isMember(
"type");
1008 MutableStorage()->removeMember(
"type");
1016 const Json::Value& v = Storage(
"type");
1017 if (v == Json::Value::null)
return StringPiece(
"");
1018 return StringPiece(v.asCString());
1029 *MutableStorage(
"type") = value.data();
1033 void operator=(
const Job&);
1036 #endif // GOOGLE_DATAFLOW_API_JOB_H_ void set_type(const StringPiece &value)
Definition: job.h:1028
void clear_requested_state()
Definition: job.h:730
const StringPiece get_current_state() const
Definition: job.h:233
void clear_current_state()
Definition: job.h:225
const StringPiece get_client_request_id() const
Definition: job.h:114
Definition: environment.h:52
void clear_client_request_id()
Definition: job.h:106
const StringPiece get_type() const
Definition: job.h:1015
const StringPiece get_location() const
Definition: job.h:502
void clear_pipeline_description()
Definition: job.h:577
void clear_steps()
Definition: job.h:848
const client::JsonCppAssociativeArray< string > get_labels() const
Definition: job.h:457
void clear_start_time()
Definition: job.h:806
bool has_requested_state() const
Definition: job.h:723
const StringPiece get_name() const
Definition: job.h:541
bool has_execution_info() const
Definition: job.h:334
void clear_location()
Definition: job.h:494
const StringPiece get_replaced_by_job_id() const
Definition: job.h:700
bool has_replace_job_id() const
Definition: job.h:643
void set_client_request_id(const StringPiece &value)
Definition: job.h:133
const StringPiece get_replace_job_id() const
Definition: job.h:658
void set_replaced_by_job_id(const StringPiece &value)
Definition: job.h:714
const StringPiece get_id() const
Definition: job.h:383
void clear_labels()
Definition: job.h:449
bool has_project_id() const
Definition: job.h:606
bool has_name() const
Definition: job.h:526
bool has_steps() const
Definition: job.h:841
bool has_stage_states() const
Definition: job.h:766
bool has_current_state() const
Definition: job.h:218
bool has_current_state_time() const
Definition: job.h:265
bool has_job_metadata() const
Definition: job.h:408
void set_location(const StringPiece &value)
Definition: job.h:517
Definition: pipeline_description.h:55
void clear_temp_files()
Definition: job.h:918
const StringPiece get_create_time() const
Definition: job.h:157
void set_steps_location(const StringPiece &value)
Definition: job.h:902
void set_created_from_snapshot_id(const StringPiece &value)
Definition: job.h:209
const StringPiece get_current_state_time() const
Definition: job.h:280
void set_replace_job_id(const StringPiece &value)
Definition: job.h:676
client::JsonCppAssociativeArray< string > mutable_transformNameMapping()
Definition: job.h:990
const StringPiece GetTypeName() const
Definition: job.h:90
void clear_replaced_by_job_id()
Definition: job.h:692
Definition: job_execution_info.h:52
const client::JsonCppArray< string > get_temp_files() const
Definition: job.h:926
bool has_replaced_by_job_id() const
Definition: job.h:685
void clear_name()
Definition: job.h:533
Definition: approximate_progress.h:40
bool has_create_time() const
Definition: job.h:142
void set_project_id(const StringPiece &value)
Definition: job.h:634
bool has_created_from_snapshot_id() const
Definition: job.h:180
void set_current_state(const StringPiece &value)
Definition: job.h:256
void set_requested_state(const StringPiece &value)
Definition: job.h:757
void clear_current_state_time()
Definition: job.h:272
bool has_id() const
Definition: job.h:368
void clear_project_id()
Definition: job.h:613
void clear_create_time()
Definition: job.h:149
bool has_location() const
Definition: job.h:487
void set_create_time(const StringPiece &value)
Definition: job.h:171
bool has_type() const
Definition: job.h:1000
void clear_type()
Definition: job.h:1007
void clear_execution_info()
Definition: job.h:341
void set_start_time(const StringPiece &value)
Definition: job.h:832
const StringPiece get_project_id() const
Definition: job.h:621
bool has_pipeline_description() const
Definition: job.h:570
bool has_steps_location() const
Definition: job.h:874
bool has_labels() const
Definition: job.h:442
void set_id(const StringPiece &value)
Definition: job.h:399
client::JsonCppArray< string > mutable_tempFiles()
Definition: job.h:950
const StringPiece get_steps_location() const
Definition: job.h:889
Definition: approximate_progress.cc:42
const StringPiece get_created_from_snapshot_id() const
Definition: job.h:195
void set_current_state_time(const StringPiece &value)
Definition: job.h:293
void clear_stage_states()
Definition: job.h:773
void clear_job_metadata()
Definition: job.h:415
void clear_environment()
Definition: job.h:309
void clear_steps_location()
Definition: job.h:881
bool has_client_request_id() const
Definition: job.h:99
void clear_created_from_snapshot_id()
Definition: job.h:187
void set_name(const StringPiece &value)
Definition: job.h:561
client::JsonCppAssociativeArray< string > mutable_labels()
Definition: job.h:477
const client::JsonCppAssociativeArray< string > get_transform_name_mapping() const
Definition: job.h:976
bool has_start_time() const
Definition: job.h:799
const StringPiece get_start_time() const
Definition: job.h:814
void clear_id()
Definition: job.h:375
void clear_replace_job_id()
Definition: job.h:650
bool has_transform_name_mapping() const
Definition: job.h:960
bool has_temp_files() const
Definition: job.h:911
void clear_transform_name_mapping()
Definition: job.h:967
const StringPiece get_requested_state() const
Definition: job.h:738
bool has_environment() const
Definition: job.h:302