lib/google/dataflow/v1beta3/jobs_pb.rb in google-cloud-dataflow-v1beta3-0.5.0 vs lib/google/dataflow/v1beta3/jobs_pb.rb in google-cloud-dataflow-v1beta3-0.6.0
- old
+ new
@@ -1,5 +1,6 @@
+# frozen_string_literal: true
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: google/dataflow/v1beta3/jobs.proto
require 'google/protobuf'
@@ -9,245 +10,38 @@
require 'google/dataflow/v1beta3/snapshots_pb'
require 'google/protobuf/duration_pb'
require 'google/protobuf/struct_pb'
require 'google/protobuf/timestamp_pb'
-Google::Protobuf::DescriptorPool.generated_pool.build do
- add_file("google/dataflow/v1beta3/jobs.proto", :syntax => :proto3) do
- add_message "google.dataflow.v1beta3.Job" do
- optional :id, :string, 1
- optional :project_id, :string, 2
- optional :name, :string, 3
- optional :type, :enum, 4, "google.dataflow.v1beta3.JobType"
- optional :environment, :message, 5, "google.dataflow.v1beta3.Environment"
- repeated :steps, :message, 6, "google.dataflow.v1beta3.Step"
- optional :steps_location, :string, 24
- optional :current_state, :enum, 7, "google.dataflow.v1beta3.JobState"
- optional :current_state_time, :message, 8, "google.protobuf.Timestamp"
- optional :requested_state, :enum, 9, "google.dataflow.v1beta3.JobState"
- optional :execution_info, :message, 10, "google.dataflow.v1beta3.JobExecutionInfo"
- optional :create_time, :message, 11, "google.protobuf.Timestamp"
- optional :replace_job_id, :string, 12
- map :transform_name_mapping, :string, :string, 13
- optional :client_request_id, :string, 14
- optional :replaced_by_job_id, :string, 15
- repeated :temp_files, :string, 16
- map :labels, :string, :string, 17
- optional :location, :string, 18
- optional :pipeline_description, :message, 19, "google.dataflow.v1beta3.PipelineDescription"
- repeated :stage_states, :message, 20, "google.dataflow.v1beta3.ExecutionStageState"
- optional :job_metadata, :message, 21, "google.dataflow.v1beta3.JobMetadata"
- optional :start_time, :message, 22, "google.protobuf.Timestamp"
- optional :created_from_snapshot_id, :string, 23
- optional :satisfies_pzs, :bool, 25
+
+descriptor_data = "\n\"google/dataflow/v1beta3/jobs.proto\x12\x17google.dataflow.v1beta3\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a)google/dataflow/v1beta3/environment.proto\x1a\'google/dataflow/v1beta3/snapshots.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xae\t\n\x03Job\x12\n\n\x02id\x18\x01 \x01(\t\x12\x12\n\nproject_id\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12.\n\x04type\x18\x04 \x01(\x0e\x32 .google.dataflow.v1beta3.JobType\x12\x39\n\x0b\x65nvironment\x18\x05 \x01(\x0b\x32$.google.dataflow.v1beta3.Environment\x12,\n\x05steps\x18\x06 \x03(\x0b\x32\x1d.google.dataflow.v1beta3.Step\x12\x16\n\x0esteps_location\x18\x18 \x01(\t\x12\x38\n\rcurrent_state\x18\x07 \x01(\x0e\x32!.google.dataflow.v1beta3.JobState\x12\x36\n\x12\x63urrent_state_time\x18\x08 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12:\n\x0frequested_state\x18\t \x01(\x0e\x32!.google.dataflow.v1beta3.JobState\x12\x41\n\x0e\x65xecution_info\x18\n \x01(\x0b\x32).google.dataflow.v1beta3.JobExecutionInfo\x12/\n\x0b\x63reate_time\x18\x0b \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x16\n\x0ereplace_job_id\x18\x0c \x01(\t\x12V\n\x16transform_name_mapping\x18\r \x03(\x0b\x32\x36.google.dataflow.v1beta3.Job.TransformNameMappingEntry\x12\x19\n\x11\x63lient_request_id\x18\x0e \x01(\t\x12\x1a\n\x12replaced_by_job_id\x18\x0f \x01(\t\x12\x12\n\ntemp_files\x18\x10 \x03(\t\x12\x38\n\x06labels\x18\x11 \x03(\x0b\x32(.google.dataflow.v1beta3.Job.LabelsEntry\x12\x10\n\x08location\x18\x12 \x01(\t\x12J\n\x14pipeline_description\x18\x13 \x01(\x0b\x32,.google.dataflow.v1beta3.PipelineDescription\x12\x42\n\x0cstage_states\x18\x14 \x03(\x0b\x32,.google.dataflow.v1beta3.ExecutionStageState\x12:\n\x0cjob_metadata\x18\x15 \x01(\x0b\x32$.google.dataflow.v1beta3.JobMetadata\x12.\n\nstart_time\x18\x16 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12 \n\x18\x63reated_from_snapshot_id\x18\x17 \x01(\t\x12\x15\n\rsatisfies_pzs\x18\x19 \x01(\x08\x1a;\n\x19TransformNameMappingEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a-\n\x0bLabelsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\";\n\x12\x44\x61tastoreIODetails\x12\x11\n\tnamespace\x18\x01 \x01(\t\x12\x12\n\nproject_id\x18\x02 \x01(\t\"6\n\x0fPubSubIODetails\x12\r\n\x05topic\x18\x01 \x01(\t\x12\x14\n\x0csubscription\x18\x02 \x01(\t\"%\n\rFileIODetails\x12\x14\n\x0c\x66ile_pattern\x18\x01 \x01(\t\"N\n\x11\x42igTableIODetails\x12\x12\n\nproject_id\x18\x01 \x01(\t\x12\x13\n\x0binstance_id\x18\x02 \x01(\t\x12\x10\n\x08table_id\x18\x03 \x01(\t\"V\n\x11\x42igQueryIODetails\x12\r\n\x05table\x18\x01 \x01(\t\x12\x0f\n\x07\x64\x61taset\x18\x02 \x01(\t\x12\x12\n\nproject_id\x18\x03 \x01(\t\x12\r\n\x05query\x18\x04 \x01(\t\"P\n\x10SpannerIODetails\x12\x12\n\nproject_id\x18\x01 \x01(\t\x12\x13\n\x0binstance_id\x18\x02 \x01(\t\x12\x13\n\x0b\x64\x61tabase_id\x18\x03 \x01(\t\"\xe9\x01\n\nSdkVersion\x12\x0f\n\x07version\x18\x01 \x01(\t\x12\x1c\n\x14version_display_name\x18\x02 \x01(\t\x12P\n\x12sdk_support_status\x18\x03 \x01(\x0e\x32\x34.google.dataflow.v1beta3.SdkVersion.SdkSupportStatus\"Z\n\x10SdkSupportStatus\x12\x0b\n\x07UNKNOWN\x10\x00\x12\r\n\tSUPPORTED\x10\x01\x12\t\n\x05STALE\x10\x02\x12\x0e\n\nDEPRECATED\x10\x03\x12\x0f\n\x0bUNSUPPORTED\x10\x04\"\xe0\x03\n\x0bJobMetadata\x12\x38\n\x0bsdk_version\x18\x01 \x01(\x0b\x32#.google.dataflow.v1beta3.SdkVersion\x12\x42\n\x0fspanner_details\x18\x02 \x03(\x0b\x32).google.dataflow.v1beta3.SpannerIODetails\x12\x44\n\x10\x62igquery_details\x18\x03 \x03(\x0b\x32*.google.dataflow.v1beta3.BigQueryIODetails\x12\x45\n\x11\x62ig_table_details\x18\x04 \x03(\x0b\x32*.google.dataflow.v1beta3.BigTableIODetails\x12@\n\x0epubsub_details\x18\x05 \x03(\x0b\x32(.google.dataflow.v1beta3.PubSubIODetails\x12<\n\x0c\x66ile_details\x18\x06 \x03(\x0b\x32&.google.dataflow.v1beta3.FileIODetails\x12\x46\n\x11\x64\x61tastore_details\x18\x07 \x03(\x0b\x32+.google.dataflow.v1beta3.DatastoreIODetails\"\xad\x01\n\x13\x45xecutionStageState\x12\x1c\n\x14\x65xecution_stage_name\x18\x01 \x01(\t\x12@\n\x15\x65xecution_stage_state\x18\x02 \x01(\x0e\x32!.google.dataflow.v1beta3.JobState\x12\x36\n\x12\x63urrent_state_time\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xf3\x01\n\x13PipelineDescription\x12N\n\x1boriginal_pipeline_transform\x18\x01 \x03(\x0b\x32).google.dataflow.v1beta3.TransformSummary\x12P\n\x18\x65xecution_pipeline_stage\x18\x02 \x03(\x0b\x32..google.dataflow.v1beta3.ExecutionStageSummary\x12:\n\x0c\x64isplay_data\x18\x03 \x03(\x0b\x32$.google.dataflow.v1beta3.DisplayData\"\xd8\x01\n\x10TransformSummary\x12/\n\x04kind\x18\x01 \x01(\x0e\x32!.google.dataflow.v1beta3.KindType\x12\n\n\x02id\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12:\n\x0c\x64isplay_data\x18\x04 \x03(\x0b\x32$.google.dataflow.v1beta3.DisplayData\x12\x1e\n\x16output_collection_name\x18\x05 \x03(\t\x12\x1d\n\x15input_collection_name\x18\x06 \x03(\t\"\xfc\x05\n\x15\x45xecutionStageSummary\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\n\n\x02id\x18\x02 \x01(\t\x12/\n\x04kind\x18\x03 \x01(\x0e\x32!.google.dataflow.v1beta3.KindType\x12P\n\x0cinput_source\x18\x04 \x03(\x0b\x32:.google.dataflow.v1beta3.ExecutionStageSummary.StageSource\x12Q\n\routput_source\x18\x05 \x03(\x0b\x32:.google.dataflow.v1beta3.ExecutionStageSummary.StageSource\x12\x1a\n\x12prerequisite_stage\x18\x08 \x03(\t\x12^\n\x13\x63omponent_transform\x18\x06 \x03(\x0b\x32\x41.google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform\x12X\n\x10\x63omponent_source\x18\x07 \x03(\x0b\x32>.google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource\x1al\n\x0bStageSource\x12\x11\n\tuser_name\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12(\n original_transform_or_collection\x18\x03 \x01(\t\x12\x12\n\nsize_bytes\x18\x04 \x01(\x03\x1aQ\n\x12\x43omponentTransform\x12\x11\n\tuser_name\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12\x1a\n\x12original_transform\x18\x03 \x01(\t\x1a\\\n\x0f\x43omponentSource\x12\x11\n\tuser_name\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12(\n original_transform_or_collection\x18\x03 \x01(\t\"\xcc\x02\n\x0b\x44isplayData\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\x11\n\tnamespace\x18\x02 \x01(\t\x12\x13\n\tstr_value\x18\x04 \x01(\tH\x00\x12\x15\n\x0bint64_value\x18\x05 \x01(\x03H\x00\x12\x15\n\x0b\x66loat_value\x18\x06 \x01(\x02H\x00\x12\x1a\n\x10java_class_value\x18\x07 \x01(\tH\x00\x12\x35\n\x0ftimestamp_value\x18\x08 \x01(\x0b\x32\x1a.google.protobuf.TimestampH\x00\x12\x33\n\x0e\x64uration_value\x18\t \x01(\x0b\x32\x19.google.protobuf.DurationH\x00\x12\x14\n\nbool_value\x18\n \x01(\x08H\x00\x12\x17\n\x0fshort_str_value\x18\x0b \x01(\t\x12\x0b\n\x03url\x18\x0c \x01(\t\x12\r\n\x05label\x18\r \x01(\tB\x07\n\x05Value\"O\n\x04Step\x12\x0c\n\x04kind\x18\x01 \x01(\t\x12\x0c\n\x04name\x18\x02 \x01(\t\x12+\n\nproperties\x18\x03 \x01(\x0b\x32\x17.google.protobuf.Struct\"\xb8\x01\n\x10JobExecutionInfo\x12\x45\n\x06stages\x18\x01 \x03(\x0b\x32\x35.google.dataflow.v1beta3.JobExecutionInfo.StagesEntry\x1a]\n\x0bStagesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12=\n\x05value\x18\x02 \x01(\x0b\x32..google.dataflow.v1beta3.JobExecutionStageInfo:\x02\x38\x01\"*\n\x15JobExecutionStageInfo\x12\x11\n\tstep_name\x18\x01 \x03(\t\"\xab\x01\n\x10\x43reateJobRequest\x12\x12\n\nproject_id\x18\x01 \x01(\t\x12)\n\x03job\x18\x02 \x01(\x0b\x32\x1c.google.dataflow.v1beta3.Job\x12.\n\x04view\x18\x03 \x01(\x0e\x32 .google.dataflow.v1beta3.JobView\x12\x16\n\x0ereplace_job_id\x18\x04 \x01(\t\x12\x10\n\x08location\x18\x05 \x01(\t\"u\n\rGetJobRequest\x12\x12\n\nproject_id\x18\x01 \x01(\t\x12\x0e\n\x06job_id\x18\x02 \x01(\t\x12.\n\x04view\x18\x03 \x01(\x0e\x32 .google.dataflow.v1beta3.JobView\x12\x10\n\x08location\x18\x04 \x01(\t\"s\n\x10UpdateJobRequest\x12\x12\n\nproject_id\x18\x01 \x01(\t\x12\x0e\n\x06job_id\x18\x02 \x01(\t\x12)\n\x03job\x18\x03 \x01(\x0b\x32\x1c.google.dataflow.v1beta3.Job\x12\x10\n\x08location\x18\x04 \x01(\t\"\x8f\x02\n\x0fListJobsRequest\x12?\n\x06\x66ilter\x18\x05 \x01(\x0e\x32/.google.dataflow.v1beta3.ListJobsRequest.Filter\x12\x12\n\nproject_id\x18\x01 \x01(\t\x12\x32\n\x04view\x18\x02 \x01(\x0e\x32 .google.dataflow.v1beta3.JobViewB\x02\x18\x01\x12\x11\n\tpage_size\x18\x03 \x01(\x05\x12\x12\n\npage_token\x18\x04 \x01(\t\x12\x10\n\x08location\x18\x11 \x01(\t\":\n\x06\x46ilter\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x07\n\x03\x41LL\x10\x01\x12\x0e\n\nTERMINATED\x10\x02\x12\n\n\x06\x41\x43TIVE\x10\x03\"\x1e\n\x0e\x46\x61iledLocation\x12\x0c\n\x04name\x18\x01 \x01(\t\"\x99\x01\n\x10ListJobsResponse\x12*\n\x04jobs\x18\x01 \x03(\x0b\x32\x1c.google.dataflow.v1beta3.Job\x12\x17\n\x0fnext_page_token\x18\x02 \x01(\t\x12@\n\x0f\x66\x61iled_location\x18\x03 \x03(\x0b\x32\'.google.dataflow.v1beta3.FailedLocation\"\xa1\x01\n\x12SnapshotJobRequest\x12\x12\n\nproject_id\x18\x01 \x01(\t\x12\x0e\n\x06job_id\x18\x02 \x01(\t\x12&\n\x03ttl\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\x12\x10\n\x08location\x18\x04 \x01(\t\x12\x18\n\x10snapshot_sources\x18\x05 \x01(\x08\x12\x13\n\x0b\x64\x65scription\x18\x06 \x01(\t\",\n\x16\x43heckActiveJobsRequest\x12\x12\n\nproject_id\x18\x01 \x01(\t\"4\n\x17\x43heckActiveJobsResponse\x12\x19\n\x11\x61\x63tive_jobs_exist\x18\x01 \x01(\x08*\xae\x01\n\x08KindType\x12\x10\n\x0cUNKNOWN_KIND\x10\x00\x12\x0f\n\x0bPAR_DO_KIND\x10\x01\x12\x15\n\x11GROUP_BY_KEY_KIND\x10\x02\x12\x10\n\x0c\x46LATTEN_KIND\x10\x03\x12\r\n\tREAD_KIND\x10\x04\x12\x0e\n\nWRITE_KIND\x10\x05\x12\x11\n\rCONSTANT_KIND\x10\x06\x12\x12\n\x0eSINGLETON_KIND\x10\x07\x12\x10\n\x0cSHUFFLE_KIND\x10\x08*\xc3\x02\n\x08JobState\x12\x15\n\x11JOB_STATE_UNKNOWN\x10\x00\x12\x15\n\x11JOB_STATE_STOPPED\x10\x01\x12\x15\n\x11JOB_STATE_RUNNING\x10\x02\x12\x12\n\x0eJOB_STATE_DONE\x10\x03\x12\x14\n\x10JOB_STATE_FAILED\x10\x04\x12\x17\n\x13JOB_STATE_CANCELLED\x10\x05\x12\x15\n\x11JOB_STATE_UPDATED\x10\x06\x12\x16\n\x12JOB_STATE_DRAINING\x10\x07\x12\x15\n\x11JOB_STATE_DRAINED\x10\x08\x12\x15\n\x11JOB_STATE_PENDING\x10\t\x12\x18\n\x14JOB_STATE_CANCELLING\x10\n\x12\x14\n\x10JOB_STATE_QUEUED\x10\x0b\x12\"\n\x1eJOB_STATE_RESOURCE_CLEANING_UP\x10\x0c*a\n\x07JobView\x12\x14\n\x10JOB_VIEW_UNKNOWN\x10\x00\x12\x14\n\x10JOB_VIEW_SUMMARY\x10\x01\x12\x10\n\x0cJOB_VIEW_ALL\x10\x02\x12\x18\n\x14JOB_VIEW_DESCRIPTION\x10\x03\x32\x91\x0c\n\x0bJobsV1Beta3\x12\xc1\x01\n\tCreateJob\x12).google.dataflow.v1beta3.CreateJobRequest\x1a\x1c.google.dataflow.v1beta3.Job\"k\x82\xd3\xe4\x93\x02\x65\"5/v1b3/projects/{project_id}/locations/{location}/jobs:\x03jobZ\'\" /v1b3/projects/{project_id}/jobs:\x03job\x12\xc3\x01\n\x06GetJob\x12&.google.dataflow.v1beta3.GetJobRequest\x1a\x1c.google.dataflow.v1beta3.Job\"s\x82\xd3\xe4\x93\x02m\x12>/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}Z+\x12)/v1b3/projects/{project_id}/jobs/{job_id}\x12\xd3\x01\n\tUpdateJob\x12).google.dataflow.v1beta3.UpdateJobRequest\x1a\x1c.google.dataflow.v1beta3.Job\"}\x82\xd3\xe4\x93\x02w\x1a>/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}:\x03jobZ0\x1a)/v1b3/projects/{project_id}/jobs/{job_id}:\x03job\x12\xc2\x01\n\x08ListJobs\x12(.google.dataflow.v1beta3.ListJobsRequest\x1a).google.dataflow.v1beta3.ListJobsResponse\"a\x82\xd3\xe4\x93\x02[\x12\x35/v1b3/projects/{project_id}/locations/{location}/jobsZ\"\x12 /v1b3/projects/{project_id}/jobs\x12\x9e\x01\n\x12\x41ggregatedListJobs\x12(.google.dataflow.v1beta3.ListJobsRequest\x1a).google.dataflow.v1beta3.ListJobsResponse\"3\x82\xd3\xe4\x93\x02-\x12+/v1b3/projects/{project_id}/jobs:aggregated\x12v\n\x0f\x43heckActiveJobs\x12/.google.dataflow.v1beta3.CheckActiveJobsRequest\x1a\x30.google.dataflow.v1beta3.CheckActiveJobsResponse\"\x00\x12\xec\x01\n\x0bSnapshotJob\x12+.google.dataflow.v1beta3.SnapshotJobRequest\x1a!.google.dataflow.v1beta3.Snapshot\"\x8c\x01\x82\xd3\xe4\x93\x02\x85\x01\"G/v1b3/projects/{project_id}/locations/{location}/jobs/{job_id}:snapshot:\x01*Z7\"2/v1b3/projects/{project_id}/jobs/{job_id}:snapshot:\x01*\x1a\xd4\x01\xca\x41\x17\x64\x61taflow.googleapis.com\xd2\x41\xb6\x01https://www.googleapis.com/auth/cloud-platform,https://www.googleapis.com/auth/compute,https://www.googleapis.com/auth/compute.readonly,https://www.googleapis.com/auth/userinfo.emailB\xcc\x01\n\x1b\x63om.google.dataflow.v1beta3B\tJobsProtoP\x01Z=cloud.google.com/go/dataflow/apiv1beta3/dataflowpb;dataflowpb\xaa\x02\x1dGoogle.Cloud.Dataflow.V1Beta3\xca\x02\x1dGoogle\\Cloud\\Dataflow\\V1beta3\xea\x02 Google::Cloud::Dataflow::V1beta3b\x06proto3"
+
+pool = Google::Protobuf::DescriptorPool.generated_pool
+
+begin
+ pool.add_serialized_file(descriptor_data)
+rescue TypeError => e
+ # Compatibility code: will be removed in the next major version.
+ require 'google/protobuf/descriptor_pb'
+ parsed = Google::Protobuf::FileDescriptorProto.decode(descriptor_data)
+ parsed.clear_dependency
+ serialized = parsed.class.encode(parsed)
+ file = pool.add_serialized_file(serialized)
+ warn "Warning: Protobuf detected an import path issue while loading generated file #{__FILE__}"
+ imports = [
+ ["google.dataflow.v1beta3.Environment", "google/dataflow/v1beta3/environment.proto"],
+ ["google.protobuf.Timestamp", "google/protobuf/timestamp.proto"],
+ ["google.protobuf.Duration", "google/protobuf/duration.proto"],
+ ["google.protobuf.Struct", "google/protobuf/struct.proto"],
+ ]
+ imports.each do |type_name, expected_filename|
+ import_file = pool.lookup(type_name).file_descriptor
+ if import_file.name != expected_filename
+ warn "- #{file.name} imports #{expected_filename}, but that import was loaded as #{import_file.name}"
end
- add_message "google.dataflow.v1beta3.DatastoreIODetails" do
- optional :namespace, :string, 1
- optional :project_id, :string, 2
- end
- add_message "google.dataflow.v1beta3.PubSubIODetails" do
- optional :topic, :string, 1
- optional :subscription, :string, 2
- end
- add_message "google.dataflow.v1beta3.FileIODetails" do
- optional :file_pattern, :string, 1
- end
- add_message "google.dataflow.v1beta3.BigTableIODetails" do
- optional :project_id, :string, 1
- optional :instance_id, :string, 2
- optional :table_id, :string, 3
- end
- add_message "google.dataflow.v1beta3.BigQueryIODetails" do
- optional :table, :string, 1
- optional :dataset, :string, 2
- optional :project_id, :string, 3
- optional :query, :string, 4
- end
- add_message "google.dataflow.v1beta3.SpannerIODetails" do
- optional :project_id, :string, 1
- optional :instance_id, :string, 2
- optional :database_id, :string, 3
- end
- add_message "google.dataflow.v1beta3.SdkVersion" do
- optional :version, :string, 1
- optional :version_display_name, :string, 2
- optional :sdk_support_status, :enum, 3, "google.dataflow.v1beta3.SdkVersion.SdkSupportStatus"
- end
- add_enum "google.dataflow.v1beta3.SdkVersion.SdkSupportStatus" do
- value :UNKNOWN, 0
- value :SUPPORTED, 1
- value :STALE, 2
- value :DEPRECATED, 3
- value :UNSUPPORTED, 4
- end
- add_message "google.dataflow.v1beta3.JobMetadata" do
- optional :sdk_version, :message, 1, "google.dataflow.v1beta3.SdkVersion"
- repeated :spanner_details, :message, 2, "google.dataflow.v1beta3.SpannerIODetails"
- repeated :bigquery_details, :message, 3, "google.dataflow.v1beta3.BigQueryIODetails"
- repeated :big_table_details, :message, 4, "google.dataflow.v1beta3.BigTableIODetails"
- repeated :pubsub_details, :message, 5, "google.dataflow.v1beta3.PubSubIODetails"
- repeated :file_details, :message, 6, "google.dataflow.v1beta3.FileIODetails"
- repeated :datastore_details, :message, 7, "google.dataflow.v1beta3.DatastoreIODetails"
- end
- add_message "google.dataflow.v1beta3.ExecutionStageState" do
- optional :execution_stage_name, :string, 1
- optional :execution_stage_state, :enum, 2, "google.dataflow.v1beta3.JobState"
- optional :current_state_time, :message, 3, "google.protobuf.Timestamp"
- end
- add_message "google.dataflow.v1beta3.PipelineDescription" do
- repeated :original_pipeline_transform, :message, 1, "google.dataflow.v1beta3.TransformSummary"
- repeated :execution_pipeline_stage, :message, 2, "google.dataflow.v1beta3.ExecutionStageSummary"
- repeated :display_data, :message, 3, "google.dataflow.v1beta3.DisplayData"
- end
- add_message "google.dataflow.v1beta3.TransformSummary" do
- optional :kind, :enum, 1, "google.dataflow.v1beta3.KindType"
- optional :id, :string, 2
- optional :name, :string, 3
- repeated :display_data, :message, 4, "google.dataflow.v1beta3.DisplayData"
- repeated :output_collection_name, :string, 5
- repeated :input_collection_name, :string, 6
- end
- add_message "google.dataflow.v1beta3.ExecutionStageSummary" do
- optional :name, :string, 1
- optional :id, :string, 2
- optional :kind, :enum, 3, "google.dataflow.v1beta3.KindType"
- repeated :input_source, :message, 4, "google.dataflow.v1beta3.ExecutionStageSummary.StageSource"
- repeated :output_source, :message, 5, "google.dataflow.v1beta3.ExecutionStageSummary.StageSource"
- repeated :prerequisite_stage, :string, 8
- repeated :component_transform, :message, 6, "google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform"
- repeated :component_source, :message, 7, "google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource"
- end
- add_message "google.dataflow.v1beta3.ExecutionStageSummary.StageSource" do
- optional :user_name, :string, 1
- optional :name, :string, 2
- optional :original_transform_or_collection, :string, 3
- optional :size_bytes, :int64, 4
- end
- add_message "google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform" do
- optional :user_name, :string, 1
- optional :name, :string, 2
- optional :original_transform, :string, 3
- end
- add_message "google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource" do
- optional :user_name, :string, 1
- optional :name, :string, 2
- optional :original_transform_or_collection, :string, 3
- end
- add_message "google.dataflow.v1beta3.DisplayData" do
- optional :key, :string, 1
- optional :namespace, :string, 2
- optional :short_str_value, :string, 11
- optional :url, :string, 12
- optional :label, :string, 13
- oneof :Value do
- optional :str_value, :string, 4
- optional :int64_value, :int64, 5
- optional :float_value, :float, 6
- optional :java_class_value, :string, 7
- optional :timestamp_value, :message, 8, "google.protobuf.Timestamp"
- optional :duration_value, :message, 9, "google.protobuf.Duration"
- optional :bool_value, :bool, 10
- end
- end
- add_message "google.dataflow.v1beta3.Step" do
- optional :kind, :string, 1
- optional :name, :string, 2
- optional :properties, :message, 3, "google.protobuf.Struct"
- end
- add_message "google.dataflow.v1beta3.JobExecutionInfo" do
- map :stages, :string, :message, 1, "google.dataflow.v1beta3.JobExecutionStageInfo"
- end
- add_message "google.dataflow.v1beta3.JobExecutionStageInfo" do
- repeated :step_name, :string, 1
- end
- add_message "google.dataflow.v1beta3.CreateJobRequest" do
- optional :project_id, :string, 1
- optional :job, :message, 2, "google.dataflow.v1beta3.Job"
- optional :view, :enum, 3, "google.dataflow.v1beta3.JobView"
- optional :replace_job_id, :string, 4
- optional :location, :string, 5
- end
- add_message "google.dataflow.v1beta3.GetJobRequest" do
- optional :project_id, :string, 1
- optional :job_id, :string, 2
- optional :view, :enum, 3, "google.dataflow.v1beta3.JobView"
- optional :location, :string, 4
- end
- add_message "google.dataflow.v1beta3.UpdateJobRequest" do
- optional :project_id, :string, 1
- optional :job_id, :string, 2
- optional :job, :message, 3, "google.dataflow.v1beta3.Job"
- optional :location, :string, 4
- end
- add_message "google.dataflow.v1beta3.ListJobsRequest" do
- optional :filter, :enum, 5, "google.dataflow.v1beta3.ListJobsRequest.Filter"
- optional :project_id, :string, 1
- optional :view, :enum, 2, "google.dataflow.v1beta3.JobView"
- optional :page_size, :int32, 3
- optional :page_token, :string, 4
- optional :location, :string, 17
- end
- add_enum "google.dataflow.v1beta3.ListJobsRequest.Filter" do
- value :UNKNOWN, 0
- value :ALL, 1
- value :TERMINATED, 2
- value :ACTIVE, 3
- end
- add_message "google.dataflow.v1beta3.FailedLocation" do
- optional :name, :string, 1
- end
- add_message "google.dataflow.v1beta3.ListJobsResponse" do
- repeated :jobs, :message, 1, "google.dataflow.v1beta3.Job"
- optional :next_page_token, :string, 2
- repeated :failed_location, :message, 3, "google.dataflow.v1beta3.FailedLocation"
- end
- add_message "google.dataflow.v1beta3.SnapshotJobRequest" do
- optional :project_id, :string, 1
- optional :job_id, :string, 2
- optional :ttl, :message, 3, "google.protobuf.Duration"
- optional :location, :string, 4
- optional :snapshot_sources, :bool, 5
- optional :description, :string, 6
- end
- add_message "google.dataflow.v1beta3.CheckActiveJobsRequest" do
- optional :project_id, :string, 1
- end
- add_message "google.dataflow.v1beta3.CheckActiveJobsResponse" do
- optional :active_jobs_exist, :bool, 1
- end
- add_enum "google.dataflow.v1beta3.KindType" do
- value :UNKNOWN_KIND, 0
- value :PAR_DO_KIND, 1
- value :GROUP_BY_KEY_KIND, 2
- value :FLATTEN_KIND, 3
- value :READ_KIND, 4
- value :WRITE_KIND, 5
- value :CONSTANT_KIND, 6
- value :SINGLETON_KIND, 7
- value :SHUFFLE_KIND, 8
- end
- add_enum "google.dataflow.v1beta3.JobState" do
- value :JOB_STATE_UNKNOWN, 0
- value :JOB_STATE_STOPPED, 1
- value :JOB_STATE_RUNNING, 2
- value :JOB_STATE_DONE, 3
- value :JOB_STATE_FAILED, 4
- value :JOB_STATE_CANCELLED, 5
- value :JOB_STATE_UPDATED, 6
- value :JOB_STATE_DRAINING, 7
- value :JOB_STATE_DRAINED, 8
- value :JOB_STATE_PENDING, 9
- value :JOB_STATE_CANCELLING, 10
- value :JOB_STATE_QUEUED, 11
- value :JOB_STATE_RESOURCE_CLEANING_UP, 12
- end
- add_enum "google.dataflow.v1beta3.JobView" do
- value :JOB_VIEW_UNKNOWN, 0
- value :JOB_VIEW_SUMMARY, 1
- value :JOB_VIEW_ALL, 2
- value :JOB_VIEW_DESCRIPTION, 3
- end
end
+ warn "Each proto file must use a consistent fully-qualified name."
+ warn "This will become an error in the next major version."
end
module Google
module Cloud
module Dataflow