Autogenerated update (2017-08-29)

Update:
- adexchangebuyer2_v2beta1
- dataflow_v1b3
- slides_v1
- storagetransfer_v1

generated/google/apis/dataflow_v1b3/classes.rb

@@ -442,6 +442,11 @@ module Google
         # @return [String]
         attr_accessor :origin_namespace
       
+        # The GroupByKey step name from the original graph.
+        # Corresponds to the JSON property `originalShuffleStepName`
+        # @return [String]
+        attr_accessor :original_shuffle_step_name
+      
         # System generated name of the original step in the user's graph, before
         # optimization.
         # Corresponds to the JSON property `originalStepName`
@@ -453,6 +458,11 @@ module Google
         # @return [String]
         attr_accessor :portion
       
+        # Uniquely identifies a side input.
+        # Corresponds to the JSON property `sideInput`
+        # @return [Google::Apis::DataflowV1b3::SideInputId]
+        attr_accessor :side_input
+      
         # ID of a particular worker.
         # Corresponds to the JSON property `workerId`
         # @return [String]
@@ -469,8 +479,10 @@ module Google
           @name = args[:name] if args.key?(:name)
           @origin = args[:origin] if args.key?(:origin)
           @origin_namespace = args[:origin_namespace] if args.key?(:origin_namespace)
+          @original_shuffle_step_name = args[:original_shuffle_step_name] if args.key?(:original_shuffle_step_name)
           @original_step_name = args[:original_step_name] if args.key?(:original_step_name)
           @portion = args[:portion] if args.key?(:portion)
+          @side_input = args[:side_input] if args.key?(:side_input)
           @worker_id = args[:worker_id] if args.key?(:worker_id)
         end
       end
@@ -3159,6 +3171,31 @@ module Google
         end
       end
       
+      # Uniquely identifies a side input.
+      class SideInputId
+        include Google::Apis::Core::Hashable
+      
+        # The step that receives and usually consumes this side input.
+        # Corresponds to the JSON property `declaringStepName`
+        # @return [String]
+        attr_accessor :declaring_step_name
+      
+        # The index of the side input, from the list of non_parallel_inputs.
+        # Corresponds to the JSON property `inputIndex`
+        # @return [Fixnum]
+        attr_accessor :input_index
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
+          @declaring_step_name = args[:declaring_step_name] if args.key?(:declaring_step_name)
+          @input_index = args[:input_index] if args.key?(:input_index)
+        end
+      end
+      
       # Information about a side input of a DoFn or an input of a SeqDoFn.
       class SideInputInfo
         include Google::Apis::Core::Hashable
@@ -4805,6 +4842,13 @@ module Google
         # @return [Google::Apis::DataflowV1b3::ResourceUtilizationReport]
         attr_accessor :worker_metrics
       
+        # Shutdown notification from workers. This is to be sent by the shutdown
+        # script of the worker VM so that the backend knows that the VM is being
+        # shut down.
+        # Corresponds to the JSON property `workerShutdownNotice`
+        # @return [Google::Apis::DataflowV1b3::WorkerShutdownNotice]
+        attr_accessor :worker_shutdown_notice
+      
         def initialize(**args)
            update!(**args)
         end
@@ -4816,6 +4860,7 @@ module Google
           @worker_health_report = args[:worker_health_report] if args.key?(:worker_health_report)
           @worker_message_code = args[:worker_message_code] if args.key?(:worker_message_code)
           @worker_metrics = args[:worker_metrics] if args.key?(:worker_metrics)
+          @worker_shutdown_notice = args[:worker_shutdown_notice] if args.key?(:worker_shutdown_notice)
         end
       end
       
@@ -4890,6 +4935,11 @@ module Google
         # @return [Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse]
         attr_accessor :worker_metrics_response
       
+        # Service-side response to WorkerMessage issuing shutdown notice.
+        # Corresponds to the JSON property `workerShutdownNoticeResponse`
+        # @return [Google::Apis::DataflowV1b3::WorkerShutdownNoticeResponse]
+        attr_accessor :worker_shutdown_notice_response
+      
         def initialize(**args)
            update!(**args)
         end
@@ -4898,6 +4948,7 @@ module Google
         def update!(**args)
           @worker_health_report_response = args[:worker_health_report_response] if args.key?(:worker_health_report_response)
           @worker_metrics_response = args[:worker_metrics_response] if args.key?(:worker_metrics_response)
+          @worker_shutdown_notice_response = args[:worker_shutdown_notice_response] if args.key?(:worker_shutdown_notice_response)
         end
       end
       
@@ -5135,6 +5186,42 @@ module Google
         end
       end
       
+      # Shutdown notification from workers. This is to be sent by the shutdown
+      # script of the worker VM so that the backend knows that the VM is being
+      # shut down.
+      class WorkerShutdownNotice
+        include Google::Apis::Core::Hashable
+      
+        # Optional reason to be attached for the shutdown notice.
+        # For example: "PREEMPTION" would indicate the VM is being shut down because
+        # of preemption. Other possible reasons may be added in the future.
+        # Corresponds to the JSON property `reason`
+        # @return [String]
+        attr_accessor :reason
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
+          @reason = args[:reason] if args.key?(:reason)
+        end
+      end
+      
+      # Service-side response to WorkerMessage issuing shutdown notice.
+      class WorkerShutdownNoticeResponse
+        include Google::Apis::Core::Hashable
+      
+        def initialize(**args)
+           update!(**args)
+        end
+      
+        # Update properties of this object
+        def update!(**args)
+        end
+      end
+      
       # An instruction that writes records.
       # Takes one input, produces no outputs.
       class WriteInstruction

generated/google/apis/dataflow_v1b3/representations.rb

@@ -502,6 +502,12 @@ module Google
         include Google::Apis::Core::JsonObjectSupport
       end
       
+      class SideInputId
+        class Representation < Google::Apis::Core::JsonRepresentation; end
+      
+        include Google::Apis::Core::JsonObjectSupport
+      end
+      
       class SideInputInfo
         class Representation < Google::Apis::Core::JsonRepresentation; end
       
@@ -754,6 +760,18 @@ module Google
         include Google::Apis::Core::JsonObjectSupport
       end
       
+      class WorkerShutdownNotice
+        class Representation < Google::Apis::Core::JsonRepresentation; end
+      
+        include Google::Apis::Core::JsonObjectSupport
+      end
+      
+      class WorkerShutdownNoticeResponse
+        class Representation < Google::Apis::Core::JsonRepresentation; end
+      
+        include Google::Apis::Core::JsonObjectSupport
+      end
+      
       class WriteInstruction
         class Representation < Google::Apis::Core::JsonRepresentation; end
       
@@ -882,8 +900,11 @@ module Google
           property :name, as: 'name'
           property :origin, as: 'origin'
           property :origin_namespace, as: 'originNamespace'
+          property :original_shuffle_step_name, as: 'originalShuffleStepName'
           property :original_step_name, as: 'originalStepName'
           property :portion, as: 'portion'
+          property :side_input, as: 'sideInput', class: Google::Apis::DataflowV1b3::SideInputId, decorator: Google::Apis::DataflowV1b3::SideInputId::Representation
+      
           property :worker_id, as: 'workerId'
         end
       end
@@ -1613,6 +1634,14 @@ module Google
         end
       end
       
+      class SideInputId
+        # @private
+        class Representation < Google::Apis::Core::JsonRepresentation
+          property :declaring_step_name, as: 'declaringStepName'
+          property :input_index, as: 'inputIndex'
+        end
+      end
+      
       class SideInputInfo
         # @private
         class Representation < Google::Apis::Core::JsonRepresentation
@@ -2048,6 +2077,8 @@ module Google
       
           property :worker_metrics, as: 'workerMetrics', class: Google::Apis::DataflowV1b3::ResourceUtilizationReport, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReport::Representation
       
+          property :worker_shutdown_notice, as: 'workerShutdownNotice', class: Google::Apis::DataflowV1b3::WorkerShutdownNotice, decorator: Google::Apis::DataflowV1b3::WorkerShutdownNotice::Representation
+      
         end
       end
       
@@ -2066,6 +2097,8 @@ module Google
       
           property :worker_metrics_response, as: 'workerMetricsResponse', class: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse::Representation
       
+          property :worker_shutdown_notice_response, as: 'workerShutdownNoticeResponse', class: Google::Apis::DataflowV1b3::WorkerShutdownNoticeResponse, decorator: Google::Apis::DataflowV1b3::WorkerShutdownNoticeResponse::Representation
+      
         end
       end
       
@@ -2112,6 +2145,19 @@ module Google
         end
       end
       
+      class WorkerShutdownNotice
+        # @private
+        class Representation < Google::Apis::Core::JsonRepresentation
+          property :reason, as: 'reason'
+        end
+      end
+      
+      class WorkerShutdownNoticeResponse
+        # @private
+        class Representation < Google::Apis::Core::JsonRepresentation
+        end
+      end
+      
       class WriteInstruction
         # @private
         class Representation < Google::Apis::Core::JsonRepresentation