Autogenerated update (2018-06-15)
Update: - cloudbuild_v1 - cloudtasks_v2beta2 - dataproc_v1 - dialogflow_v2 - dialogflow_v2beta1 - iamcredentials_v1 - ml_v1 - serviceconsumermanagement_v1 - servicecontrol_v1
This commit is contained in:
1 parent
f7475934ab
commit
da450745d5
22 files changed
+742
-122
No files matched your search
@@ -239,6 +239,38 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
# The cluster operation triggered by a workflow.
|
||||
class ClusterOperation
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Output only. Indicates the operation is done.
|
||||
# Corresponds to the JSON property `done`
|
||||
# @return [Boolean]
|
||||
attr_accessor :done
|
||||
alias_method :done?, :done
|
||||
|
||||
# Output only. Error, if operation failed.
|
||||
# Corresponds to the JSON property `error`
|
||||
# @return [String]
|
||||
attr_accessor :error
|
||||
|
||||
# Output only. The id of the cluster operation.
|
||||
# Corresponds to the JSON property `operationId`
|
||||
# @return [String]
|
||||
attr_accessor :operation_id
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@done = args[:done] if args.key?(:done)
|
||||
@error = args[:error] if args.key?(:error)
|
||||
@operation_id = args[:operation_id] if args.key?(:operation_id)
|
||||
end
|
||||
end
|
||||
|
||||
# Metadata describing the operation.
|
||||
class ClusterOperationMetadata
|
||||
include Google::Apis::Core::Hashable
|
||||
@@ -417,6 +449,13 @@ module Google
|
||||
# @return [Fixnum]
|
||||
attr_accessor :boot_disk_size_gb
|
||||
|
||||
# Optional. Type of the boot disk (default is "pd-standard"). Valid values: "pd-
|
||||
# ssd" (Persistent Disk Solid State Drive) or "pd-standard" (Persistent Disk
|
||||
# Hard Disk Drive).
|
||||
# Corresponds to the JSON property `bootDiskType`
|
||||
# @return [String]
|
||||
attr_accessor :boot_disk_type
|
||||
|
||||
# Optional. Number of attached SSDs, from 0 to 4 (default is 0). If SSDs are not
|
||||
# attached, the boot disk is used to store runtime logs and HDFS (https://hadoop.
|
||||
# apache.org/docs/r1.2.1/hdfs_user_guide.html) data. If one or more SSDs are
|
||||
@@ -433,6 +472,7 @@ module Google
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@boot_disk_size_gb = args[:boot_disk_size_gb] if args.key?(:boot_disk_size_gb)
|
||||
@boot_disk_type = args[:boot_disk_type] if args.key?(:boot_disk_type)
|
||||
@num_local_ssds = args[:num_local_ssds] if args.key?(:num_local_ssds)
|
||||
end
|
||||
end
|
||||
@@ -1683,6 +1723,129 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
# The workflow graph.
|
||||
class WorkflowGraph
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Output only. The workflow nodes.
|
||||
# Corresponds to the JSON property `nodes`
|
||||
# @return [Array<Google::Apis::DataprocV1::WorkflowNode>]
|
||||
attr_accessor :nodes
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@nodes = args[:nodes] if args.key?(:nodes)
|
||||
end
|
||||
end
|
||||
|
||||
# A Cloud Dataproc workflow template resource.
|
||||
class WorkflowMetadata
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Output only. The name of the managed cluster.
|
||||
# Corresponds to the JSON property `clusterName`
|
||||
# @return [String]
|
||||
attr_accessor :cluster_name
|
||||
|
||||
# The cluster operation triggered by a workflow.
|
||||
# Corresponds to the JSON property `createCluster`
|
||||
# @return [Google::Apis::DataprocV1::ClusterOperation]
|
||||
attr_accessor :create_cluster
|
||||
|
||||
# The cluster operation triggered by a workflow.
|
||||
# Corresponds to the JSON property `deleteCluster`
|
||||
# @return [Google::Apis::DataprocV1::ClusterOperation]
|
||||
attr_accessor :delete_cluster
|
||||
|
||||
# The workflow graph.
|
||||
# Corresponds to the JSON property `graph`
|
||||
# @return [Google::Apis::DataprocV1::WorkflowGraph]
|
||||
attr_accessor :graph
|
||||
|
||||
# Map from parameter names to values that were used for those parameters.
|
||||
# Corresponds to the JSON property `parameters`
|
||||
# @return [Hash<String,String>]
|
||||
attr_accessor :parameters
|
||||
|
||||
# Output only. The workflow state.
|
||||
# Corresponds to the JSON property `state`
|
||||
# @return [String]
|
||||
attr_accessor :state
|
||||
|
||||
# Output only. The "resource name" of the template.
|
||||
# Corresponds to the JSON property `template`
|
||||
# @return [String]
|
||||
attr_accessor :template
|
||||
|
||||
# Output only. The version of template at the time of workflow instantiation.
|
||||
# Corresponds to the JSON property `version`
|
||||
# @return [Fixnum]
|
||||
attr_accessor :version
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@cluster_name = args[:cluster_name] if args.key?(:cluster_name)
|
||||
@create_cluster = args[:create_cluster] if args.key?(:create_cluster)
|
||||
@delete_cluster = args[:delete_cluster] if args.key?(:delete_cluster)
|
||||
@graph = args[:graph] if args.key?(:graph)
|
||||
@parameters = args[:parameters] if args.key?(:parameters)
|
||||
@state = args[:state] if args.key?(:state)
|
||||
@template = args[:template] if args.key?(:template)
|
||||
@version = args[:version] if args.key?(:version)
|
||||
end
|
||||
end
|
||||
|
||||
# The workflow node.
|
||||
class WorkflowNode
|
||||
include Google::Apis::Core::Hashable
|
||||
|
||||
# Output only. The error detail.
|
||||
# Corresponds to the JSON property `error`
|
||||
# @return [String]
|
||||
attr_accessor :error
|
||||
|
||||
# Output only. The job id; populated after the node enters RUNNING state.
|
||||
# Corresponds to the JSON property `jobId`
|
||||
# @return [String]
|
||||
attr_accessor :job_id
|
||||
|
||||
# Output only. Node's prerequisite nodes.
|
||||
# Corresponds to the JSON property `prerequisiteStepIds`
|
||||
# @return [Array<String>]
|
||||
attr_accessor :prerequisite_step_ids
|
||||
|
||||
# Output only. The node state.
|
||||
# Corresponds to the JSON property `state`
|
||||
# @return [String]
|
||||
attr_accessor :state
|
||||
|
||||
# Output only. The name of the node.
|
||||
# Corresponds to the JSON property `stepId`
|
||||
# @return [String]
|
||||
attr_accessor :step_id
|
||||
|
||||
def initialize(**args)
|
||||
update!(**args)
|
||||
end
|
||||
|
||||
# Update properties of this object
|
||||
def update!(**args)
|
||||
@error = args[:error] if args.key?(:error)
|
||||
@job_id = args[:job_id] if args.key?(:job_id)
|
||||
@prerequisite_step_ids = args[:prerequisite_step_ids] if args.key?(:prerequisite_step_ids)
|
||||
@state = args[:state] if args.key?(:state)
|
||||
@step_id = args[:step_id] if args.key?(:step_id)
|
||||
end
|
||||
end
|
||||
|
||||
# A YARN application created by a job. Application information is a subset of <
|
||||
# code>org.apache.hadoop.yarn.proto.YarnProtos.ApplicationReportProto</code>.
|
||||
# Beta Feature: This report is available for testing purposes only. It may be
|
||||
|
||||
@@ -52,6 +52,12 @@ module Google
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ClusterOperation
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class ClusterOperationMetadata
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
@@ -238,6 +244,24 @@ module Google
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class WorkflowGraph
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class WorkflowMetadata
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class WorkflowNode
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
include Google::Apis::Core::JsonObjectSupport
|
||||
end
|
||||
|
||||
class YarnApplication
|
||||
class Representation < Google::Apis::Core::JsonRepresentation; end
|
||||
|
||||
@@ -303,6 +327,15 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
class ClusterOperation
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :done, as: 'done'
|
||||
property :error, as: 'error'
|
||||
property :operation_id, as: 'operationId'
|
||||
end
|
||||
end
|
||||
|
||||
class ClusterOperationMetadata
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
@@ -356,6 +389,7 @@ module Google
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :boot_disk_size_gb, as: 'bootDiskSizeGb'
|
||||
property :boot_disk_type, as: 'bootDiskType'
|
||||
property :num_local_ssds, as: 'numLocalSsds'
|
||||
end
|
||||
end
|
||||
@@ -645,6 +679,42 @@ module Google
|
||||
end
|
||||
end
|
||||
|
||||
class WorkflowGraph
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
collection :nodes, as: 'nodes', class: Google::Apis::DataprocV1::WorkflowNode, decorator: Google::Apis::DataprocV1::WorkflowNode::Representation
|
||||
|
||||
end
|
||||
end
|
||||
|
||||
class WorkflowMetadata
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :cluster_name, as: 'clusterName'
|
||||
property :create_cluster, as: 'createCluster', class: Google::Apis::DataprocV1::ClusterOperation, decorator: Google::Apis::DataprocV1::ClusterOperation::Representation
|
||||
|
||||
property :delete_cluster, as: 'deleteCluster', class: Google::Apis::DataprocV1::ClusterOperation, decorator: Google::Apis::DataprocV1::ClusterOperation::Representation
|
||||
|
||||
property :graph, as: 'graph', class: Google::Apis::DataprocV1::WorkflowGraph, decorator: Google::Apis::DataprocV1::WorkflowGraph::Representation
|
||||
|
||||
hash :parameters, as: 'parameters'
|
||||
property :state, as: 'state'
|
||||
property :template, as: 'template'
|
||||
property :version, as: 'version'
|
||||
end
|
||||
end
|
||||
|
||||
class WorkflowNode
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
property :error, as: 'error'
|
||||
property :job_id, as: 'jobId'
|
||||
collection :prerequisite_step_ids, as: 'prerequisiteStepIds'
|
||||
property :state, as: 'state'
|
||||
property :step_id, as: 'stepId'
|
||||
end
|
||||
end
|
||||
|
||||
class YarnApplication
|
||||
# @private
|
||||
class Representation < Google::Apis::Core::JsonRepresentation
|
||||
|
||||
Reference in new issue
Block a user