generated/google/apis/dataflow_v1b3/representations.rb in google-api-client-0.10.0 vs generated/google/apis/dataflow_v1b3/representations.rb in google-api-client-0.10.1

- old
+ new

@@ -20,10 +20,202 @@ module Google module Apis module DataflowV1b3 + class ParDoInstruction + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class MetricUpdate + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class CounterStructuredName + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class ApproximateProgress + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkerMessageResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class TemplateMetadata + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkerMessage + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class JobMetrics + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class FloatingPointList + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class CounterUpdate + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class SourceMetadata + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class DistributionUpdate + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class SourceFork + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkerHealthReportResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkItemStatus + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class ComponentSource + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkItemServiceState + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class MetricStructuredName + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class SeqMapTaskOutputInfo + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class JobExecutionStageInfo + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class KeyRangeLocation + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class SourceGetMetadataRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class SeqMapTask + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class NameAndKind + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class WorkerMessageCode + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class CustomSourceLocation + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class MapTask + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class FloatingPointMean + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class ReportWorkItemStatusResponse + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class InstructionOutput + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class CreateJobFromTemplateRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + + class IntegerMean + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class ListJobsResponse class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -38,35 +230,41 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class MountedDataDisk + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class StreamingSideInputLocation class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class MountedDataDisk + class LaunchTemplateResponse class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class DynamicSourceSplit + class DerivedSource class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class Job + class DynamicSourceSplit class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class DerivedSource + class Job class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -86,35 +284,35 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class WriteInstruction + class CounterStructuredNameAndMetadata class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class CounterStructuredNameAndMetadata + class ConcatPosition class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class ConcatPosition + class WriteInstruction class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class AutoscalingSettings + class StreamingComputationRanges class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class StreamingComputationRanges + class AutoscalingSettings class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -194,10 +392,16 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class ParameterMetadata + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class MultiOutputInfo class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -302,17 +506,17 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class DataDiskAssignment + class StreamingStageLocation class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class StreamingStageLocation + class DataDiskAssignment class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -338,17 +542,17 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class TransformSummary + class StreamingComputationConfig class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class StreamingComputationConfig + class TransformSummary class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -356,10 +560,16 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class LaunchTemplateParameters + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class Sink class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -374,17 +584,17 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class StageSource + class InstructionInput class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class InstructionInput + class StageSource class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -398,17 +608,23 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end + class GetDebugConfigRequest + class Representation < Google::Apis::Core::JsonRepresentation; end + + include Google::Apis::Core::JsonObjectSupport + end + class LeaseWorkItemRequest class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class GetDebugConfigRequest + class GetTemplateResponse class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -416,17 +632,17 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class PipelineDescription + class StreamingConfigTask class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class StreamingConfigTask + class PipelineDescription class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -452,17 +668,17 @@ class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class ListJobMessagesResponse + class CounterMetadata class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end - class CounterMetadata + class ListJobMessagesResponse class Representation < Google::Apis::Core::JsonRepresentation; end include Google::Apis::Core::JsonObjectSupport end @@ -513,220 +729,409 @@ include Google::Apis::Core::JsonObjectSupport end class ParDoInstruction - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :multi_output_infos, as: 'multiOutputInfos', class: Google::Apis::DataflowV1b3::MultiOutputInfo, decorator: Google::Apis::DataflowV1b3::MultiOutputInfo::Representation - include Google::Apis::Core::JsonObjectSupport + hash :user_fn, as: 'userFn' + property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation + + property :num_outputs, as: 'numOutputs' + collection :side_inputs, as: 'sideInputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation + + end end class MetricUpdate - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :set, as: 'set' + property :cumulative, as: 'cumulative' + property :internal, as: 'internal' + property :kind, as: 'kind' + property :scalar, as: 'scalar' + property :mean_count, as: 'meanCount' + property :mean_sum, as: 'meanSum' + property :update_time, as: 'updateTime' + property :name, as: 'name', class: Google::Apis::DataflowV1b3::MetricStructuredName, decorator: Google::Apis::DataflowV1b3::MetricStructuredName::Representation - include Google::Apis::Core::JsonObjectSupport + end end class CounterStructuredName - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :component_step_name, as: 'componentStepName' + property :portion, as: 'portion' + property :original_step_name, as: 'originalStepName' + property :worker_id, as: 'workerId' + property :origin_namespace, as: 'originNamespace' + property :origin, as: 'origin' + property :name, as: 'name' + property :execution_step_name, as: 'executionStepName' + end end class ApproximateProgress - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :percent_complete, as: 'percentComplete' + property :remaining_time, as: 'remainingTime' + property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation - include Google::Apis::Core::JsonObjectSupport + end end class WorkerMessageResponse - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :worker_metrics_response, as: 'workerMetricsResponse', class: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse::Representation - include Google::Apis::Core::JsonObjectSupport + property :worker_health_report_response, as: 'workerHealthReportResponse', class: Google::Apis::DataflowV1b3::WorkerHealthReportResponse, decorator: Google::Apis::DataflowV1b3::WorkerHealthReportResponse::Representation + + end end + class TemplateMetadata + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :bypass_temp_dir_validation, as: 'bypassTempDirValidation' + property :name, as: 'name' + collection :parameters, as: 'parameters', class: Google::Apis::DataflowV1b3::ParameterMetadata, decorator: Google::Apis::DataflowV1b3::ParameterMetadata::Representation + + property :description, as: 'description' + end + end + class WorkerMessage - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :time, as: 'time' + property :worker_health_report, as: 'workerHealthReport', class: Google::Apis::DataflowV1b3::WorkerHealthReport, decorator: Google::Apis::DataflowV1b3::WorkerHealthReport::Representation - include Google::Apis::Core::JsonObjectSupport + property :worker_message_code, as: 'workerMessageCode', class: Google::Apis::DataflowV1b3::WorkerMessageCode, decorator: Google::Apis::DataflowV1b3::WorkerMessageCode::Representation + + property :worker_metrics, as: 'workerMetrics', class: Google::Apis::DataflowV1b3::ResourceUtilizationReport, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReport::Representation + + hash :labels, as: 'labels' + end end class JobMetrics - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :metric_time, as: 'metricTime' + collection :metrics, as: 'metrics', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation - include Google::Apis::Core::JsonObjectSupport + end end class FloatingPointList - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :elements, as: 'elements' + end end class CounterUpdate - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :floating_point_list, as: 'floatingPointList', class: Google::Apis::DataflowV1b3::FloatingPointList, decorator: Google::Apis::DataflowV1b3::FloatingPointList::Representation - include Google::Apis::Core::JsonObjectSupport + property :integer, as: 'integer', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation + + property :integer_list, as: 'integerList', class: Google::Apis::DataflowV1b3::IntegerList, decorator: Google::Apis::DataflowV1b3::IntegerList::Representation + + property :structured_name_and_metadata, as: 'structuredNameAndMetadata', class: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata, decorator: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata::Representation + + property :floating_point, as: 'floatingPoint' + property :integer_mean, as: 'integerMean', class: Google::Apis::DataflowV1b3::IntegerMean, decorator: Google::Apis::DataflowV1b3::IntegerMean::Representation + + property :cumulative, as: 'cumulative' + property :internal, as: 'internal' + property :floating_point_mean, as: 'floatingPointMean', class: Google::Apis::DataflowV1b3::FloatingPointMean, decorator: Google::Apis::DataflowV1b3::FloatingPointMean::Representation + + property :boolean, as: 'boolean' + property :name_and_kind, as: 'nameAndKind', class: Google::Apis::DataflowV1b3::NameAndKind, decorator: Google::Apis::DataflowV1b3::NameAndKind::Representation + + property :distribution, as: 'distribution', class: Google::Apis::DataflowV1b3::DistributionUpdate, decorator: Google::Apis::DataflowV1b3::DistributionUpdate::Representation + + property :string_list, as: 'stringList', class: Google::Apis::DataflowV1b3::StringList, decorator: Google::Apis::DataflowV1b3::StringList::Representation + + property :short_id, as: 'shortId' + end end class SourceMetadata - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :produces_sorted_keys, as: 'producesSortedKeys' + property :infinite, as: 'infinite' + property :estimated_size_bytes, as: 'estimatedSizeBytes' + end end class DistributionUpdate - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :min, as: 'min', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - include Google::Apis::Core::JsonObjectSupport + property :sum_of_squares, as: 'sumOfSquares' + property :max, as: 'max', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation + + property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation + + property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation + + end end class SourceFork - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :primary_source, as: 'primarySource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation - include Google::Apis::Core::JsonObjectSupport + property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation + + property :residual_source, as: 'residualSource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation + + property :primary, as: 'primary', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation + + end end class WorkerHealthReportResponse - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :report_interval, as: 'reportInterval' + end end class WorkItemStatus - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :counter_updates, as: 'counterUpdates', class: Google::Apis::DataflowV1b3::CounterUpdate, decorator: Google::Apis::DataflowV1b3::CounterUpdate::Representation - include Google::Apis::Core::JsonObjectSupport + property :work_item_id, as: 'workItemId' + collection :metric_updates, as: 'metricUpdates', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation + + collection :errors, as: 'errors', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation + + property :dynamic_source_split, as: 'dynamicSourceSplit', class: Google::Apis::DataflowV1b3::DynamicSourceSplit, decorator: Google::Apis::DataflowV1b3::DynamicSourceSplit::Representation + + property :source_operation_response, as: 'sourceOperationResponse', class: Google::Apis::DataflowV1b3::SourceOperationResponse, decorator: Google::Apis::DataflowV1b3::SourceOperationResponse::Representation + + property :progress, as: 'progress', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation + + property :requested_lease_duration, as: 'requestedLeaseDuration' + property :report_index, as: 'reportIndex' + property :stop_position, as: 'stopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation + + property :completed, as: 'completed' + property :reported_progress, as: 'reportedProgress', class: Google::Apis::DataflowV1b3::ApproximateReportedProgress, decorator: Google::Apis::DataflowV1b3::ApproximateReportedProgress::Representation + + property :source_fork, as: 'sourceFork', class: Google::Apis::DataflowV1b3::SourceFork, decorator: Google::Apis::DataflowV1b3::SourceFork::Representation + + end end class ComponentSource - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :original_transform_or_collection, as: 'originalTransformOrCollection' + property :name, as: 'name' + property :user_name, as: 'userName' + end end class WorkItemServiceState - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :report_status_interval, as: 'reportStatusInterval' + property :suggested_stop_position, as: 'suggestedStopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation - include Google::Apis::Core::JsonObjectSupport + hash :harness_data, as: 'harnessData' + property :lease_expire_time, as: 'leaseExpireTime' + collection :metric_short_id, as: 'metricShortId', class: Google::Apis::DataflowV1b3::MetricShortId, decorator: Google::Apis::DataflowV1b3::MetricShortId::Representation + + property :next_report_index, as: 'nextReportIndex' + property :suggested_stop_point, as: 'suggestedStopPoint', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation + + property :split_request, as: 'splitRequest', class: Google::Apis::DataflowV1b3::ApproximateSplitRequest, decorator: Google::Apis::DataflowV1b3::ApproximateSplitRequest::Representation + + end end class MetricStructuredName - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :origin, as: 'origin' + property :name, as: 'name' + hash :context, as: 'context' + end end class SeqMapTaskOutputInfo - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation - include Google::Apis::Core::JsonObjectSupport + property :tag, as: 'tag' + end end class JobExecutionStageInfo - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :step_name, as: 'stepName' + end end class KeyRangeLocation - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :delivery_endpoint, as: 'deliveryEndpoint' + property :start, as: 'start' + property :data_disk, as: 'dataDisk' + property :persistent_directory, as: 'persistentDirectory' + property :end, as: 'end' + end end class SourceGetMetadataRequest - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation - include Google::Apis::Core::JsonObjectSupport + end end class SeqMapTask - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :name, as: 'name' + collection :output_infos, as: 'outputInfos', class: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo, decorator: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo::Representation - include Google::Apis::Core::JsonObjectSupport + collection :inputs, as: 'inputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation + + property :stage_name, as: 'stageName' + property :system_name, as: 'systemName' + hash :user_fn, as: 'userFn' + end end class NameAndKind - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :name, as: 'name' + property :kind, as: 'kind' + end end class WorkerMessageCode - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + hash :parameters, as: 'parameters' + property :code, as: 'code' + end end class CustomSourceLocation - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :stateful, as: 'stateful' + end end class MapTask - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation - include Google::Apis::Core::JsonObjectSupport + property :system_name, as: 'systemName' + property :stage_name, as: 'stageName' + end end class FloatingPointMean - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :sum, as: 'sum' + property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - include Google::Apis::Core::JsonObjectSupport + end end class ReportWorkItemStatusResponse - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :work_item_service_states, as: 'workItemServiceStates', class: Google::Apis::DataflowV1b3::WorkItemServiceState, decorator: Google::Apis::DataflowV1b3::WorkItemServiceState::Representation - include Google::Apis::Core::JsonObjectSupport + end end class InstructionOutput - class Representation < Google::Apis::Core::JsonRepresentation; end - - include Google::Apis::Core::JsonObjectSupport + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :system_name, as: 'systemName' + property :only_count_key_bytes, as: 'onlyCountKeyBytes' + property :only_count_value_bytes, as: 'onlyCountValueBytes' + hash :codec, as: 'codec' + property :name, as: 'name' + property :original_name, as: 'originalName' + end end class CreateJobFromTemplateRequest - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :gcs_path, as: 'gcsPath' + property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::RuntimeEnvironment, decorator: Google::Apis::DataflowV1b3::RuntimeEnvironment::Representation - include Google::Apis::Core::JsonObjectSupport + hash :parameters, as: 'parameters' + property :job_name, as: 'jobName' + end end class IntegerMean - class Representation < Google::Apis::Core::JsonRepresentation; end + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - include Google::Apis::Core::JsonObjectSupport + property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation + + end end class ListJobsResponse # @private class Representation < Google::Apis::Core::JsonRepresentation - collection :jobs, as: 'jobs', class: Google::Apis::DataflowV1b3::Job, decorator: Google::Apis::DataflowV1b3::Job::Representation - property :next_page_token, as: 'nextPageToken' collection :failed_location, as: 'failedLocation', class: Google::Apis::DataflowV1b3::FailedLocation, decorator: Google::Apis::DataflowV1b3::FailedLocation::Representation + collection :jobs, as: 'jobs', class: Google::Apis::DataflowV1b3::Job, decorator: Google::Apis::DataflowV1b3::Job::Representation + end end class ComputationTopology # @private class Representation < Google::Apis::Core::JsonRepresentation - collection :key_ranges, as: 'keyRanges', class: Google::Apis::DataflowV1b3::KeyRangeLocation, decorator: Google::Apis::DataflowV1b3::KeyRangeLocation::Representation - property :user_stage_name, as: 'userStageName' - collection :outputs, as: 'outputs', class: Google::Apis::DataflowV1b3::StreamLocation, decorator: Google::Apis::DataflowV1b3::StreamLocation::Representation - collection :state_families, as: 'stateFamilies', class: Google::Apis::DataflowV1b3::StateFamilyConfig, decorator: Google::Apis::DataflowV1b3::StateFamilyConfig::Representation + collection :outputs, as: 'outputs', class: Google::Apis::DataflowV1b3::StreamLocation, decorator: Google::Apis::DataflowV1b3::StreamLocation::Representation + property :system_stage_name, as: 'systemStageName' - property :computation_id, as: 'computationId' collection :inputs, as: 'inputs', class: Google::Apis::DataflowV1b3::StreamLocation, decorator: Google::Apis::DataflowV1b3::StreamLocation::Representation + property :computation_id, as: 'computationId' + collection :key_ranges, as: 'keyRanges', class: Google::Apis::DataflowV1b3::KeyRangeLocation, decorator: Google::Apis::DataflowV1b3::KeyRangeLocation::Representation + end end class RuntimeEnvironment # @private @@ -737,70 +1142,80 @@ property :temp_location, as: 'tempLocation' property :bypass_temp_dir_validation, as: 'bypassTempDirValidation' end end + class MountedDataDisk + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :data_disk, as: 'dataDisk' + end + end + class StreamingSideInputLocation # @private class Representation < Google::Apis::Core::JsonRepresentation - property :tag, as: 'tag' property :state_family, as: 'stateFamily' + property :tag, as: 'tag' end end - class MountedDataDisk + class LaunchTemplateResponse # @private class Representation < Google::Apis::Core::JsonRepresentation - property :data_disk, as: 'dataDisk' + property :job, as: 'job', class: Google::Apis::DataflowV1b3::Job, decorator: Google::Apis::DataflowV1b3::Job::Representation + + property :status, as: 'status', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation + end end - class DynamicSourceSplit + class DerivedSource # @private class Representation < Google::Apis::Core::JsonRepresentation - property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation + property :derivation_mode, as: 'derivationMode' + property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation + end + end + + class DynamicSourceSplit + # @private + class Representation < Google::Apis::Core::JsonRepresentation property :primary, as: 'primary', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation + property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation + end end class Job # @private class Representation < Google::Apis::Core::JsonRepresentation - property :current_state, as: 'currentState' - property :location, as: 'location' - property :current_state_time, as: 'currentStateTime' - hash :transform_name_mapping, as: 'transformNameMapping' - property :create_time, as: 'createTime' - property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::Environment, decorator: Google::Apis::DataflowV1b3::Environment::Representation - - hash :labels, as: 'labels' - property :type, as: 'type' - property :project_id, as: 'projectId' property :pipeline_description, as: 'pipelineDescription', class: Google::Apis::DataflowV1b3::PipelineDescription, decorator: Google::Apis::DataflowV1b3::PipelineDescription::Representation property :replace_job_id, as: 'replaceJobId' property :requested_state, as: 'requestedState' collection :temp_files, as: 'tempFiles' property :client_request_id, as: 'clientRequestId' property :name, as: 'name' property :replaced_by_job_id, as: 'replacedByJobId' collection :steps, as: 'steps', class: Google::Apis::DataflowV1b3::Step, decorator: Google::Apis::DataflowV1b3::Step::Representation - property :id, as: 'id' property :execution_info, as: 'executionInfo', class: Google::Apis::DataflowV1b3::JobExecutionInfo, decorator: Google::Apis::DataflowV1b3::JobExecutionInfo::Representation - end - end + property :id, as: 'id' + property :current_state, as: 'currentState' + property :location, as: 'location' + property :current_state_time, as: 'currentStateTime' + hash :transform_name_mapping, as: 'transformNameMapping' + hash :labels, as: 'labels' + property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::Environment, decorator: Google::Apis::DataflowV1b3::Environment::Representation - class DerivedSource - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :derivation_mode, as: 'derivationMode' - property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation - + property :create_time, as: 'createTime' + property :type, as: 'type' + property :project_id, as: 'projectId' end end class SourceOperationResponse # @private @@ -826,20 +1241,10 @@ hash :kind, as: 'kind' property :tag, as: 'tag' end end - class WriteInstruction - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation - - property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation - - end - end - class CounterStructuredNameAndMetadata # @private class Representation < Google::Apis::Core::JsonRepresentation property :name, as: 'name', class: Google::Apis::DataflowV1b3::CounterStructuredName, decorator: Google::Apis::DataflowV1b3::CounterStructuredName::Representation @@ -849,47 +1254,57 @@ end class ConcatPosition # @private class Representation < Google::Apis::Core::JsonRepresentation - property :index, as: 'index' property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation + property :index, as: 'index' end end - class AutoscalingSettings + class WriteInstruction # @private class Representation < Google::Apis::Core::JsonRepresentation - property :max_num_workers, as: 'maxNumWorkers' - property :algorithm, as: 'algorithm' + property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation + + property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation + end end class StreamingComputationRanges # @private class Representation < Google::Apis::Core::JsonRepresentation - property :computation_id, as: 'computationId' collection :range_assignments, as: 'rangeAssignments', class: Google::Apis::DataflowV1b3::KeyRangeDataDiskAssignment, decorator: Google::Apis::DataflowV1b3::KeyRangeDataDiskAssignment::Representation + property :computation_id, as: 'computationId' end end - class ExecutionStageSummary + class AutoscalingSettings # @private class Representation < Google::Apis::Core::JsonRepresentation - collection :output_source, as: 'outputSource', class: Google::Apis::DataflowV1b3::StageSource, decorator: Google::Apis::DataflowV1b3::StageSource::Representation + property :max_num_workers, as: 'maxNumWorkers' + property :algorithm, as: 'algorithm' + end + end - property :name, as: 'name' + class ExecutionStageSummary + # @private + class Representation < Google::Apis::Core::JsonRepresentation collection :input_source, as: 'inputSource', class: Google::Apis::DataflowV1b3::StageSource, decorator: Google::Apis::DataflowV1b3::StageSource::Representation property :id, as: 'id' collection :component_transform, as: 'componentTransform', class: Google::Apis::DataflowV1b3::ComponentTransform, decorator: Google::Apis::DataflowV1b3::ComponentTransform::Representation collection :component_source, as: 'componentSource', class: Google::Apis::DataflowV1b3::ComponentSource, decorator: Google::Apis::DataflowV1b3::ComponentSource::Representation property :kind, as: 'kind' + collection :output_source, as: 'outputSource', class: Google::Apis::DataflowV1b3::StageSource, decorator: Google::Apis::DataflowV1b3::StageSource::Representation + + property :name, as: 'name' end end class SendWorkerMessagesRequest # @private @@ -918,21 +1333,21 @@ end class Environment # @private class Representation < Google::Apis::Core::JsonRepresentation + property :service_account_email, as: 'serviceAccountEmail' + hash :user_agent, as: 'userAgent' + hash :sdk_pipeline_options, as: 'sdkPipelineOptions' property :cluster_manager_api_service, as: 'clusterManagerApiService' property :temp_storage_prefix, as: 'tempStoragePrefix' collection :worker_pools, as: 'workerPools', class: Google::Apis::DataflowV1b3::WorkerPool, decorator: Google::Apis::DataflowV1b3::WorkerPool::Representation property :dataset, as: 'dataset' collection :experiments, as: 'experiments' - hash :internal_experiments, as: 'internalExperiments' hash :version, as: 'version' - property :service_account_email, as: 'serviceAccountEmail' - hash :user_agent, as: 'userAgent' - hash :sdk_pipeline_options, as: 'sdkPipelineOptions' + hash :internal_experiments, as: 'internalExperiments' end end class StreamingComputationTask # @private @@ -962,24 +1377,24 @@ end class ComponentTransform # @private class Representation < Google::Apis::Core::JsonRepresentation - property :user_name, as: 'userName' property :original_transform, as: 'originalTransform' property :name, as: 'name' + property :user_name, as: 'userName' end end class StreamingSetupTask # @private class Representation < Google::Apis::Core::JsonRepresentation - property :receive_work_port, as: 'receiveWorkPort' property :streaming_computation_topology, as: 'streamingComputationTopology', class: Google::Apis::DataflowV1b3::TopologyConfig, decorator: Google::Apis::DataflowV1b3::TopologyConfig::Representation property :worker_harness_port, as: 'workerHarnessPort' property :drain, as: 'drain' + property :receive_work_port, as: 'receiveWorkPort' end end class PubsubLocation # @private @@ -995,27 +1410,38 @@ end class WorkerHealthReport # @private class Representation < Google::Apis::Core::JsonRepresentation + collection :pods, as: 'pods' property :vm_startup_time, as: 'vmStartupTime' property :vm_is_healthy, as: 'vmIsHealthy' property :report_interval, as: 'reportInterval' - collection :pods, as: 'pods' end end class JobMessage # @private class Representation < Google::Apis::Core::JsonRepresentation + property :id, as: 'id' property :message_text, as: 'messageText' property :message_importance, as: 'messageImportance' property :time, as: 'time' - property :id, as: 'id' end end + class ParameterMetadata + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :regexes, as: 'regexes' + property :label, as: 'label' + property :help_text, as: 'helpText' + property :is_optional, as: 'isOptional' + property :name, as: 'name' + end + end + class MultiOutputInfo # @private class Representation < Google::Apis::Core::JsonRepresentation property :tag, as: 'tag' end @@ -1061,12 +1487,12 @@ property :task_group, as: 'taskGroup' property :harness_command, as: 'harnessCommand' property :log_dir, as: 'logDir' property :dataflow_api_version, as: 'dataflowApiVersion' collection :oauth_scopes, as: 'oauthScopes' - property :log_upload_location, as: 'logUploadLocation' property :streaming_worker_main_class, as: 'streamingWorkerMainClass' + property :log_upload_location, as: 'logUploadLocation' property :workflow_file_name, as: 'workflowFileName' property :temp_storage_prefix, as: 'tempStoragePrefix' property :base_task_dir, as: 'baseTaskDir' property :commandlines_file_name, as: 'commandlinesFileName' property :language_hint, as: 'languageHint' @@ -1082,17 +1508,17 @@ end class Position # @private class Representation < Google::Apis::Core::JsonRepresentation - property :key, as: 'key' - property :record_index, as: 'recordIndex' - property :shuffle_position, as: 'shufflePosition' - property :byte_offset, as: 'byteOffset' property :concat_position, as: 'concatPosition', class: Google::Apis::DataflowV1b3::ConcatPosition, decorator: Google::Apis::DataflowV1b3::ConcatPosition::Representation + property :byte_offset, as: 'byteOffset' property :end, as: 'end' + property :key, as: 'key' + property :record_index, as: 'recordIndex' + property :shuffle_position, as: 'shufflePosition' end end class SplitInt64 # @private @@ -1115,35 +1541,35 @@ end class WorkerPool # @private class Representation < Google::Apis::Core::JsonRepresentation - property :network, as: 'network' - property :default_package_set, as: 'defaultPackageSet' - property :num_threads_per_worker, as: 'numThreadsPerWorker' - property :num_workers, as: 'numWorkers' - property :zone, as: 'zone' - property :disk_source_image, as: 'diskSourceImage' - collection :packages, as: 'packages', class: Google::Apis::DataflowV1b3::Package, decorator: Google::Apis::DataflowV1b3::Package::Representation - property :teardown_policy, as: 'teardownPolicy' property :on_host_maintenance, as: 'onHostMaintenance' hash :pool_args, as: 'poolArgs' property :disk_size_gb, as: 'diskSizeGb' property :worker_harness_container_image, as: 'workerHarnessContainerImage' - property :disk_type, as: 'diskType' property :machine_type, as: 'machineType' + property :disk_type, as: 'diskType' property :kind, as: 'kind' collection :data_disks, as: 'dataDisks', class: Google::Apis::DataflowV1b3::Disk, decorator: Google::Apis::DataflowV1b3::Disk::Representation property :subnetwork, as: 'subnetwork' property :ip_configuration, as: 'ipConfiguration' property :autoscaling_settings, as: 'autoscalingSettings', class: Google::Apis::DataflowV1b3::AutoscalingSettings, decorator: Google::Apis::DataflowV1b3::AutoscalingSettings::Representation property :taskrunner_settings, as: 'taskrunnerSettings', class: Google::Apis::DataflowV1b3::TaskRunnerSettings, decorator: Google::Apis::DataflowV1b3::TaskRunnerSettings::Representation hash :metadata, as: 'metadata' + property :default_package_set, as: 'defaultPackageSet' + property :network, as: 'network' + property :num_threads_per_worker, as: 'numThreadsPerWorker' + property :zone, as: 'zone' + property :num_workers, as: 'numWorkers' + property :disk_source_image, as: 'diskSourceImage' + collection :packages, as: 'packages', class: Google::Apis::DataflowV1b3::Package, decorator: Google::Apis::DataflowV1b3::Package::Representation + end end class SourceOperationRequest # @private @@ -1156,33 +1582,33 @@ end class WorkItem # @private class Representation < Google::Apis::Core::JsonRepresentation - property :lease_expire_time, as: 'leaseExpireTime' - property :streaming_config_task, as: 'streamingConfigTask', class: Google::Apis::DataflowV1b3::StreamingConfigTask, decorator: Google::Apis::DataflowV1b3::StreamingConfigTask::Representation - property :initial_report_index, as: 'initialReportIndex' - property :shell_task, as: 'shellTask', class: Google::Apis::DataflowV1b3::ShellTask, decorator: Google::Apis::DataflowV1b3::ShellTask::Representation - property :streaming_computation_task, as: 'streamingComputationTask', class: Google::Apis::DataflowV1b3::StreamingComputationTask, decorator: Google::Apis::DataflowV1b3::StreamingComputationTask::Representation + property :shell_task, as: 'shellTask', class: Google::Apis::DataflowV1b3::ShellTask, decorator: Google::Apis::DataflowV1b3::ShellTask::Representation + property :job_id, as: 'jobId' property :id, as: 'id' property :configuration, as: 'configuration' property :map_task, as: 'mapTask', class: Google::Apis::DataflowV1b3::MapTask, decorator: Google::Apis::DataflowV1b3::MapTask::Representation property :seq_map_task, as: 'seqMapTask', class: Google::Apis::DataflowV1b3::SeqMapTask, decorator: Google::Apis::DataflowV1b3::SeqMapTask::Representation collection :packages, as: 'packages', class: Google::Apis::DataflowV1b3::Package, decorator: Google::Apis::DataflowV1b3::Package::Representation property :project_id, as: 'projectId' + property :report_status_interval, as: 'reportStatusInterval' property :streaming_setup_task, as: 'streamingSetupTask', class: Google::Apis::DataflowV1b3::StreamingSetupTask, decorator: Google::Apis::DataflowV1b3::StreamingSetupTask::Representation - property :report_status_interval, as: 'reportStatusInterval' property :source_operation_task, as: 'sourceOperationTask', class: Google::Apis::DataflowV1b3::SourceOperationRequest, decorator: Google::Apis::DataflowV1b3::SourceOperationRequest::Representation + property :lease_expire_time, as: 'leaseExpireTime' + property :streaming_config_task, as: 'streamingConfigTask', class: Google::Apis::DataflowV1b3::StreamingConfigTask, decorator: Google::Apis::DataflowV1b3::StreamingConfigTask::Representation + end end class ResourceUtilizationReport # @private @@ -1201,17 +1627,17 @@ end class TopologyConfig # @private class Representation < Google::Apis::Core::JsonRepresentation - hash :user_stage_to_computation_name_map, as: 'userStageToComputationNameMap' collection :computations, as: 'computations', class: Google::Apis::DataflowV1b3::ComputationTopology, decorator: Google::Apis::DataflowV1b3::ComputationTopology::Representation collection :data_disk_assignments, as: 'dataDiskAssignments', class: Google::Apis::DataflowV1b3::DataDiskAssignment, decorator: Google::Apis::DataflowV1b3::DataDiskAssignment::Representation property :persistent_state_version, as: 'persistentStateVersion' property :forwarding_key_bits, as: 'forwardingKeyBits' + hash :user_stage_to_computation_name_map, as: 'userStageToComputationNameMap' end end class SourceSplitOptions # @private @@ -1239,22 +1665,22 @@ property :shuffle_service_path, as: 'shuffleServicePath' property :worker_id, as: 'workerId' end end - class DataDiskAssignment + class StreamingStageLocation # @private class Representation < Google::Apis::Core::JsonRepresentation - property :vm_instance, as: 'vmInstance' - collection :data_disks, as: 'dataDisks' + property :stream_id, as: 'streamId' end end - class StreamingStageLocation + class DataDiskAssignment # @private class Representation < Google::Apis::Core::JsonRepresentation - property :stream_id, as: 'streamId' + property :vm_instance, as: 'vmInstance' + collection :data_disks, as: 'dataDisks' end end class ApproximateSplitRequest # @private @@ -1266,13 +1692,13 @@ end class Status # @private class Representation < Google::Apis::Core::JsonRepresentation - collection :details, as: 'details' property :code, as: 'code' property :message, as: 'message' + collection :details, as: 'details' end end class StreamLocation # @private @@ -1294,39 +1720,49 @@ collection :worker_message_responses, as: 'workerMessageResponses', class: Google::Apis::DataflowV1b3::WorkerMessageResponse, decorator: Google::Apis::DataflowV1b3::WorkerMessageResponse::Representation end end + class StreamingComputationConfig + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :system_name, as: 'systemName' + property :stage_name, as: 'stageName' + collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation + + property :computation_id, as: 'computationId' + end + end + class TransformSummary # @private class Representation < Google::Apis::Core::JsonRepresentation - collection :output_collection_name, as: 'outputCollectionName' + property :id, as: 'id' collection :display_data, as: 'displayData', class: Google::Apis::DataflowV1b3::DisplayData, decorator: Google::Apis::DataflowV1b3::DisplayData::Representation + collection :output_collection_name, as: 'outputCollectionName' property :kind, as: 'kind' collection :input_collection_name, as: 'inputCollectionName' property :name, as: 'name' - property :id, as: 'id' end end - class StreamingComputationConfig + class LeaseWorkItemResponse # @private class Representation < Google::Apis::Core::JsonRepresentation - property :computation_id, as: 'computationId' - property :system_name, as: 'systemName' - property :stage_name, as: 'stageName' - collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation + collection :work_items, as: 'workItems', class: Google::Apis::DataflowV1b3::WorkItem, decorator: Google::Apis::DataflowV1b3::WorkItem::Representation end end - class LeaseWorkItemResponse + class LaunchTemplateParameters # @private class Representation < Google::Apis::Core::JsonRepresentation - collection :work_items, as: 'workItems', class: Google::Apis::DataflowV1b3::WorkItem, decorator: Google::Apis::DataflowV1b3::WorkItem::Representation + property :job_name, as: 'jobName' + property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::RuntimeEnvironment, decorator: Google::Apis::DataflowV1b3::RuntimeEnvironment::Representation + hash :parameters, as: 'parameters' end end class Sink # @private @@ -1345,36 +1781,36 @@ end class PartialGroupByKeyInstruction # @private class Representation < Google::Apis::Core::JsonRepresentation - hash :value_combining_fn, as: 'valueCombiningFn' hash :input_element_codec, as: 'inputElementCodec' + hash :value_combining_fn, as: 'valueCombiningFn' property :original_combine_values_input_store_name, as: 'originalCombineValuesInputStoreName' property :original_combine_values_step_name, as: 'originalCombineValuesStepName' collection :side_inputs, as: 'sideInputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation end end - class StageSource + class InstructionInput # @private class Representation < Google::Apis::Core::JsonRepresentation - property :name, as: 'name' - property :original_user_transform_or_collection, as: 'originalUserTransformOrCollection' - property :size_bytes, as: 'sizeBytes' - property :user_name, as: 'userName' + property :producer_instruction_index, as: 'producerInstructionIndex' + property :output_num, as: 'outputNum' end end - class InstructionInput + class StageSource # @private class Representation < Google::Apis::Core::JsonRepresentation - property :producer_instruction_index, as: 'producerInstructionIndex' - property :output_num, as: 'outputNum' + property :original_transform_or_collection, as: 'originalTransformOrCollection' + property :name, as: 'name' + property :size_bytes, as: 'sizeBytes' + property :user_name, as: 'userName' end end class StringList # @private @@ -1384,42 +1820,52 @@ end class DisplayData # @private class Representation < Google::Apis::Core::JsonRepresentation - property :url, as: 'url' - property :label, as: 'label' - property :timestamp_value, as: 'timestampValue' - property :bool_value, as: 'boolValue' - property :java_class_value, as: 'javaClassValue' - property :str_value, as: 'strValue' - property :int64_value, as: 'int64Value' property :duration_value, as: 'durationValue' + property :int64_value, as: 'int64Value' property :namespace, as: 'namespace' property :float_value, as: 'floatValue' property :key, as: 'key' property :short_str_value, as: 'shortStrValue' + property :label, as: 'label' + property :url, as: 'url' + property :timestamp_value, as: 'timestampValue' + property :bool_value, as: 'boolValue' + property :java_class_value, as: 'javaClassValue' + property :str_value, as: 'strValue' end end + class GetDebugConfigRequest + # @private + class Representation < Google::Apis::Core::JsonRepresentation + property :component_id, as: 'componentId' + property :worker_id, as: 'workerId' + end + end + class LeaseWorkItemRequest # @private class Representation < Google::Apis::Core::JsonRepresentation property :current_worker_time, as: 'currentWorkerTime' - collection :work_item_types, as: 'workItemTypes' property :location, as: 'location' + collection :work_item_types, as: 'workItemTypes' collection :worker_capabilities, as: 'workerCapabilities' property :worker_id, as: 'workerId' property :requested_lease_duration, as: 'requestedLeaseDuration' end end - class GetDebugConfigRequest + class GetTemplateResponse # @private class Representation < Google::Apis::Core::JsonRepresentation - property :component_id, as: 'componentId' - property :worker_id, as: 'workerId' + property :status, as: 'status', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation + + property :metadata, as: 'metadata', class: Google::Apis::DataflowV1b3::TemplateMetadata, decorator: Google::Apis::DataflowV1b3::TemplateMetadata::Representation + end end class ReportWorkItemStatusRequest # @private @@ -1430,10 +1876,19 @@ collection :work_item_statuses, as: 'workItemStatuses', class: Google::Apis::DataflowV1b3::WorkItemStatus, decorator: Google::Apis::DataflowV1b3::WorkItemStatus::Representation end end + class StreamingConfigTask + # @private + class Representation < Google::Apis::Core::JsonRepresentation + collection :streaming_computation_configs, as: 'streamingComputationConfigs', class: Google::Apis::DataflowV1b3::StreamingComputationConfig, decorator: Google::Apis::DataflowV1b3::StreamingComputationConfig::Representation + + hash :user_step_to_state_family_name_map, as: 'userStepToStateFamilyNameMap' + end + end + class PipelineDescription # @private class Representation < Google::Apis::Core::JsonRepresentation collection :original_pipeline_transform, as: 'originalPipelineTransform', class: Google::Apis::DataflowV1b3::TransformSummary, decorator: Google::Apis::DataflowV1b3::TransformSummary::Representation @@ -1442,25 +1897,16 @@ collection :execution_pipeline_stage, as: 'executionPipelineStage', class: Google::Apis::DataflowV1b3::ExecutionStageSummary, decorator: Google::Apis::DataflowV1b3::ExecutionStageSummary::Representation end end - class StreamingConfigTask - # @private - class Representation < Google::Apis::Core::JsonRepresentation - collection :streaming_computation_configs, as: 'streamingComputationConfigs', class: Google::Apis::DataflowV1b3::StreamingComputationConfig, decorator: Google::Apis::DataflowV1b3::StreamingComputationConfig::Representation - - hash :user_step_to_state_family_name_map, as: 'userStepToStateFamilyNameMap' - end - end - class Step # @private class Representation < Google::Apis::Core::JsonRepresentation + property :name, as: 'name' property :kind, as: 'kind' hash :properties, as: 'properties' - property :name, as: 'name' end end class JobExecutionInfo # @private @@ -1484,39 +1930,39 @@ property :disk_type, as: 'diskType' property :mount_point, as: 'mountPoint' end end - class ListJobMessagesResponse + class CounterMetadata # @private class Representation < Google::Apis::Core::JsonRepresentation - property :next_page_token, as: 'nextPageToken' - collection :job_messages, as: 'jobMessages', class: Google::Apis::DataflowV1b3::JobMessage, decorator: Google::Apis::DataflowV1b3::JobMessage::Representation - + property :standard_units, as: 'standardUnits' + property :other_units, as: 'otherUnits' + property :kind, as: 'kind' + property :description, as: 'description' end end - class CounterMetadata + class ListJobMessagesResponse # @private class Representation < Google::Apis::Core::JsonRepresentation - property :kind, as: 'kind' - property :description, as: 'description' - property :standard_units, as: 'standardUnits' - property :other_units, as: 'otherUnits' + collection :job_messages, as: 'jobMessages', class: Google::Apis::DataflowV1b3::JobMessage, decorator: Google::Apis::DataflowV1b3::JobMessage::Representation + + property :next_page_token, as: 'nextPageToken' end end class ApproximateReportedProgress # @private class Representation < Google::Apis::Core::JsonRepresentation + property :remaining_parallelism, as: 'remainingParallelism', class: Google::Apis::DataflowV1b3::ReportedParallelism, decorator: Google::Apis::DataflowV1b3::ReportedParallelism::Representation + property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation property :fraction_consumed, as: 'fractionConsumed' property :consumed_parallelism, as: 'consumedParallelism', class: Google::Apis::DataflowV1b3::ReportedParallelism, decorator: Google::Apis::DataflowV1b3::ReportedParallelism::Representation - property :remaining_parallelism, as: 'remainingParallelism', class: Google::Apis::DataflowV1b3::ReportedParallelism, decorator: Google::Apis::DataflowV1b3::ReportedParallelism::Representation - end end class StateFamilyConfig # @private @@ -1541,416 +1987,52 @@ end class SourceSplitResponse # @private class Representation < Google::Apis::Core::JsonRepresentation - collection :shards, as: 'shards', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation - property :outcome, as: 'outcome' collection :bundles, as: 'bundles', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation + collection :shards, as: 'shards', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation + end end class ParallelInstruction # @private class Representation < Google::Apis::Core::JsonRepresentation collection :outputs, as: 'outputs', class: Google::Apis::DataflowV1b3::InstructionOutput, decorator: Google::Apis::DataflowV1b3::InstructionOutput::Representation property :name, as: 'name' - property :read, as: 'read', class: Google::Apis::DataflowV1b3::ReadInstruction, decorator: Google::Apis::DataflowV1b3::ReadInstruction::Representation - property :par_do, as: 'parDo', class: Google::Apis::DataflowV1b3::ParDoInstruction, decorator: Google::Apis::DataflowV1b3::ParDoInstruction::Representation - property :flatten, as: 'flatten', class: Google::Apis::DataflowV1b3::FlattenInstruction, decorator: Google::Apis::DataflowV1b3::FlattenInstruction::Representation + property :read, as: 'read', class: Google::Apis::DataflowV1b3::ReadInstruction, decorator: Google::Apis::DataflowV1b3::ReadInstruction::Representation property :original_name, as: 'originalName' - property :system_name, as: 'systemName' + property :flatten, as: 'flatten', class: Google::Apis::DataflowV1b3::FlattenInstruction, decorator: Google::Apis::DataflowV1b3::FlattenInstruction::Representation + property :write, as: 'write', class: Google::Apis::DataflowV1b3::WriteInstruction, decorator: Google::Apis::DataflowV1b3::WriteInstruction::Representation + property :system_name, as: 'systemName' property :partial_group_by_key, as: 'partialGroupByKey', class: Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction, decorator: Google::Apis::DataflowV1b3::PartialGroupByKeyInstruction::Representation end end class Package # @private class Representation < Google::Apis::Core::JsonRepresentation - property :location, as: 'location' property :name, as: 'name' + property :location, as: 'location' end end class KeyRangeDataDiskAssignment # @private class Representation < Google::Apis::Core::JsonRepresentation property :start, as: 'start' property :data_disk, as: 'dataDisk' property :end, as: 'end' - end - end - - class ParDoInstruction - # @private - class Representation < Google::Apis::Core::JsonRepresentation - collection :multi_output_infos, as: 'multiOutputInfos', class: Google::Apis::DataflowV1b3::MultiOutputInfo, decorator: Google::Apis::DataflowV1b3::MultiOutputInfo::Representation - - hash :user_fn, as: 'userFn' - property :input, as: 'input', class: Google::Apis::DataflowV1b3::InstructionInput, decorator: Google::Apis::DataflowV1b3::InstructionInput::Representation - - property :num_outputs, as: 'numOutputs' - collection :side_inputs, as: 'sideInputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation - - end - end - - class MetricUpdate - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :internal, as: 'internal' - property :cumulative, as: 'cumulative' - property :kind, as: 'kind' - property :scalar, as: 'scalar' - property :mean_count, as: 'meanCount' - property :mean_sum, as: 'meanSum' - property :update_time, as: 'updateTime' - property :name, as: 'name', class: Google::Apis::DataflowV1b3::MetricStructuredName, decorator: Google::Apis::DataflowV1b3::MetricStructuredName::Representation - - property :set, as: 'set' - end - end - - class CounterStructuredName - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :component_step_name, as: 'componentStepName' - property :portion, as: 'portion' - property :original_step_name, as: 'originalStepName' - property :worker_id, as: 'workerId' - property :origin_namespace, as: 'originNamespace' - property :origin, as: 'origin' - property :name, as: 'name' - property :execution_step_name, as: 'executionStepName' - end - end - - class ApproximateProgress - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :position, as: 'position', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation - - property :percent_complete, as: 'percentComplete' - property :remaining_time, as: 'remainingTime' - end - end - - class WorkerMessageResponse - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :worker_metrics_response, as: 'workerMetricsResponse', class: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReportResponse::Representation - - property :worker_health_report_response, as: 'workerHealthReportResponse', class: Google::Apis::DataflowV1b3::WorkerHealthReportResponse, decorator: Google::Apis::DataflowV1b3::WorkerHealthReportResponse::Representation - - end - end - - class WorkerMessage - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :time, as: 'time' - property :worker_health_report, as: 'workerHealthReport', class: Google::Apis::DataflowV1b3::WorkerHealthReport, decorator: Google::Apis::DataflowV1b3::WorkerHealthReport::Representation - - property :worker_message_code, as: 'workerMessageCode', class: Google::Apis::DataflowV1b3::WorkerMessageCode, decorator: Google::Apis::DataflowV1b3::WorkerMessageCode::Representation - - property :worker_metrics, as: 'workerMetrics', class: Google::Apis::DataflowV1b3::ResourceUtilizationReport, decorator: Google::Apis::DataflowV1b3::ResourceUtilizationReport::Representation - - hash :labels, as: 'labels' - end - end - - class JobMetrics - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :metric_time, as: 'metricTime' - collection :metrics, as: 'metrics', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation - - end - end - - class FloatingPointList - # @private - class Representation < Google::Apis::Core::JsonRepresentation - collection :elements, as: 'elements' - end - end - - class CounterUpdate - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :floating_point_list, as: 'floatingPointList', class: Google::Apis::DataflowV1b3::FloatingPointList, decorator: Google::Apis::DataflowV1b3::FloatingPointList::Representation - - property :integer, as: 'integer', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - - property :integer_list, as: 'integerList', class: Google::Apis::DataflowV1b3::IntegerList, decorator: Google::Apis::DataflowV1b3::IntegerList::Representation - - property :structured_name_and_metadata, as: 'structuredNameAndMetadata', class: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata, decorator: Google::Apis::DataflowV1b3::CounterStructuredNameAndMetadata::Representation - - property :integer_mean, as: 'integerMean', class: Google::Apis::DataflowV1b3::IntegerMean, decorator: Google::Apis::DataflowV1b3::IntegerMean::Representation - - property :floating_point, as: 'floatingPoint' - property :cumulative, as: 'cumulative' - property :internal, as: 'internal' - property :floating_point_mean, as: 'floatingPointMean', class: Google::Apis::DataflowV1b3::FloatingPointMean, decorator: Google::Apis::DataflowV1b3::FloatingPointMean::Representation - - property :boolean, as: 'boolean' - property :name_and_kind, as: 'nameAndKind', class: Google::Apis::DataflowV1b3::NameAndKind, decorator: Google::Apis::DataflowV1b3::NameAndKind::Representation - - property :string_list, as: 'stringList', class: Google::Apis::DataflowV1b3::StringList, decorator: Google::Apis::DataflowV1b3::StringList::Representation - - property :distribution, as: 'distribution', class: Google::Apis::DataflowV1b3::DistributionUpdate, decorator: Google::Apis::DataflowV1b3::DistributionUpdate::Representation - - property :short_id, as: 'shortId' - end - end - - class SourceMetadata - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :produces_sorted_keys, as: 'producesSortedKeys' - property :infinite, as: 'infinite' - property :estimated_size_bytes, as: 'estimatedSizeBytes' - end - end - - class DistributionUpdate - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - - property :min, as: 'min', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - - property :sum_of_squares, as: 'sumOfSquares' - property :max, as: 'max', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - - property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - - end - end - - class SourceFork - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :residual, as: 'residual', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation - - property :residual_source, as: 'residualSource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation - - property :primary, as: 'primary', class: Google::Apis::DataflowV1b3::SourceSplitShard, decorator: Google::Apis::DataflowV1b3::SourceSplitShard::Representation - - property :primary_source, as: 'primarySource', class: Google::Apis::DataflowV1b3::DerivedSource, decorator: Google::Apis::DataflowV1b3::DerivedSource::Representation - - end - end - - class WorkerHealthReportResponse - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :report_interval, as: 'reportInterval' - end - end - - class WorkItemStatus - # @private - class Representation < Google::Apis::Core::JsonRepresentation - collection :counter_updates, as: 'counterUpdates', class: Google::Apis::DataflowV1b3::CounterUpdate, decorator: Google::Apis::DataflowV1b3::CounterUpdate::Representation - - property :work_item_id, as: 'workItemId' - collection :metric_updates, as: 'metricUpdates', class: Google::Apis::DataflowV1b3::MetricUpdate, decorator: Google::Apis::DataflowV1b3::MetricUpdate::Representation - - collection :errors, as: 'errors', class: Google::Apis::DataflowV1b3::Status, decorator: Google::Apis::DataflowV1b3::Status::Representation - - property :dynamic_source_split, as: 'dynamicSourceSplit', class: Google::Apis::DataflowV1b3::DynamicSourceSplit, decorator: Google::Apis::DataflowV1b3::DynamicSourceSplit::Representation - - property :source_operation_response, as: 'sourceOperationResponse', class: Google::Apis::DataflowV1b3::SourceOperationResponse, decorator: Google::Apis::DataflowV1b3::SourceOperationResponse::Representation - - property :progress, as: 'progress', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation - - property :requested_lease_duration, as: 'requestedLeaseDuration' - property :report_index, as: 'reportIndex' - property :stop_position, as: 'stopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation - - property :completed, as: 'completed' - property :reported_progress, as: 'reportedProgress', class: Google::Apis::DataflowV1b3::ApproximateReportedProgress, decorator: Google::Apis::DataflowV1b3::ApproximateReportedProgress::Representation - - property :source_fork, as: 'sourceFork', class: Google::Apis::DataflowV1b3::SourceFork, decorator: Google::Apis::DataflowV1b3::SourceFork::Representation - - end - end - - class ComponentSource - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :user_name, as: 'userName' - property :original_transform_or_collection, as: 'originalTransformOrCollection' - property :name, as: 'name' - end - end - - class WorkItemServiceState - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :split_request, as: 'splitRequest', class: Google::Apis::DataflowV1b3::ApproximateSplitRequest, decorator: Google::Apis::DataflowV1b3::ApproximateSplitRequest::Representation - - property :report_status_interval, as: 'reportStatusInterval' - property :suggested_stop_position, as: 'suggestedStopPosition', class: Google::Apis::DataflowV1b3::Position, decorator: Google::Apis::DataflowV1b3::Position::Representation - - hash :harness_data, as: 'harnessData' - property :lease_expire_time, as: 'leaseExpireTime' - collection :metric_short_id, as: 'metricShortId', class: Google::Apis::DataflowV1b3::MetricShortId, decorator: Google::Apis::DataflowV1b3::MetricShortId::Representation - - property :next_report_index, as: 'nextReportIndex' - property :suggested_stop_point, as: 'suggestedStopPoint', class: Google::Apis::DataflowV1b3::ApproximateProgress, decorator: Google::Apis::DataflowV1b3::ApproximateProgress::Representation - - end - end - - class MetricStructuredName - # @private - class Representation < Google::Apis::Core::JsonRepresentation - hash :context, as: 'context' - property :origin, as: 'origin' - property :name, as: 'name' - end - end - - class SeqMapTaskOutputInfo - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :sink, as: 'sink', class: Google::Apis::DataflowV1b3::Sink, decorator: Google::Apis::DataflowV1b3::Sink::Representation - - property :tag, as: 'tag' - end - end - - class JobExecutionStageInfo - # @private - class Representation < Google::Apis::Core::JsonRepresentation - collection :step_name, as: 'stepName' - end - end - - class KeyRangeLocation - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :persistent_directory, as: 'persistentDirectory' - property :end, as: 'end' - property :delivery_endpoint, as: 'deliveryEndpoint' - property :start, as: 'start' - property :data_disk, as: 'dataDisk' - end - end - - class SourceGetMetadataRequest - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :source, as: 'source', class: Google::Apis::DataflowV1b3::Source, decorator: Google::Apis::DataflowV1b3::Source::Representation - - end - end - - class SeqMapTask - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :name, as: 'name' - collection :output_infos, as: 'outputInfos', class: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo, decorator: Google::Apis::DataflowV1b3::SeqMapTaskOutputInfo::Representation - - collection :inputs, as: 'inputs', class: Google::Apis::DataflowV1b3::SideInputInfo, decorator: Google::Apis::DataflowV1b3::SideInputInfo::Representation - - property :system_name, as: 'systemName' - property :stage_name, as: 'stageName' - hash :user_fn, as: 'userFn' - end - end - - class NameAndKind - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :name, as: 'name' - property :kind, as: 'kind' - end - end - - class WorkerMessageCode - # @private - class Representation < Google::Apis::Core::JsonRepresentation - hash :parameters, as: 'parameters' - property :code, as: 'code' - end - end - - class CustomSourceLocation - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :stateful, as: 'stateful' - end - end - - class MapTask - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :system_name, as: 'systemName' - property :stage_name, as: 'stageName' - collection :instructions, as: 'instructions', class: Google::Apis::DataflowV1b3::ParallelInstruction, decorator: Google::Apis::DataflowV1b3::ParallelInstruction::Representation - - end - end - - class FloatingPointMean - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :sum, as: 'sum' - property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - - end - end - - class ReportWorkItemStatusResponse - # @private - class Representation < Google::Apis::Core::JsonRepresentation - collection :work_item_service_states, as: 'workItemServiceStates', class: Google::Apis::DataflowV1b3::WorkItemServiceState, decorator: Google::Apis::DataflowV1b3::WorkItemServiceState::Representation - - end - end - - class InstructionOutput - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :name, as: 'name' - property :original_name, as: 'originalName' - property :system_name, as: 'systemName' - property :only_count_key_bytes, as: 'onlyCountKeyBytes' - property :only_count_value_bytes, as: 'onlyCountValueBytes' - hash :codec, as: 'codec' - end - end - - class CreateJobFromTemplateRequest - # @private - class Representation < Google::Apis::Core::JsonRepresentation - hash :parameters, as: 'parameters' - property :job_name, as: 'jobName' - property :gcs_path, as: 'gcsPath' - property :environment, as: 'environment', class: Google::Apis::DataflowV1b3::RuntimeEnvironment, decorator: Google::Apis::DataflowV1b3::RuntimeEnvironment::Representation - - end - end - - class IntegerMean - # @private - class Representation < Google::Apis::Core::JsonRepresentation - property :count, as: 'count', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - - property :sum, as: 'sum', class: Google::Apis::DataflowV1b3::SplitInt64, decorator: Google::Apis::DataflowV1b3::SplitInt64::Representation - end end end end end