/* * Copyright 2020 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * https://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // Generated by the protocol buffer compiler. DO NOT EDIT! // source: google/dataflow/v1beta3/jobs.proto package com.google.dataflow.v1beta3; public final class JobsProto { private JobsProto() {} public static void registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry) {} public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry) { registerAllExtensions((com.google.protobuf.ExtensionRegistryLite) registry); } static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_Job_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_Job_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_Job_TransformNameMappingEntry_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_Job_TransformNameMappingEntry_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_Job_LabelsEntry_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_Job_LabelsEntry_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_DatastoreIODetails_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_DatastoreIODetails_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_PubSubIODetails_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_PubSubIODetails_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_FileIODetails_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_FileIODetails_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_BigTableIODetails_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_BigTableIODetails_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_BigQueryIODetails_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_BigQueryIODetails_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_SpannerIODetails_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_SpannerIODetails_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_SdkVersion_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_SdkVersion_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_JobMetadata_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_JobMetadata_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_ExecutionStageState_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_ExecutionStageState_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_PipelineDescription_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_PipelineDescription_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_TransformSummary_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_TransformSummary_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_ExecutionStageSummary_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_ExecutionStageSummary_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_ExecutionStageSummary_StageSource_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_ExecutionStageSummary_StageSource_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentTransform_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentTransform_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentSource_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentSource_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_DisplayData_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_DisplayData_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_Step_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_Step_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_JobExecutionInfo_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_JobExecutionInfo_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_JobExecutionInfo_StagesEntry_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_JobExecutionInfo_StagesEntry_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_JobExecutionStageInfo_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_JobExecutionStageInfo_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_CreateJobRequest_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_CreateJobRequest_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_GetJobRequest_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_GetJobRequest_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_UpdateJobRequest_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_UpdateJobRequest_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_ListJobsRequest_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_ListJobsRequest_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_FailedLocation_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_FailedLocation_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_ListJobsResponse_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_ListJobsResponse_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_SnapshotJobRequest_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_SnapshotJobRequest_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_CheckActiveJobsRequest_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_CheckActiveJobsRequest_fieldAccessorTable; static final com.google.protobuf.Descriptors.Descriptor internal_static_google_dataflow_v1beta3_CheckActiveJobsResponse_descriptor; static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_google_dataflow_v1beta3_CheckActiveJobsResponse_fieldAccessorTable; public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { return descriptor; } private static com.google.protobuf.Descriptors.FileDescriptor descriptor; static { java.lang.String[] descriptorData = { "\n\"google/dataflow/v1beta3/jobs.proto\022\027go" + "ogle.dataflow.v1beta3\032\034google/api/annota" + "tions.proto\032\027google/api/client.proto\032)go" + "ogle/dataflow/v1beta3/environment.proto\032" + "\'google/dataflow/v1beta3/snapshots.proto" + "\032\036google/protobuf/duration.proto\032\034google" + "/protobuf/struct.proto\032\037google/protobuf/" + "timestamp.proto\"\256\t\n\003Job\022\n\n\002id\030\001 \001(\t\022\022\n\np" + "roject_id\030\002 \001(\t\022\014\n\004name\030\003 \001(\t\022.\n\004type\030\004 " + "\001(\0162 .google.dataflow.v1beta3.JobType\0229\n" + "\013environment\030\005 \001(\0132$.google.dataflow.v1b" + "eta3.Environment\022,\n\005steps\030\006 \003(\0132\035.google" + ".dataflow.v1beta3.Step\022\026\n\016steps_location" + "\030\030 \001(\t\0228\n\rcurrent_state\030\007 \001(\0162!.google.d" + "ataflow.v1beta3.JobState\0226\n\022current_stat" + "e_time\030\010 \001(\0132\032.google.protobuf.Timestamp" + "\022:\n\017requested_state\030\t \001(\0162!.google.dataf" + "low.v1beta3.JobState\022A\n\016execution_info\030\n" + " \001(\0132).google.dataflow.v1beta3.JobExecut" + "ionInfo\022/\n\013create_time\030\013 \001(\0132\032.google.pr" + "otobuf.Timestamp\022\026\n\016replace_job_id\030\014 \001(\t" + "\022V\n\026transform_name_mapping\030\r \003(\01326.googl" + "e.dataflow.v1beta3.Job.TransformNameMapp" + "ingEntry\022\031\n\021client_request_id\030\016 \001(\t\022\032\n\022r" + "eplaced_by_job_id\030\017 \001(\t\022\022\n\ntemp_files\030\020 " + "\003(\t\0228\n\006labels\030\021 \003(\0132(.google.dataflow.v1" + "beta3.Job.LabelsEntry\022\020\n\010location\030\022 \001(\t\022" + "J\n\024pipeline_description\030\023 \001(\0132,.google.d" + "ataflow.v1beta3.PipelineDescription\022B\n\014s" + "tage_states\030\024 \003(\0132,.google.dataflow.v1be" + "ta3.ExecutionStageState\022:\n\014job_metadata\030" + "\025 \001(\0132$.google.dataflow.v1beta3.JobMetad" + "ata\022.\n\nstart_time\030\026 \001(\0132\032.google.protobu" + "f.Timestamp\022 \n\030created_from_snapshot_id\030" + "\027 \001(\t\022\025\n\rsatisfies_pzs\030\031 \001(\010\032;\n\031Transfor" + "mNameMappingEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030" + "\002 \001(\t:\0028\001\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n" + "\005value\030\002 \001(\t:\0028\001\";\n\022DatastoreIODetails\022\021" + "\n\tnamespace\030\001 \001(\t\022\022\n\nproject_id\030\002 \001(\t\"6\n" + "\017PubSubIODetails\022\r\n\005topic\030\001 \001(\t\022\024\n\014subsc" + "ription\030\002 \001(\t\"%\n\rFileIODetails\022\024\n\014file_p" + "attern\030\001 \001(\t\"N\n\021BigTableIODetails\022\022\n\npro" + "ject_id\030\001 \001(\t\022\023\n\013instance_id\030\002 \001(\t\022\020\n\010ta" + "ble_id\030\003 \001(\t\"V\n\021BigQueryIODetails\022\r\n\005tab" + "le\030\001 \001(\t\022\017\n\007dataset\030\002 \001(\t\022\022\n\nproject_id\030" + "\003 \001(\t\022\r\n\005query\030\004 \001(\t\"P\n\020SpannerIODetails" + "\022\022\n\nproject_id\030\001 \001(\t\022\023\n\013instance_id\030\002 \001(" + "\t\022\023\n\013database_id\030\003 \001(\t\"\351\001\n\nSdkVersion\022\017\n" + "\007version\030\001 \001(\t\022\034\n\024version_display_name\030\002" + " \001(\t\022P\n\022sdk_support_status\030\003 \001(\01624.googl" + "e.dataflow.v1beta3.SdkVersion.SdkSupport" + "Status\"Z\n\020SdkSupportStatus\022\013\n\007UNKNOWN\020\000\022" + "\r\n\tSUPPORTED\020\001\022\t\n\005STALE\020\002\022\016\n\nDEPRECATED\020" + "\003\022\017\n\013UNSUPPORTED\020\004\"\340\003\n\013JobMetadata\0228\n\013sd" + "k_version\030\001 \001(\0132#.google.dataflow.v1beta" + "3.SdkVersion\022B\n\017spanner_details\030\002 \003(\0132)." + "google.dataflow.v1beta3.SpannerIODetails" + "\022D\n\020bigquery_details\030\003 \003(\0132*.google.data" + "flow.v1beta3.BigQueryIODetails\022E\n\021big_ta" + "ble_details\030\004 \003(\0132*.google.dataflow.v1be" + "ta3.BigTableIODetails\022@\n\016pubsub_details\030" + "\005 \003(\0132(.google.dataflow.v1beta3.PubSubIO" + "Details\022<\n\014file_details\030\006 \003(\0132&.google.d" + "ataflow.v1beta3.FileIODetails\022F\n\021datasto" + "re_details\030\007 \003(\0132+.google.dataflow.v1bet" + "a3.DatastoreIODetails\"\255\001\n\023ExecutionStage" + "State\022\034\n\024execution_stage_name\030\001 \001(\t\022@\n\025e" + "xecution_stage_state\030\002 \001(\0162!.google.data" + "flow.v1beta3.JobState\0226\n\022current_state_t" + "ime\030\003 \001(\0132\032.google.protobuf.Timestamp\"\363\001" + "\n\023PipelineDescription\022N\n\033original_pipeli" + "ne_transform\030\001 \003(\0132).google.dataflow.v1b" + "eta3.TransformSummary\022P\n\030execution_pipel" + "ine_stage\030\002 \003(\0132..google.dataflow.v1beta" + "3.ExecutionStageSummary\022:\n\014display_data\030" + "\003 \003(\0132$.google.dataflow.v1beta3.DisplayD" + "ata\"\330\001\n\020TransformSummary\022/\n\004kind\030\001 \001(\0162!" + ".google.dataflow.v1beta3.KindType\022\n\n\002id\030" + "\002 \001(\t\022\014\n\004name\030\003 \001(\t\022:\n\014display_data\030\004 \003(" + "\0132$.google.dataflow.v1beta3.DisplayData\022" + "\036\n\026output_collection_name\030\005 \003(\t\022\035\n\025input" + "_collection_name\030\006 \003(\t\"\374\005\n\025ExecutionStag" + "eSummary\022\014\n\004name\030\001 \001(\t\022\n\n\002id\030\002 \001(\t\022/\n\004ki" + "nd\030\003 \001(\0162!.google.dataflow.v1beta3.KindT" + "ype\022P\n\014input_source\030\004 \003(\0132:.google.dataf" + "low.v1beta3.ExecutionStageSummary.StageS" + "ource\022Q\n\routput_source\030\005 \003(\0132:.google.da" + "taflow.v1beta3.ExecutionStageSummary.Sta" + "geSource\022\032\n\022prerequisite_stage\030\010 \003(\t\022^\n\023" + "component_transform\030\006 \003(\0132A.google.dataf" + "low.v1beta3.ExecutionStageSummary.Compon" + "entTransform\022X\n\020component_source\030\007 \003(\0132>" + ".google.dataflow.v1beta3.ExecutionStageS" + "ummary.ComponentSource\032l\n\013StageSource\022\021\n" + "\tuser_name\030\001 \001(\t\022\014\n\004name\030\002 \001(\t\022(\n origin" + "al_transform_or_collection\030\003 \001(\t\022\022\n\nsize" + "_bytes\030\004 \001(\003\032Q\n\022ComponentTransform\022\021\n\tus" + "er_name\030\001 \001(\t\022\014\n\004name\030\002 \001(\t\022\032\n\022original_" + "transform\030\003 \001(\t\032\\\n\017ComponentSource\022\021\n\tus" + "er_name\030\001 \001(\t\022\014\n\004name\030\002 \001(\t\022(\n original_" + "transform_or_collection\030\003 \001(\t\"\314\002\n\013Displa" + "yData\022\013\n\003key\030\001 \001(\t\022\021\n\tnamespace\030\002 \001(\t\022\023\n" + "\tstr_value\030\004 \001(\tH\000\022\025\n\013int64_value\030\005 \001(\003H" + "\000\022\025\n\013float_value\030\006 \001(\002H\000\022\032\n\020java_class_v" + "alue\030\007 \001(\tH\000\0225\n\017timestamp_value\030\010 \001(\0132\032." + "google.protobuf.TimestampH\000\0223\n\016duration_" + "value\030\t \001(\0132\031.google.protobuf.DurationH\000" + "\022\024\n\nbool_value\030\n \001(\010H\000\022\027\n\017short_str_valu" + "e\030\013 \001(\t\022\013\n\003url\030\014 \001(\t\022\r\n\005label\030\r \001(\tB\007\n\005V" + "alue\"O\n\004Step\022\014\n\004kind\030\001 \001(\t\022\014\n\004name\030\002 \001(\t" + "\022+\n\nproperties\030\003 \001(\0132\027.google.protobuf.S" + "truct\"\270\001\n\020JobExecutionInfo\022E\n\006stages\030\001 \003" + "(\01325.google.dataflow.v1beta3.JobExecutio" + "nInfo.StagesEntry\032]\n\013StagesEntry\022\013\n\003key\030" + "\001 \001(\t\022=\n\005value\030\002 \001(\0132..google.dataflow.v" + "1beta3.JobExecutionStageInfo:\0028\001\"*\n\025JobE" + "xecutionStageInfo\022\021\n\tstep_name\030\001 \003(\t\"\253\001\n" + "\020CreateJobRequest\022\022\n\nproject_id\030\001 \001(\t\022)\n" + "\003job\030\002 \001(\0132\034.google.dataflow.v1beta3.Job" + "\022.\n\004view\030\003 \001(\0162 .google.dataflow.v1beta3" + ".JobView\022\026\n\016replace_job_id\030\004 \001(\t\022\020\n\010loca" + "tion\030\005 \001(\t\"u\n\rGetJobRequest\022\022\n\nproject_i" + "d\030\001 \001(\t\022\016\n\006job_id\030\002 \001(\t\022.\n\004view\030\003 \001(\0162 ." + "google.dataflow.v1beta3.JobView\022\020\n\010locat" + "ion\030\004 \001(\t\"s\n\020UpdateJobRequest\022\022\n\nproject" + "_id\030\001 \001(\t\022\016\n\006job_id\030\002 \001(\t\022)\n\003job\030\003 \001(\0132\034" + ".google.dataflow.v1beta3.Job\022\020\n\010location" + "\030\004 \001(\t\"\217\002\n\017ListJobsRequest\022?\n\006filter\030\005 \001" + "(\0162/.google.dataflow.v1beta3.ListJobsReq" + "uest.Filter\022\022\n\nproject_id\030\001 \001(\t\0222\n\004view\030" + "\002 \001(\0162 .google.dataflow.v1beta3.JobViewB" + "\002\030\001\022\021\n\tpage_size\030\003 \001(\005\022\022\n\npage_token\030\004 \001" + "(\t\022\020\n\010location\030\021 \001(\t\":\n\006Filter\022\013\n\007UNKNOW" + "N\020\000\022\007\n\003ALL\020\001\022\016\n\nTERMINATED\020\002\022\n\n\006ACTIVE\020\003" + "\"\036\n\016FailedLocation\022\014\n\004name\030\001 \001(\t\"\231\001\n\020Lis" + "tJobsResponse\022*\n\004jobs\030\001 \003(\0132\034.google.dat" + "aflow.v1beta3.Job\022\027\n\017next_page_token\030\002 \001" + "(\t\022@\n\017failed_location\030\003 \003(\0132\'.google.dat" + "aflow.v1beta3.FailedLocation\"\241\001\n\022Snapsho" + "tJobRequest\022\022\n\nproject_id\030\001 \001(\t\022\016\n\006job_i" + "d\030\002 \001(\t\022&\n\003ttl\030\003 \001(\0132\031.google.protobuf.D" + "uration\022\020\n\010location\030\004 \001(\t\022\030\n\020snapshot_so" + "urces\030\005 \001(\010\022\023\n\013description\030\006 \001(\t\",\n\026Chec" + "kActiveJobsRequest\022\022\n\nproject_id\030\001 \001(\t\"4" + "\n\027CheckActiveJobsResponse\022\031\n\021active_jobs" + "_exist\030\001 \001(\010*\256\001\n\010KindType\022\020\n\014UNKNOWN_KIN" + "D\020\000\022\017\n\013PAR_DO_KIND\020\001\022\025\n\021GROUP_BY_KEY_KIN" + "D\020\002\022\020\n\014FLATTEN_KIND\020\003\022\r\n\tREAD_KIND\020\004\022\016\n\n" + "WRITE_KIND\020\005\022\021\n\rCONSTANT_KIND\020\006\022\022\n\016SINGL" + "ETON_KIND\020\007\022\020\n\014SHUFFLE_KIND\020\010*\303\002\n\010JobSta" + "te\022\025\n\021JOB_STATE_UNKNOWN\020\000\022\025\n\021JOB_STATE_S" + "TOPPED\020\001\022\025\n\021JOB_STATE_RUNNING\020\002\022\022\n\016JOB_S" + "TATE_DONE\020\003\022\024\n\020JOB_STATE_FAILED\020\004\022\027\n\023JOB" + "_STATE_CANCELLED\020\005\022\025\n\021JOB_STATE_UPDATED\020" + "\006\022\026\n\022JOB_STATE_DRAINING\020\007\022\025\n\021JOB_STATE_D" + "RAINED\020\010\022\025\n\021JOB_STATE_PENDING\020\t\022\030\n\024JOB_S" + "TATE_CANCELLING\020\n\022\024\n\020JOB_STATE_QUEUED\020\013\022" + "\"\n\036JOB_STATE_RESOURCE_CLEANING_UP\020\014*a\n\007J" + "obView\022\024\n\020JOB_VIEW_UNKNOWN\020\000\022\024\n\020JOB_VIEW" + "_SUMMARY\020\001\022\020\n\014JOB_VIEW_ALL\020\002\022\030\n\024JOB_VIEW" + "_DESCRIPTION\020\0032\221\014\n\013JobsV1Beta3\022\301\001\n\tCreat" + "eJob\022).google.dataflow.v1beta3.CreateJob" + "Request\032\034.google.dataflow.v1beta3.Job\"k\202" + "\323\344\223\002e\"5/v1b3/projects/{project_id}/locat" + "ions/{location}/jobs:\003jobZ\'\" /v1b3/proje" + "cts/{project_id}/jobs:\003job\022\303\001\n\006GetJob\022&." + "google.dataflow.v1beta3.GetJobRequest\032\034." + "google.dataflow.v1beta3.Job\"s\202\323\344\223\002m\022>/v1" + "b3/projects/{project_id}/locations/{loca" + "tion}/jobs/{job_id}Z+\022)/v1b3/projects/{p" + "roject_id}/jobs/{job_id}\022\323\001\n\tUpdateJob\022)" + ".google.dataflow.v1beta3.UpdateJobReques" + "t\032\034.google.dataflow.v1beta3.Job\"}\202\323\344\223\002w\032" + ">/v1b3/projects/{project_id}/locations/{" + "location}/jobs/{job_id}:\003jobZ0\032)/v1b3/pr" + "ojects/{project_id}/jobs/{job_id}:\003job\022\302" + "\001\n\010ListJobs\022(.google.dataflow.v1beta3.Li" + "stJobsRequest\032).google.dataflow.v1beta3." + "ListJobsResponse\"a\202\323\344\223\002[\0225/v1b3/projects" + "/{project_id}/locations/{location}/jobsZ" + "\"\022 /v1b3/projects/{project_id}/jobs\022\236\001\n\022" + "AggregatedListJobs\022(.google.dataflow.v1b" + "eta3.ListJobsRequest\032).google.dataflow.v" + "1beta3.ListJobsResponse\"3\202\323\344\223\002-\022+/v1b3/p" + "rojects/{project_id}/jobs:aggregated\022v\n\017" + "CheckActiveJobs\022/.google.dataflow.v1beta" + "3.CheckActiveJobsRequest\0320.google.datafl" + "ow.v1beta3.CheckActiveJobsResponse\"\000\022\354\001\n" + "\013SnapshotJob\022+.google.dataflow.v1beta3.S" + "napshotJobRequest\032!.google.dataflow.v1be" + "ta3.Snapshot\"\214\001\202\323\344\223\002\205\001\"G/v1b3/projects/{" + "project_id}/locations/{location}/jobs/{j" + "ob_id}:snapshot:\001*Z7\"2/v1b3/projects/{pr" + "oject_id}/jobs/{job_id}:snapshot:\001*\032\324\001\312A" + "\027dataflow.googleapis.com\322A\266\001https://www." + "googleapis.com/auth/cloud-platform,https" + "://www.googleapis.com/auth/compute,https" + "://www.googleapis.com/auth/compute.reado" + "nly,https://www.googleapis.com/auth/user" + "info.emailB\314\001\n\033com.google.dataflow.v1bet" + "a3B\tJobsProtoP\001Z=cloud.google.com/go/dat" + "aflow/apiv1beta3/dataflowpb;dataflowpb\252\002" + "\035Google.Cloud.Dataflow.V1Beta3\312\002\035Google\\" + "Cloud\\Dataflow\\V1beta3\352\002 Google::Cloud::" + "Dataflow::V1beta3b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( descriptorData, new com.google.protobuf.Descriptors.FileDescriptor[] { com.google.api.AnnotationsProto.getDescriptor(), com.google.api.ClientProto.getDescriptor(), com.google.dataflow.v1beta3.EnvironmentProto.getDescriptor(), com.google.dataflow.v1beta3.SnapshotsProto.getDescriptor(), com.google.protobuf.DurationProto.getDescriptor(), com.google.protobuf.StructProto.getDescriptor(), com.google.protobuf.TimestampProto.getDescriptor(), }); internal_static_google_dataflow_v1beta3_Job_descriptor = getDescriptor().getMessageTypes().get(0); internal_static_google_dataflow_v1beta3_Job_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_Job_descriptor, new java.lang.String[] { "Id", "ProjectId", "Name", "Type", "Environment", "Steps", "StepsLocation", "CurrentState", "CurrentStateTime", "RequestedState", "ExecutionInfo", "CreateTime", "ReplaceJobId", "TransformNameMapping", "ClientRequestId", "ReplacedByJobId", "TempFiles", "Labels", "Location", "PipelineDescription", "StageStates", "JobMetadata", "StartTime", "CreatedFromSnapshotId", "SatisfiesPzs", }); internal_static_google_dataflow_v1beta3_Job_TransformNameMappingEntry_descriptor = internal_static_google_dataflow_v1beta3_Job_descriptor.getNestedTypes().get(0); internal_static_google_dataflow_v1beta3_Job_TransformNameMappingEntry_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_Job_TransformNameMappingEntry_descriptor, new java.lang.String[] { "Key", "Value", }); internal_static_google_dataflow_v1beta3_Job_LabelsEntry_descriptor = internal_static_google_dataflow_v1beta3_Job_descriptor.getNestedTypes().get(1); internal_static_google_dataflow_v1beta3_Job_LabelsEntry_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_Job_LabelsEntry_descriptor, new java.lang.String[] { "Key", "Value", }); internal_static_google_dataflow_v1beta3_DatastoreIODetails_descriptor = getDescriptor().getMessageTypes().get(1); internal_static_google_dataflow_v1beta3_DatastoreIODetails_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_DatastoreIODetails_descriptor, new java.lang.String[] { "Namespace", "ProjectId", }); internal_static_google_dataflow_v1beta3_PubSubIODetails_descriptor = getDescriptor().getMessageTypes().get(2); internal_static_google_dataflow_v1beta3_PubSubIODetails_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_PubSubIODetails_descriptor, new java.lang.String[] { "Topic", "Subscription", }); internal_static_google_dataflow_v1beta3_FileIODetails_descriptor = getDescriptor().getMessageTypes().get(3); internal_static_google_dataflow_v1beta3_FileIODetails_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_FileIODetails_descriptor, new java.lang.String[] { "FilePattern", }); internal_static_google_dataflow_v1beta3_BigTableIODetails_descriptor = getDescriptor().getMessageTypes().get(4); internal_static_google_dataflow_v1beta3_BigTableIODetails_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_BigTableIODetails_descriptor, new java.lang.String[] { "ProjectId", "InstanceId", "TableId", }); internal_static_google_dataflow_v1beta3_BigQueryIODetails_descriptor = getDescriptor().getMessageTypes().get(5); internal_static_google_dataflow_v1beta3_BigQueryIODetails_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_BigQueryIODetails_descriptor, new java.lang.String[] { "Table", "Dataset", "ProjectId", "Query", }); internal_static_google_dataflow_v1beta3_SpannerIODetails_descriptor = getDescriptor().getMessageTypes().get(6); internal_static_google_dataflow_v1beta3_SpannerIODetails_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_SpannerIODetails_descriptor, new java.lang.String[] { "ProjectId", "InstanceId", "DatabaseId", }); internal_static_google_dataflow_v1beta3_SdkVersion_descriptor = getDescriptor().getMessageTypes().get(7); internal_static_google_dataflow_v1beta3_SdkVersion_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_SdkVersion_descriptor, new java.lang.String[] { "Version", "VersionDisplayName", "SdkSupportStatus", }); internal_static_google_dataflow_v1beta3_JobMetadata_descriptor = getDescriptor().getMessageTypes().get(8); internal_static_google_dataflow_v1beta3_JobMetadata_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_JobMetadata_descriptor, new java.lang.String[] { "SdkVersion", "SpannerDetails", "BigqueryDetails", "BigTableDetails", "PubsubDetails", "FileDetails", "DatastoreDetails", }); internal_static_google_dataflow_v1beta3_ExecutionStageState_descriptor = getDescriptor().getMessageTypes().get(9); internal_static_google_dataflow_v1beta3_ExecutionStageState_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_ExecutionStageState_descriptor, new java.lang.String[] { "ExecutionStageName", "ExecutionStageState", "CurrentStateTime", }); internal_static_google_dataflow_v1beta3_PipelineDescription_descriptor = getDescriptor().getMessageTypes().get(10); internal_static_google_dataflow_v1beta3_PipelineDescription_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_PipelineDescription_descriptor, new java.lang.String[] { "OriginalPipelineTransform", "ExecutionPipelineStage", "DisplayData", }); internal_static_google_dataflow_v1beta3_TransformSummary_descriptor = getDescriptor().getMessageTypes().get(11); internal_static_google_dataflow_v1beta3_TransformSummary_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_TransformSummary_descriptor, new java.lang.String[] { "Kind", "Id", "Name", "DisplayData", "OutputCollectionName", "InputCollectionName", }); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_descriptor = getDescriptor().getMessageTypes().get(12); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_ExecutionStageSummary_descriptor, new java.lang.String[] { "Name", "Id", "Kind", "InputSource", "OutputSource", "PrerequisiteStage", "ComponentTransform", "ComponentSource", }); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_StageSource_descriptor = internal_static_google_dataflow_v1beta3_ExecutionStageSummary_descriptor .getNestedTypes() .get(0); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_StageSource_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_ExecutionStageSummary_StageSource_descriptor, new java.lang.String[] { "UserName", "Name", "OriginalTransformOrCollection", "SizeBytes", }); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentTransform_descriptor = internal_static_google_dataflow_v1beta3_ExecutionStageSummary_descriptor .getNestedTypes() .get(1); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentTransform_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentTransform_descriptor, new java.lang.String[] { "UserName", "Name", "OriginalTransform", }); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentSource_descriptor = internal_static_google_dataflow_v1beta3_ExecutionStageSummary_descriptor .getNestedTypes() .get(2); internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentSource_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_ExecutionStageSummary_ComponentSource_descriptor, new java.lang.String[] { "UserName", "Name", "OriginalTransformOrCollection", }); internal_static_google_dataflow_v1beta3_DisplayData_descriptor = getDescriptor().getMessageTypes().get(13); internal_static_google_dataflow_v1beta3_DisplayData_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_DisplayData_descriptor, new java.lang.String[] { "Key", "Namespace", "StrValue", "Int64Value", "FloatValue", "JavaClassValue", "TimestampValue", "DurationValue", "BoolValue", "ShortStrValue", "Url", "Label", "Value", }); internal_static_google_dataflow_v1beta3_Step_descriptor = getDescriptor().getMessageTypes().get(14); internal_static_google_dataflow_v1beta3_Step_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_Step_descriptor, new java.lang.String[] { "Kind", "Name", "Properties", }); internal_static_google_dataflow_v1beta3_JobExecutionInfo_descriptor = getDescriptor().getMessageTypes().get(15); internal_static_google_dataflow_v1beta3_JobExecutionInfo_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_JobExecutionInfo_descriptor, new java.lang.String[] { "Stages", }); internal_static_google_dataflow_v1beta3_JobExecutionInfo_StagesEntry_descriptor = internal_static_google_dataflow_v1beta3_JobExecutionInfo_descriptor.getNestedTypes().get(0); internal_static_google_dataflow_v1beta3_JobExecutionInfo_StagesEntry_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_JobExecutionInfo_StagesEntry_descriptor, new java.lang.String[] { "Key", "Value", }); internal_static_google_dataflow_v1beta3_JobExecutionStageInfo_descriptor = getDescriptor().getMessageTypes().get(16); internal_static_google_dataflow_v1beta3_JobExecutionStageInfo_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_JobExecutionStageInfo_descriptor, new java.lang.String[] { "StepName", }); internal_static_google_dataflow_v1beta3_CreateJobRequest_descriptor = getDescriptor().getMessageTypes().get(17); internal_static_google_dataflow_v1beta3_CreateJobRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_CreateJobRequest_descriptor, new java.lang.String[] { "ProjectId", "Job", "View", "ReplaceJobId", "Location", }); internal_static_google_dataflow_v1beta3_GetJobRequest_descriptor = getDescriptor().getMessageTypes().get(18); internal_static_google_dataflow_v1beta3_GetJobRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_GetJobRequest_descriptor, new java.lang.String[] { "ProjectId", "JobId", "View", "Location", }); internal_static_google_dataflow_v1beta3_UpdateJobRequest_descriptor = getDescriptor().getMessageTypes().get(19); internal_static_google_dataflow_v1beta3_UpdateJobRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_UpdateJobRequest_descriptor, new java.lang.String[] { "ProjectId", "JobId", "Job", "Location", }); internal_static_google_dataflow_v1beta3_ListJobsRequest_descriptor = getDescriptor().getMessageTypes().get(20); internal_static_google_dataflow_v1beta3_ListJobsRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_ListJobsRequest_descriptor, new java.lang.String[] { "Filter", "ProjectId", "View", "PageSize", "PageToken", "Location", }); internal_static_google_dataflow_v1beta3_FailedLocation_descriptor = getDescriptor().getMessageTypes().get(21); internal_static_google_dataflow_v1beta3_FailedLocation_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_FailedLocation_descriptor, new java.lang.String[] { "Name", }); internal_static_google_dataflow_v1beta3_ListJobsResponse_descriptor = getDescriptor().getMessageTypes().get(22); internal_static_google_dataflow_v1beta3_ListJobsResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_ListJobsResponse_descriptor, new java.lang.String[] { "Jobs", "NextPageToken", "FailedLocation", }); internal_static_google_dataflow_v1beta3_SnapshotJobRequest_descriptor = getDescriptor().getMessageTypes().get(23); internal_static_google_dataflow_v1beta3_SnapshotJobRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_SnapshotJobRequest_descriptor, new java.lang.String[] { "ProjectId", "JobId", "Ttl", "Location", "SnapshotSources", "Description", }); internal_static_google_dataflow_v1beta3_CheckActiveJobsRequest_descriptor = getDescriptor().getMessageTypes().get(24); internal_static_google_dataflow_v1beta3_CheckActiveJobsRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_CheckActiveJobsRequest_descriptor, new java.lang.String[] { "ProjectId", }); internal_static_google_dataflow_v1beta3_CheckActiveJobsResponse_descriptor = getDescriptor().getMessageTypes().get(25); internal_static_google_dataflow_v1beta3_CheckActiveJobsResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_dataflow_v1beta3_CheckActiveJobsResponse_descriptor, new java.lang.String[] { "ActiveJobsExist", }); com.google.protobuf.ExtensionRegistry registry = com.google.protobuf.ExtensionRegistry.newInstance(); registry.add(com.google.api.ClientProto.defaultHost); registry.add(com.google.api.AnnotationsProto.http); registry.add(com.google.api.ClientProto.oauthScopes); com.google.protobuf.Descriptors.FileDescriptor.internalUpdateFileDescriptor( descriptor, registry); com.google.api.AnnotationsProto.getDescriptor(); com.google.api.ClientProto.getDescriptor(); com.google.dataflow.v1beta3.EnvironmentProto.getDescriptor(); com.google.dataflow.v1beta3.SnapshotsProto.getDescriptor(); com.google.protobuf.DurationProto.getDescriptor(); com.google.protobuf.StructProto.getDescriptor(); com.google.protobuf.TimestampProto.getDescriptor(); } // @@protoc_insertion_point(outer_class_scope) }