genproto: google.golang.org/genproto/googleapis/cloud/dataproc/v1 Index | Files

package dataproc

import "google.golang.org/genproto/googleapis/cloud/dataproc/v1"

Index

Package Files

clusters.pb.go jobs.pb.go operations.pb.go shared.pb.go workflow_templates.pb.go

Variables

var ClusterOperationStatus_State_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "PENDING",
    2:  "RUNNING",
    3:  "DONE",
}
var ClusterOperationStatus_State_value = map[string]int32{
    "UNKNOWN": 0,
    "PENDING": 1,
    "RUNNING": 2,
    "DONE":    3,
}
var ClusterStatus_State_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "CREATING",
    2:  "RUNNING",
    3:  "ERROR",
    4:  "DELETING",
    5:  "UPDATING",
}
var ClusterStatus_State_value = map[string]int32{
    "UNKNOWN":  0,
    "CREATING": 1,
    "RUNNING":  2,
    "ERROR":    3,
    "DELETING": 4,
    "UPDATING": 5,
}
var ClusterStatus_Substate_name = map[int32]string{
    0:  "UNSPECIFIED",
    1:  "UNHEALTHY",
    2:  "STALE_STATUS",
}
var ClusterStatus_Substate_value = map[string]int32{
    "UNSPECIFIED":  0,
    "UNHEALTHY":    1,
    "STALE_STATUS": 2,
}
var Component_name = map[int32]string{
    0:  "COMPONENT_UNSPECIFIED",
    5:  "ANACONDA",
    3:  "HIVE_WEBHCAT",
    1:  "JUPYTER",
    4:  "ZEPPELIN",
}
var Component_value = map[string]int32{
    "COMPONENT_UNSPECIFIED": 0,
    "ANACONDA":              5,
    "HIVE_WEBHCAT":          3,
    "JUPYTER":               1,
    "ZEPPELIN":              4,
}
var JobStatus_State_name = map[int32]string{
    0:  "STATE_UNSPECIFIED",
    1:  "PENDING",
    8:  "SETUP_DONE",
    2:  "RUNNING",
    3:  "CANCEL_PENDING",
    7:  "CANCEL_STARTED",
    4:  "CANCELLED",
    5:  "DONE",
    6:  "ERROR",
    9:  "ATTEMPT_FAILURE",
}
var JobStatus_State_value = map[string]int32{
    "STATE_UNSPECIFIED": 0,
    "PENDING":           1,
    "SETUP_DONE":        8,
    "RUNNING":           2,
    "CANCEL_PENDING":    3,
    "CANCEL_STARTED":    7,
    "CANCELLED":         4,
    "DONE":              5,
    "ERROR":             6,
    "ATTEMPT_FAILURE":   9,
}
var JobStatus_Substate_name = map[int32]string{
    0:  "UNSPECIFIED",
    1:  "SUBMITTED",
    2:  "QUEUED",
    3:  "STALE_STATUS",
}
var JobStatus_Substate_value = map[string]int32{
    "UNSPECIFIED":  0,
    "SUBMITTED":    1,
    "QUEUED":       2,
    "STALE_STATUS": 3,
}
var ListJobsRequest_JobStateMatcher_name = map[int32]string{
    0:  "ALL",
    1:  "ACTIVE",
    2:  "NON_ACTIVE",
}
var ListJobsRequest_JobStateMatcher_value = map[string]int32{
    "ALL":        0,
    "ACTIVE":     1,
    "NON_ACTIVE": 2,
}
var LoggingConfig_Level_name = map[int32]string{
    0:  "LEVEL_UNSPECIFIED",
    1:  "ALL",
    2:  "TRACE",
    3:  "DEBUG",
    4:  "INFO",
    5:  "WARN",
    6:  "ERROR",
    7:  "FATAL",
    8:  "OFF",
}
var LoggingConfig_Level_value = map[string]int32{
    "LEVEL_UNSPECIFIED": 0,
    "ALL":               1,
    "TRACE":             2,
    "DEBUG":             3,
    "INFO":              4,
    "WARN":              5,
    "ERROR":             6,
    "FATAL":             7,
    "OFF":               8,
}
var WorkflowMetadata_State_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "PENDING",
    2:  "RUNNING",
    3:  "DONE",
}
var WorkflowMetadata_State_value = map[string]int32{
    "UNKNOWN": 0,
    "PENDING": 1,
    "RUNNING": 2,
    "DONE":    3,
}
var WorkflowNode_NodeState_name = map[int32]string{
    0:  "NODE_STATE_UNSPECIFIED",
    1:  "BLOCKED",
    2:  "RUNNABLE",
    3:  "RUNNING",
    4:  "COMPLETED",
    5:  "FAILED",
}
var WorkflowNode_NodeState_value = map[string]int32{
    "NODE_STATE_UNSPECIFIED": 0,
    "BLOCKED":                1,
    "RUNNABLE":               2,
    "RUNNING":                3,
    "COMPLETED":              4,
    "FAILED":                 5,
}
var YarnApplication_State_name = map[int32]string{
    0:  "STATE_UNSPECIFIED",
    1:  "NEW",
    2:  "NEW_SAVING",
    3:  "SUBMITTED",
    4:  "ACCEPTED",
    5:  "RUNNING",
    6:  "FINISHED",
    7:  "FAILED",
    8:  "KILLED",
}
var YarnApplication_State_value = map[string]int32{
    "STATE_UNSPECIFIED": 0,
    "NEW":               1,
    "NEW_SAVING":        2,
    "SUBMITTED":         3,
    "ACCEPTED":          4,
    "RUNNING":           5,
    "FINISHED":          6,
    "FAILED":            7,
    "KILLED":            8,
}

func RegisterClusterControllerServer Uses

func RegisterClusterControllerServer(s *grpc.Server, srv ClusterControllerServer)

func RegisterJobControllerServer Uses

func RegisterJobControllerServer(s *grpc.Server, srv JobControllerServer)

func RegisterWorkflowTemplateServiceServer Uses

func RegisterWorkflowTemplateServiceServer(s *grpc.Server, srv WorkflowTemplateServiceServer)

type AcceleratorConfig Uses

type AcceleratorConfig struct {
    // Full URL, partial URI, or short name of the accelerator type resource to
    // expose to this instance. See
    // [Compute Engine
    // AcceleratorTypes](/compute/docs/reference/beta/acceleratorTypes).
    //
    // Examples:
    //
    // * `https://www.googleapis.com/compute/beta/projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80`
    // * `projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80`
    // * `nvidia-tesla-k80`
    //
    // **Auto Zone Exception**: If you are using the Cloud Dataproc
    // [Auto Zone
    // Placement](/dataproc/docs/concepts/configuring-clusters/auto-zone#using_auto_zone_placement)
    // feature, you must use the short name of the accelerator type
    // resource, for example, `nvidia-tesla-k80`.
    AcceleratorTypeUri string `protobuf:"bytes,1,opt,name=accelerator_type_uri,json=acceleratorTypeUri,proto3" json:"accelerator_type_uri,omitempty"`
    // The number of the accelerator cards of this type exposed to this instance.
    AcceleratorCount     int32    `protobuf:"varint,2,opt,name=accelerator_count,json=acceleratorCount,proto3" json:"accelerator_count,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Specifies the type and number of accelerator cards attached to the instances of an instance. See [GPUs on Compute Engine](/compute/docs/gpus/).

func (*AcceleratorConfig) Descriptor Uses

func (*AcceleratorConfig) Descriptor() ([]byte, []int)

func (*AcceleratorConfig) GetAcceleratorCount Uses

func (m *AcceleratorConfig) GetAcceleratorCount() int32

func (*AcceleratorConfig) GetAcceleratorTypeUri Uses

func (m *AcceleratorConfig) GetAcceleratorTypeUri() string

func (*AcceleratorConfig) ProtoMessage Uses

func (*AcceleratorConfig) ProtoMessage()

func (*AcceleratorConfig) Reset Uses

func (m *AcceleratorConfig) Reset()

func (*AcceleratorConfig) String Uses

func (m *AcceleratorConfig) String() string

func (*AcceleratorConfig) XXX_DiscardUnknown Uses

func (m *AcceleratorConfig) XXX_DiscardUnknown()

func (*AcceleratorConfig) XXX_Marshal Uses

func (m *AcceleratorConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AcceleratorConfig) XXX_Merge Uses

func (m *AcceleratorConfig) XXX_Merge(src proto.Message)

func (*AcceleratorConfig) XXX_Size Uses

func (m *AcceleratorConfig) XXX_Size() int

func (*AcceleratorConfig) XXX_Unmarshal Uses

func (m *AcceleratorConfig) XXX_Unmarshal(b []byte) error

type CancelJobRequest Uses

type CancelJobRequest struct {
    // Required. The ID of the Google Cloud Platform project that the job
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The job ID.
    JobId                string   `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to cancel a job.

func (*CancelJobRequest) Descriptor Uses

func (*CancelJobRequest) Descriptor() ([]byte, []int)

func (*CancelJobRequest) GetJobId Uses

func (m *CancelJobRequest) GetJobId() string

func (*CancelJobRequest) GetProjectId Uses

func (m *CancelJobRequest) GetProjectId() string

func (*CancelJobRequest) GetRegion Uses

func (m *CancelJobRequest) GetRegion() string

func (*CancelJobRequest) ProtoMessage Uses

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) Reset Uses

func (m *CancelJobRequest) Reset()

func (*CancelJobRequest) String Uses

func (m *CancelJobRequest) String() string

func (*CancelJobRequest) XXX_DiscardUnknown Uses

func (m *CancelJobRequest) XXX_DiscardUnknown()

func (*CancelJobRequest) XXX_Marshal Uses

func (m *CancelJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelJobRequest) XXX_Merge Uses

func (m *CancelJobRequest) XXX_Merge(src proto.Message)

func (*CancelJobRequest) XXX_Size Uses

func (m *CancelJobRequest) XXX_Size() int

func (*CancelJobRequest) XXX_Unmarshal Uses

func (m *CancelJobRequest) XXX_Unmarshal(b []byte) error

type Cluster Uses

type Cluster struct {
    // Required. The Google Cloud Platform project ID that the cluster belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The cluster name. Cluster names within a project must be
    // unique. Names of deleted clusters can be reused.
    ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    // Required. The cluster config. Note that Cloud Dataproc may set
    // default values, and values may change when clusters are updated.
    Config *ClusterConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
    // Optional. The labels to associate with this cluster.
    // Label **keys** must contain 1 to 63 characters, and must conform to
    // [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt).
    // Label **values** may be empty, but, if present, must contain 1 to 63
    // characters, and must conform to [RFC
    // 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be
    // associated with a cluster.
    Labels map[string]string `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Output only. Cluster status.
    Status *ClusterStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
    // Output only. The previous cluster status.
    StatusHistory []*ClusterStatus `protobuf:"bytes,7,rep,name=status_history,json=statusHistory,proto3" json:"status_history,omitempty"`
    // Output only. A cluster UUID (Unique Universal Identifier). Cloud Dataproc
    // generates this value when it creates the cluster.
    ClusterUuid string `protobuf:"bytes,6,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"`
    // Contains cluster daemon metrics such as HDFS and YARN stats.
    //
    // **Beta Feature**: This report is available for testing purposes only. It
    // may be changed before final release.
    Metrics              *ClusterMetrics `protobuf:"bytes,9,opt,name=metrics,proto3" json:"metrics,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

Describes the identifying information, config, and status of a cluster of Compute Engine instances.

func (*Cluster) Descriptor Uses

func (*Cluster) Descriptor() ([]byte, []int)

func (*Cluster) GetClusterName Uses

func (m *Cluster) GetClusterName() string

func (*Cluster) GetClusterUuid Uses

func (m *Cluster) GetClusterUuid() string

func (*Cluster) GetConfig Uses

func (m *Cluster) GetConfig() *ClusterConfig

func (*Cluster) GetLabels Uses

func (m *Cluster) GetLabels() map[string]string

func (*Cluster) GetMetrics Uses

func (m *Cluster) GetMetrics() *ClusterMetrics

func (*Cluster) GetProjectId Uses

func (m *Cluster) GetProjectId() string

func (*Cluster) GetStatus Uses

func (m *Cluster) GetStatus() *ClusterStatus

func (*Cluster) GetStatusHistory Uses

func (m *Cluster) GetStatusHistory() []*ClusterStatus

func (*Cluster) ProtoMessage Uses

func (*Cluster) ProtoMessage()

func (*Cluster) Reset Uses

func (m *Cluster) Reset()

func (*Cluster) String Uses

func (m *Cluster) String() string

func (*Cluster) XXX_DiscardUnknown Uses

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal Uses

func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cluster) XXX_Merge Uses

func (m *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size Uses

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal Uses

func (m *Cluster) XXX_Unmarshal(b []byte) error

type ClusterConfig Uses

type ClusterConfig struct {
    // Optional. A Google Cloud Storage bucket used to stage job
    // dependencies, config files, and job driver console output.
    // If you do not specify a staging bucket, Cloud
    // Dataproc will determine a Cloud Storage location (US,
    // ASIA, or EU) for your cluster's staging bucket according to the Google
    // Compute Engine zone where your cluster is deployed, and then create
    // and manage this project-level, per-location bucket (see
    // [Cloud Dataproc staging
    // bucket](/dataproc/docs/concepts/configuring-clusters/staging-bucket)).
    ConfigBucket string `protobuf:"bytes,1,opt,name=config_bucket,json=configBucket,proto3" json:"config_bucket,omitempty"`
    // Optional. The shared Compute Engine config settings for
    // all instances in a cluster.
    GceClusterConfig *GceClusterConfig `protobuf:"bytes,8,opt,name=gce_cluster_config,json=gceClusterConfig,proto3" json:"gce_cluster_config,omitempty"`
    // Optional. The Compute Engine config settings for
    // the master instance in a cluster.
    MasterConfig *InstanceGroupConfig `protobuf:"bytes,9,opt,name=master_config,json=masterConfig,proto3" json:"master_config,omitempty"`
    // Optional. The Compute Engine config settings for
    // worker instances in a cluster.
    WorkerConfig *InstanceGroupConfig `protobuf:"bytes,10,opt,name=worker_config,json=workerConfig,proto3" json:"worker_config,omitempty"`
    // Optional. The Compute Engine config settings for
    // additional worker instances in a cluster.
    SecondaryWorkerConfig *InstanceGroupConfig `protobuf:"bytes,12,opt,name=secondary_worker_config,json=secondaryWorkerConfig,proto3" json:"secondary_worker_config,omitempty"`
    // Optional. The config settings for software inside the cluster.
    SoftwareConfig *SoftwareConfig `protobuf:"bytes,13,opt,name=software_config,json=softwareConfig,proto3" json:"software_config,omitempty"`
    // Optional. Commands to execute on each node after config is
    // completed. By default, executables are run on master and all worker nodes.
    // You can test a node's `role` metadata to run an executable on
    // a master or worker node, as shown below using `curl` (you can also use
    // `wget`):
    //
    //     ROLE=$(curl -H Metadata-Flavor:Google
    //     http://metadata/computeMetadata/v1/instance/attributes/dataproc-role)
    //     if [[ "${ROLE}" == 'Master' ]]; then
    //       ... master specific actions ...
    //     else
    //       ... worker specific actions ...
    //     fi
    InitializationActions []*NodeInitializationAction `protobuf:"bytes,11,rep,name=initialization_actions,json=initializationActions,proto3" json:"initialization_actions,omitempty"`
    // Optional. Encryption settings for the cluster.
    EncryptionConfig     *EncryptionConfig `protobuf:"bytes,15,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

The cluster config.

func (*ClusterConfig) Descriptor Uses

func (*ClusterConfig) Descriptor() ([]byte, []int)

func (*ClusterConfig) GetConfigBucket Uses

func (m *ClusterConfig) GetConfigBucket() string

func (*ClusterConfig) GetEncryptionConfig Uses

func (m *ClusterConfig) GetEncryptionConfig() *EncryptionConfig

func (*ClusterConfig) GetGceClusterConfig Uses

func (m *ClusterConfig) GetGceClusterConfig() *GceClusterConfig

func (*ClusterConfig) GetInitializationActions Uses

func (m *ClusterConfig) GetInitializationActions() []*NodeInitializationAction

func (*ClusterConfig) GetMasterConfig Uses

func (m *ClusterConfig) GetMasterConfig() *InstanceGroupConfig

func (*ClusterConfig) GetSecondaryWorkerConfig Uses

func (m *ClusterConfig) GetSecondaryWorkerConfig() *InstanceGroupConfig

func (*ClusterConfig) GetSoftwareConfig Uses

func (m *ClusterConfig) GetSoftwareConfig() *SoftwareConfig

func (*ClusterConfig) GetWorkerConfig Uses

func (m *ClusterConfig) GetWorkerConfig() *InstanceGroupConfig

func (*ClusterConfig) ProtoMessage Uses

func (*ClusterConfig) ProtoMessage()

func (*ClusterConfig) Reset Uses

func (m *ClusterConfig) Reset()

func (*ClusterConfig) String Uses

func (m *ClusterConfig) String() string

func (*ClusterConfig) XXX_DiscardUnknown Uses

func (m *ClusterConfig) XXX_DiscardUnknown()

func (*ClusterConfig) XXX_Marshal Uses

func (m *ClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterConfig) XXX_Merge Uses

func (m *ClusterConfig) XXX_Merge(src proto.Message)

func (*ClusterConfig) XXX_Size Uses

func (m *ClusterConfig) XXX_Size() int

func (*ClusterConfig) XXX_Unmarshal Uses

func (m *ClusterConfig) XXX_Unmarshal(b []byte) error

type ClusterControllerClient Uses

type ClusterControllerClient interface {
    // Creates a cluster in a project.
    CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
    // Updates a cluster in a project.
    UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
    // Deletes a cluster in a project.
    DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
    // Gets the resource representation for a cluster in a project.
    GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
    // Lists all regions/{region}/clusters in a project.
    ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
    // Gets cluster diagnostic information.
    // After the operation completes, the Operation.response field
    // contains `DiagnoseClusterOutputLocation`.
    DiagnoseCluster(ctx context.Context, in *DiagnoseClusterRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
}

ClusterControllerClient is the client API for ClusterController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterControllerClient Uses

func NewClusterControllerClient(cc *grpc.ClientConn) ClusterControllerClient

type ClusterControllerServer Uses

type ClusterControllerServer interface {
    // Creates a cluster in a project.
    CreateCluster(context.Context, *CreateClusterRequest) (*longrunning.Operation, error)
    // Updates a cluster in a project.
    UpdateCluster(context.Context, *UpdateClusterRequest) (*longrunning.Operation, error)
    // Deletes a cluster in a project.
    DeleteCluster(context.Context, *DeleteClusterRequest) (*longrunning.Operation, error)
    // Gets the resource representation for a cluster in a project.
    GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
    // Lists all regions/{region}/clusters in a project.
    ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
    // Gets cluster diagnostic information.
    // After the operation completes, the Operation.response field
    // contains `DiagnoseClusterOutputLocation`.
    DiagnoseCluster(context.Context, *DiagnoseClusterRequest) (*longrunning.Operation, error)
}

ClusterControllerServer is the server API for ClusterController service.

type ClusterMetrics Uses

type ClusterMetrics struct {
    // The HDFS metrics.
    HdfsMetrics map[string]int64 `protobuf:"bytes,1,rep,name=hdfs_metrics,json=hdfsMetrics,proto3" json:"hdfs_metrics,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // The YARN metrics.
    YarnMetrics          map[string]int64 `protobuf:"bytes,2,rep,name=yarn_metrics,json=yarnMetrics,proto3" json:"yarn_metrics,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

Contains cluster daemon metrics, such as HDFS and YARN stats.

**Beta Feature**: This report is available for testing purposes only. It may be changed before final release.

func (*ClusterMetrics) Descriptor Uses

func (*ClusterMetrics) Descriptor() ([]byte, []int)

func (*ClusterMetrics) GetHdfsMetrics Uses

func (m *ClusterMetrics) GetHdfsMetrics() map[string]int64

func (*ClusterMetrics) GetYarnMetrics Uses

func (m *ClusterMetrics) GetYarnMetrics() map[string]int64

func (*ClusterMetrics) ProtoMessage Uses

func (*ClusterMetrics) ProtoMessage()

func (*ClusterMetrics) Reset Uses

func (m *ClusterMetrics) Reset()

func (*ClusterMetrics) String Uses

func (m *ClusterMetrics) String() string

func (*ClusterMetrics) XXX_DiscardUnknown Uses

func (m *ClusterMetrics) XXX_DiscardUnknown()

func (*ClusterMetrics) XXX_Marshal Uses

func (m *ClusterMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterMetrics) XXX_Merge Uses

func (m *ClusterMetrics) XXX_Merge(src proto.Message)

func (*ClusterMetrics) XXX_Size Uses

func (m *ClusterMetrics) XXX_Size() int

func (*ClusterMetrics) XXX_Unmarshal Uses

func (m *ClusterMetrics) XXX_Unmarshal(b []byte) error

type ClusterOperation Uses

type ClusterOperation struct {
    // Output only. The id of the cluster operation.
    OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
    // Output only. Error, if operation failed.
    Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    // Output only. Indicates the operation is done.
    Done                 bool     `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

The cluster operation triggered by a workflow.

func (*ClusterOperation) Descriptor Uses

func (*ClusterOperation) Descriptor() ([]byte, []int)

func (*ClusterOperation) GetDone Uses

func (m *ClusterOperation) GetDone() bool

func (*ClusterOperation) GetError Uses

func (m *ClusterOperation) GetError() string

func (*ClusterOperation) GetOperationId Uses

func (m *ClusterOperation) GetOperationId() string

func (*ClusterOperation) ProtoMessage Uses

func (*ClusterOperation) ProtoMessage()

func (*ClusterOperation) Reset Uses

func (m *ClusterOperation) Reset()

func (*ClusterOperation) String Uses

func (m *ClusterOperation) String() string

func (*ClusterOperation) XXX_DiscardUnknown Uses

func (m *ClusterOperation) XXX_DiscardUnknown()

func (*ClusterOperation) XXX_Marshal Uses

func (m *ClusterOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterOperation) XXX_Merge Uses

func (m *ClusterOperation) XXX_Merge(src proto.Message)

func (*ClusterOperation) XXX_Size Uses

func (m *ClusterOperation) XXX_Size() int

func (*ClusterOperation) XXX_Unmarshal Uses

func (m *ClusterOperation) XXX_Unmarshal(b []byte) error

type ClusterOperationMetadata Uses

type ClusterOperationMetadata struct {
    // Output only. Name of the cluster for the operation.
    ClusterName string `protobuf:"bytes,7,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    // Output only. Cluster UUID for the operation.
    ClusterUuid string `protobuf:"bytes,8,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"`
    // Output only. Current operation status.
    Status *ClusterOperationStatus `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
    // Output only. The previous operation status.
    StatusHistory []*ClusterOperationStatus `protobuf:"bytes,10,rep,name=status_history,json=statusHistory,proto3" json:"status_history,omitempty"`
    // Output only. The operation type.
    OperationType string `protobuf:"bytes,11,opt,name=operation_type,json=operationType,proto3" json:"operation_type,omitempty"`
    // Output only. Short description of operation.
    Description string `protobuf:"bytes,12,opt,name=description,proto3" json:"description,omitempty"`
    // Output only. Labels associated with the operation
    Labels map[string]string `protobuf:"bytes,13,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Output only. Errors encountered during operation execution.
    Warnings             []string `protobuf:"bytes,14,rep,name=warnings,proto3" json:"warnings,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Metadata describing the operation.

func (*ClusterOperationMetadata) Descriptor Uses

func (*ClusterOperationMetadata) Descriptor() ([]byte, []int)

func (*ClusterOperationMetadata) GetClusterName Uses

func (m *ClusterOperationMetadata) GetClusterName() string

func (*ClusterOperationMetadata) GetClusterUuid Uses

func (m *ClusterOperationMetadata) GetClusterUuid() string

func (*ClusterOperationMetadata) GetDescription Uses

func (m *ClusterOperationMetadata) GetDescription() string

func (*ClusterOperationMetadata) GetLabels Uses

func (m *ClusterOperationMetadata) GetLabels() map[string]string

func (*ClusterOperationMetadata) GetOperationType Uses

func (m *ClusterOperationMetadata) GetOperationType() string

func (*ClusterOperationMetadata) GetStatus Uses

func (m *ClusterOperationMetadata) GetStatus() *ClusterOperationStatus

func (*ClusterOperationMetadata) GetStatusHistory Uses

func (m *ClusterOperationMetadata) GetStatusHistory() []*ClusterOperationStatus

func (*ClusterOperationMetadata) GetWarnings Uses

func (m *ClusterOperationMetadata) GetWarnings() []string

func (*ClusterOperationMetadata) ProtoMessage Uses

func (*ClusterOperationMetadata) ProtoMessage()

func (*ClusterOperationMetadata) Reset Uses

func (m *ClusterOperationMetadata) Reset()

func (*ClusterOperationMetadata) String Uses

func (m *ClusterOperationMetadata) String() string

func (*ClusterOperationMetadata) XXX_DiscardUnknown Uses

func (m *ClusterOperationMetadata) XXX_DiscardUnknown()

func (*ClusterOperationMetadata) XXX_Marshal Uses

func (m *ClusterOperationMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterOperationMetadata) XXX_Merge Uses

func (m *ClusterOperationMetadata) XXX_Merge(src proto.Message)

func (*ClusterOperationMetadata) XXX_Size Uses

func (m *ClusterOperationMetadata) XXX_Size() int

func (*ClusterOperationMetadata) XXX_Unmarshal Uses

func (m *ClusterOperationMetadata) XXX_Unmarshal(b []byte) error

type ClusterOperationStatus Uses

type ClusterOperationStatus struct {
    // Output only. A message containing the operation state.
    State ClusterOperationStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.v1.ClusterOperationStatus_State" json:"state,omitempty"`
    // Output only. A message containing the detailed operation state.
    InnerState string `protobuf:"bytes,2,opt,name=inner_state,json=innerState,proto3" json:"inner_state,omitempty"`
    // Output only. A message containing any operation metadata details.
    Details string `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
    // Output only. The time this state was entered.
    StateStartTime       *timestamp.Timestamp `protobuf:"bytes,4,opt,name=state_start_time,json=stateStartTime,proto3" json:"state_start_time,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

The status of the operation.

func (*ClusterOperationStatus) Descriptor Uses

func (*ClusterOperationStatus) Descriptor() ([]byte, []int)

func (*ClusterOperationStatus) GetDetails Uses

func (m *ClusterOperationStatus) GetDetails() string

func (*ClusterOperationStatus) GetInnerState Uses

func (m *ClusterOperationStatus) GetInnerState() string

func (*ClusterOperationStatus) GetState Uses

func (m *ClusterOperationStatus) GetState() ClusterOperationStatus_State

func (*ClusterOperationStatus) GetStateStartTime Uses

func (m *ClusterOperationStatus) GetStateStartTime() *timestamp.Timestamp

func (*ClusterOperationStatus) ProtoMessage Uses

func (*ClusterOperationStatus) ProtoMessage()

func (*ClusterOperationStatus) Reset Uses

func (m *ClusterOperationStatus) Reset()

func (*ClusterOperationStatus) String Uses

func (m *ClusterOperationStatus) String() string

func (*ClusterOperationStatus) XXX_DiscardUnknown Uses

func (m *ClusterOperationStatus) XXX_DiscardUnknown()

func (*ClusterOperationStatus) XXX_Marshal Uses

func (m *ClusterOperationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterOperationStatus) XXX_Merge Uses

func (m *ClusterOperationStatus) XXX_Merge(src proto.Message)

func (*ClusterOperationStatus) XXX_Size Uses

func (m *ClusterOperationStatus) XXX_Size() int

func (*ClusterOperationStatus) XXX_Unmarshal Uses

func (m *ClusterOperationStatus) XXX_Unmarshal(b []byte) error

type ClusterOperationStatus_State Uses

type ClusterOperationStatus_State int32

The operation state.

const (
    // Unused.
    ClusterOperationStatus_UNKNOWN ClusterOperationStatus_State = 0
    // The operation has been created.
    ClusterOperationStatus_PENDING ClusterOperationStatus_State = 1
    // The operation is running.
    ClusterOperationStatus_RUNNING ClusterOperationStatus_State = 2
    // The operation is done; either cancelled or completed.
    ClusterOperationStatus_DONE ClusterOperationStatus_State = 3
)

func (ClusterOperationStatus_State) EnumDescriptor Uses

func (ClusterOperationStatus_State) EnumDescriptor() ([]byte, []int)

func (ClusterOperationStatus_State) String Uses

func (x ClusterOperationStatus_State) String() string

type ClusterSelector Uses

type ClusterSelector struct {
    // Optional. The zone where workflow process executes. This parameter does not
    // affect the selection of the cluster.
    //
    // If unspecified, the zone of the first cluster matching the selector
    // is used.
    Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
    // Required. The cluster labels. Cluster must have all labels
    // to match.
    ClusterLabels        map[string]string `protobuf:"bytes,2,rep,name=cluster_labels,json=clusterLabels,proto3" json:"cluster_labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

A selector that chooses target cluster for jobs based on metadata.

func (*ClusterSelector) Descriptor Uses

func (*ClusterSelector) Descriptor() ([]byte, []int)

func (*ClusterSelector) GetClusterLabels Uses

func (m *ClusterSelector) GetClusterLabels() map[string]string

func (*ClusterSelector) GetZone Uses

func (m *ClusterSelector) GetZone() string

func (*ClusterSelector) ProtoMessage Uses

func (*ClusterSelector) ProtoMessage()

func (*ClusterSelector) Reset Uses

func (m *ClusterSelector) Reset()

func (*ClusterSelector) String Uses

func (m *ClusterSelector) String() string

func (*ClusterSelector) XXX_DiscardUnknown Uses

func (m *ClusterSelector) XXX_DiscardUnknown()

func (*ClusterSelector) XXX_Marshal Uses

func (m *ClusterSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterSelector) XXX_Merge Uses

func (m *ClusterSelector) XXX_Merge(src proto.Message)

func (*ClusterSelector) XXX_Size Uses

func (m *ClusterSelector) XXX_Size() int

func (*ClusterSelector) XXX_Unmarshal Uses

func (m *ClusterSelector) XXX_Unmarshal(b []byte) error

type ClusterStatus Uses

type ClusterStatus struct {
    // Output only. The cluster's state.
    State ClusterStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.v1.ClusterStatus_State" json:"state,omitempty"`
    // Output only. Optional details of cluster's state.
    Detail string `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"`
    // Output only. Time when this state was entered.
    StateStartTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=state_start_time,json=stateStartTime,proto3" json:"state_start_time,omitempty"`
    // Output only. Additional state information that includes
    // status reported by the agent.
    Substate             ClusterStatus_Substate `protobuf:"varint,4,opt,name=substate,proto3,enum=google.cloud.dataproc.v1.ClusterStatus_Substate" json:"substate,omitempty"`
    XXX_NoUnkeyedLiteral struct{}               `json:"-"`
    XXX_unrecognized     []byte                 `json:"-"`
    XXX_sizecache        int32                  `json:"-"`
}

The status of a cluster and its instances.

func (*ClusterStatus) Descriptor Uses

func (*ClusterStatus) Descriptor() ([]byte, []int)

func (*ClusterStatus) GetDetail Uses

func (m *ClusterStatus) GetDetail() string

func (*ClusterStatus) GetState Uses

func (m *ClusterStatus) GetState() ClusterStatus_State

func (*ClusterStatus) GetStateStartTime Uses

func (m *ClusterStatus) GetStateStartTime() *timestamp.Timestamp

func (*ClusterStatus) GetSubstate Uses

func (m *ClusterStatus) GetSubstate() ClusterStatus_Substate

func (*ClusterStatus) ProtoMessage Uses

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) Reset Uses

func (m *ClusterStatus) Reset()

func (*ClusterStatus) String Uses

func (m *ClusterStatus) String() string

func (*ClusterStatus) XXX_DiscardUnknown Uses

func (m *ClusterStatus) XXX_DiscardUnknown()

func (*ClusterStatus) XXX_Marshal Uses

func (m *ClusterStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterStatus) XXX_Merge Uses

func (m *ClusterStatus) XXX_Merge(src proto.Message)

func (*ClusterStatus) XXX_Size Uses

func (m *ClusterStatus) XXX_Size() int

func (*ClusterStatus) XXX_Unmarshal Uses

func (m *ClusterStatus) XXX_Unmarshal(b []byte) error

type ClusterStatus_State Uses

type ClusterStatus_State int32

The cluster state.

const (
    // The cluster state is unknown.
    ClusterStatus_UNKNOWN ClusterStatus_State = 0
    // The cluster is being created and set up. It is not ready for use.
    ClusterStatus_CREATING ClusterStatus_State = 1
    // The cluster is currently running and healthy. It is ready for use.
    ClusterStatus_RUNNING ClusterStatus_State = 2
    // The cluster encountered an error. It is not ready for use.
    ClusterStatus_ERROR ClusterStatus_State = 3
    // The cluster is being deleted. It cannot be used.
    ClusterStatus_DELETING ClusterStatus_State = 4
    // The cluster is being updated. It continues to accept and process jobs.
    ClusterStatus_UPDATING ClusterStatus_State = 5
)

func (ClusterStatus_State) EnumDescriptor Uses

func (ClusterStatus_State) EnumDescriptor() ([]byte, []int)

func (ClusterStatus_State) String Uses

func (x ClusterStatus_State) String() string

type ClusterStatus_Substate Uses

type ClusterStatus_Substate int32

The cluster substate.

const (
    // The cluster substate is unknown.
    ClusterStatus_UNSPECIFIED ClusterStatus_Substate = 0
    // The cluster is known to be in an unhealthy state
    // (for example, critical daemons are not running or HDFS capacity is
    // exhausted).
    //
    // Applies to RUNNING state.
    ClusterStatus_UNHEALTHY ClusterStatus_Substate = 1
    // The agent-reported status is out of date (may occur if
    // Cloud Dataproc loses communication with Agent).
    //
    // Applies to RUNNING state.
    ClusterStatus_STALE_STATUS ClusterStatus_Substate = 2
)

func (ClusterStatus_Substate) EnumDescriptor Uses

func (ClusterStatus_Substate) EnumDescriptor() ([]byte, []int)

func (ClusterStatus_Substate) String Uses

func (x ClusterStatus_Substate) String() string

type Component Uses

type Component int32

Cluster components that can be activated.

const (
    // Unspecified component.
    Component_COMPONENT_UNSPECIFIED Component = 0
    // The Anaconda python distribution.
    Component_ANACONDA Component = 5
    // The Hive Web HCatalog (the REST service for accessing HCatalog).
    Component_HIVE_WEBHCAT Component = 3
    // The Jupyter Notebook.
    Component_JUPYTER Component = 1
    // The Zeppelin notebook.
    Component_ZEPPELIN Component = 4
)

func (Component) EnumDescriptor Uses

func (Component) EnumDescriptor() ([]byte, []int)

func (Component) String Uses

func (x Component) String() string

type CreateClusterRequest Uses

type CreateClusterRequest struct {
    // Required. The ID of the Google Cloud Platform project that the cluster
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The cluster to create.
    Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
    // Optional. A unique id used to identify the request. If the server
    // receives two [CreateClusterRequest][google.cloud.dataproc.v1.CreateClusterRequest] requests  with the same
    // id, then the second request will be ignored and the
    // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the backend
    // is returned.
    //
    // It is recommended to always set this value to a
    // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier).
    //
    // The id must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), and hyphens (-). The maximum length is 40 characters.
    RequestId            string   `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to create a cluster.

func (*CreateClusterRequest) Descriptor Uses

func (*CreateClusterRequest) Descriptor() ([]byte, []int)

func (*CreateClusterRequest) GetCluster Uses

func (m *CreateClusterRequest) GetCluster() *Cluster

func (*CreateClusterRequest) GetProjectId Uses

func (m *CreateClusterRequest) GetProjectId() string

func (*CreateClusterRequest) GetRegion Uses

func (m *CreateClusterRequest) GetRegion() string

func (*CreateClusterRequest) GetRequestId Uses

func (m *CreateClusterRequest) GetRequestId() string

func (*CreateClusterRequest) ProtoMessage Uses

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) Reset Uses

func (m *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String Uses

func (m *CreateClusterRequest) String() string

func (*CreateClusterRequest) XXX_DiscardUnknown Uses

func (m *CreateClusterRequest) XXX_DiscardUnknown()

func (*CreateClusterRequest) XXX_Marshal Uses

func (m *CreateClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateClusterRequest) XXX_Merge Uses

func (m *CreateClusterRequest) XXX_Merge(src proto.Message)

func (*CreateClusterRequest) XXX_Size Uses

func (m *CreateClusterRequest) XXX_Size() int

func (*CreateClusterRequest) XXX_Unmarshal Uses

func (m *CreateClusterRequest) XXX_Unmarshal(b []byte) error

type CreateWorkflowTemplateRequest Uses

type CreateWorkflowTemplateRequest struct {
    // Required. The "resource name" of the region, as described
    // in https://cloud.google.com/apis/design/resource_names of the form
    // `projects/{project_id}/regions/{region}`
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Required. The Dataproc workflow template to create.
    Template             *WorkflowTemplate `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

A request to create a workflow template.

func (*CreateWorkflowTemplateRequest) Descriptor Uses

func (*CreateWorkflowTemplateRequest) Descriptor() ([]byte, []int)

func (*CreateWorkflowTemplateRequest) GetParent Uses

func (m *CreateWorkflowTemplateRequest) GetParent() string

func (*CreateWorkflowTemplateRequest) GetTemplate Uses

func (m *CreateWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate

func (*CreateWorkflowTemplateRequest) ProtoMessage Uses

func (*CreateWorkflowTemplateRequest) ProtoMessage()

func (*CreateWorkflowTemplateRequest) Reset Uses

func (m *CreateWorkflowTemplateRequest) Reset()

func (*CreateWorkflowTemplateRequest) String Uses

func (m *CreateWorkflowTemplateRequest) String() string

func (*CreateWorkflowTemplateRequest) XXX_DiscardUnknown Uses

func (m *CreateWorkflowTemplateRequest) XXX_DiscardUnknown()

func (*CreateWorkflowTemplateRequest) XXX_Marshal Uses

func (m *CreateWorkflowTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWorkflowTemplateRequest) XXX_Merge Uses

func (m *CreateWorkflowTemplateRequest) XXX_Merge(src proto.Message)

func (*CreateWorkflowTemplateRequest) XXX_Size Uses

func (m *CreateWorkflowTemplateRequest) XXX_Size() int

func (*CreateWorkflowTemplateRequest) XXX_Unmarshal Uses

func (m *CreateWorkflowTemplateRequest) XXX_Unmarshal(b []byte) error

type DeleteClusterRequest Uses

type DeleteClusterRequest struct {
    // Required. The ID of the Google Cloud Platform project that the cluster
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The cluster name.
    ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    // Optional. Specifying the `cluster_uuid` means the RPC should fail
    // (with error NOT_FOUND) if cluster with specified UUID does not exist.
    ClusterUuid string `protobuf:"bytes,4,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"`
    // Optional. A unique id used to identify the request. If the server
    // receives two [DeleteClusterRequest][google.cloud.dataproc.v1.DeleteClusterRequest] requests  with the same
    // id, then the second request will be ignored and the
    // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the
    // backend is returned.
    //
    // It is recommended to always set this value to a
    // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier).
    //
    // The id must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), and hyphens (-). The maximum length is 40 characters.
    RequestId            string   `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to delete a cluster.

func (*DeleteClusterRequest) Descriptor Uses

func (*DeleteClusterRequest) Descriptor() ([]byte, []int)

func (*DeleteClusterRequest) GetClusterName Uses

func (m *DeleteClusterRequest) GetClusterName() string

func (*DeleteClusterRequest) GetClusterUuid Uses

func (m *DeleteClusterRequest) GetClusterUuid() string

func (*DeleteClusterRequest) GetProjectId Uses

func (m *DeleteClusterRequest) GetProjectId() string

func (*DeleteClusterRequest) GetRegion Uses

func (m *DeleteClusterRequest) GetRegion() string

func (*DeleteClusterRequest) GetRequestId Uses

func (m *DeleteClusterRequest) GetRequestId() string

func (*DeleteClusterRequest) ProtoMessage Uses

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) Reset Uses

func (m *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String Uses

func (m *DeleteClusterRequest) String() string

func (*DeleteClusterRequest) XXX_DiscardUnknown Uses

func (m *DeleteClusterRequest) XXX_DiscardUnknown()

func (*DeleteClusterRequest) XXX_Marshal Uses

func (m *DeleteClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteClusterRequest) XXX_Merge Uses

func (m *DeleteClusterRequest) XXX_Merge(src proto.Message)

func (*DeleteClusterRequest) XXX_Size Uses

func (m *DeleteClusterRequest) XXX_Size() int

func (*DeleteClusterRequest) XXX_Unmarshal Uses

func (m *DeleteClusterRequest) XXX_Unmarshal(b []byte) error

type DeleteJobRequest Uses

type DeleteJobRequest struct {
    // Required. The ID of the Google Cloud Platform project that the job
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The job ID.
    JobId                string   `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to delete a job.

func (*DeleteJobRequest) Descriptor Uses

func (*DeleteJobRequest) Descriptor() ([]byte, []int)

func (*DeleteJobRequest) GetJobId Uses

func (m *DeleteJobRequest) GetJobId() string

func (*DeleteJobRequest) GetProjectId Uses

func (m *DeleteJobRequest) GetProjectId() string

func (*DeleteJobRequest) GetRegion Uses

func (m *DeleteJobRequest) GetRegion() string

func (*DeleteJobRequest) ProtoMessage Uses

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) Reset Uses

func (m *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String Uses

func (m *DeleteJobRequest) String() string

func (*DeleteJobRequest) XXX_DiscardUnknown Uses

func (m *DeleteJobRequest) XXX_DiscardUnknown()

func (*DeleteJobRequest) XXX_Marshal Uses

func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteJobRequest) XXX_Merge Uses

func (m *DeleteJobRequest) XXX_Merge(src proto.Message)

func (*DeleteJobRequest) XXX_Size Uses

func (m *DeleteJobRequest) XXX_Size() int

func (*DeleteJobRequest) XXX_Unmarshal Uses

func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error

type DeleteWorkflowTemplateRequest Uses

type DeleteWorkflowTemplateRequest struct {
    // Required. The "resource name" of the workflow template, as described
    // in https://cloud.google.com/apis/design/resource_names of the form
    // `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Optional. The version of workflow template to delete. If specified,
    // will only delete the template if the current server version matches
    // specified version.
    Version              int32    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to delete a workflow template.

Currently started workflows will remain running.

func (*DeleteWorkflowTemplateRequest) Descriptor Uses

func (*DeleteWorkflowTemplateRequest) Descriptor() ([]byte, []int)

func (*DeleteWorkflowTemplateRequest) GetName Uses

func (m *DeleteWorkflowTemplateRequest) GetName() string

func (*DeleteWorkflowTemplateRequest) GetVersion Uses

func (m *DeleteWorkflowTemplateRequest) GetVersion() int32

func (*DeleteWorkflowTemplateRequest) ProtoMessage Uses

func (*DeleteWorkflowTemplateRequest) ProtoMessage()

func (*DeleteWorkflowTemplateRequest) Reset Uses

func (m *DeleteWorkflowTemplateRequest) Reset()

func (*DeleteWorkflowTemplateRequest) String Uses

func (m *DeleteWorkflowTemplateRequest) String() string

func (*DeleteWorkflowTemplateRequest) XXX_DiscardUnknown Uses

func (m *DeleteWorkflowTemplateRequest) XXX_DiscardUnknown()

func (*DeleteWorkflowTemplateRequest) XXX_Marshal Uses

func (m *DeleteWorkflowTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteWorkflowTemplateRequest) XXX_Merge Uses

func (m *DeleteWorkflowTemplateRequest) XXX_Merge(src proto.Message)

func (*DeleteWorkflowTemplateRequest) XXX_Size Uses

func (m *DeleteWorkflowTemplateRequest) XXX_Size() int

func (*DeleteWorkflowTemplateRequest) XXX_Unmarshal Uses

func (m *DeleteWorkflowTemplateRequest) XXX_Unmarshal(b []byte) error

type DiagnoseClusterRequest Uses

type DiagnoseClusterRequest struct {
    // Required. The ID of the Google Cloud Platform project that the cluster
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The cluster name.
    ClusterName          string   `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to collect cluster diagnostic information.

func (*DiagnoseClusterRequest) Descriptor Uses

func (*DiagnoseClusterRequest) Descriptor() ([]byte, []int)

func (*DiagnoseClusterRequest) GetClusterName Uses

func (m *DiagnoseClusterRequest) GetClusterName() string

func (*DiagnoseClusterRequest) GetProjectId Uses

func (m *DiagnoseClusterRequest) GetProjectId() string

func (*DiagnoseClusterRequest) GetRegion Uses

func (m *DiagnoseClusterRequest) GetRegion() string

func (*DiagnoseClusterRequest) ProtoMessage Uses

func (*DiagnoseClusterRequest) ProtoMessage()

func (*DiagnoseClusterRequest) Reset Uses

func (m *DiagnoseClusterRequest) Reset()

func (*DiagnoseClusterRequest) String Uses

func (m *DiagnoseClusterRequest) String() string

func (*DiagnoseClusterRequest) XXX_DiscardUnknown Uses

func (m *DiagnoseClusterRequest) XXX_DiscardUnknown()

func (*DiagnoseClusterRequest) XXX_Marshal Uses

func (m *DiagnoseClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiagnoseClusterRequest) XXX_Merge Uses

func (m *DiagnoseClusterRequest) XXX_Merge(src proto.Message)

func (*DiagnoseClusterRequest) XXX_Size Uses

func (m *DiagnoseClusterRequest) XXX_Size() int

func (*DiagnoseClusterRequest) XXX_Unmarshal Uses

func (m *DiagnoseClusterRequest) XXX_Unmarshal(b []byte) error

type DiagnoseClusterResults Uses

type DiagnoseClusterResults struct {
    // Output only. The Cloud Storage URI of the diagnostic output.
    // The output report is a plain text file with a summary of collected
    // diagnostics.
    OutputUri            string   `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3" json:"output_uri,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

The location of diagnostic output.

func (*DiagnoseClusterResults) Descriptor Uses

func (*DiagnoseClusterResults) Descriptor() ([]byte, []int)

func (*DiagnoseClusterResults) GetOutputUri Uses

func (m *DiagnoseClusterResults) GetOutputUri() string

func (*DiagnoseClusterResults) ProtoMessage Uses

func (*DiagnoseClusterResults) ProtoMessage()

func (*DiagnoseClusterResults) Reset Uses

func (m *DiagnoseClusterResults) Reset()

func (*DiagnoseClusterResults) String Uses

func (m *DiagnoseClusterResults) String() string

func (*DiagnoseClusterResults) XXX_DiscardUnknown Uses

func (m *DiagnoseClusterResults) XXX_DiscardUnknown()

func (*DiagnoseClusterResults) XXX_Marshal Uses

func (m *DiagnoseClusterResults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiagnoseClusterResults) XXX_Merge Uses

func (m *DiagnoseClusterResults) XXX_Merge(src proto.Message)

func (*DiagnoseClusterResults) XXX_Size Uses

func (m *DiagnoseClusterResults) XXX_Size() int

func (*DiagnoseClusterResults) XXX_Unmarshal Uses

func (m *DiagnoseClusterResults) XXX_Unmarshal(b []byte) error

type DiskConfig Uses

type DiskConfig struct {
    // 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).
    BootDiskType string `protobuf:"bytes,3,opt,name=boot_disk_type,json=bootDiskType,proto3" json:"boot_disk_type,omitempty"`
    // Optional. Size in GB of the boot disk (default is 500GB).
    BootDiskSizeGb int32 `protobuf:"varint,1,opt,name=boot_disk_size_gb,json=bootDiskSizeGb,proto3" json:"boot_disk_size_gb,omitempty"`
    // 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 attached, this runtime bulk
    // data is spread across them, and the boot disk contains only basic
    // config and installed binaries.
    NumLocalSsds         int32    `protobuf:"varint,2,opt,name=num_local_ssds,json=numLocalSsds,proto3" json:"num_local_ssds,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Specifies the config of disk options for a group of VM instances.

func (*DiskConfig) Descriptor Uses

func (*DiskConfig) Descriptor() ([]byte, []int)

func (*DiskConfig) GetBootDiskSizeGb Uses

func (m *DiskConfig) GetBootDiskSizeGb() int32

func (*DiskConfig) GetBootDiskType Uses

func (m *DiskConfig) GetBootDiskType() string

func (*DiskConfig) GetNumLocalSsds Uses

func (m *DiskConfig) GetNumLocalSsds() int32

func (*DiskConfig) ProtoMessage Uses

func (*DiskConfig) ProtoMessage()

func (*DiskConfig) Reset Uses

func (m *DiskConfig) Reset()

func (*DiskConfig) String Uses

func (m *DiskConfig) String() string

func (*DiskConfig) XXX_DiscardUnknown Uses

func (m *DiskConfig) XXX_DiscardUnknown()

func (*DiskConfig) XXX_Marshal Uses

func (m *DiskConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiskConfig) XXX_Merge Uses

func (m *DiskConfig) XXX_Merge(src proto.Message)

func (*DiskConfig) XXX_Size Uses

func (m *DiskConfig) XXX_Size() int

func (*DiskConfig) XXX_Unmarshal Uses

func (m *DiskConfig) XXX_Unmarshal(b []byte) error

type EncryptionConfig Uses

type EncryptionConfig struct {
    // Optional. The Cloud KMS key name to use for PD disk encryption for all
    // instances in the cluster.
    GcePdKmsKeyName      string   `protobuf:"bytes,1,opt,name=gce_pd_kms_key_name,json=gcePdKmsKeyName,proto3" json:"gce_pd_kms_key_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Encryption settings for the cluster.

func (*EncryptionConfig) Descriptor Uses

func (*EncryptionConfig) Descriptor() ([]byte, []int)

func (*EncryptionConfig) GetGcePdKmsKeyName Uses

func (m *EncryptionConfig) GetGcePdKmsKeyName() string

func (*EncryptionConfig) ProtoMessage Uses

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) Reset Uses

func (m *EncryptionConfig) Reset()

func (*EncryptionConfig) String Uses

func (m *EncryptionConfig) String() string

func (*EncryptionConfig) XXX_DiscardUnknown Uses

func (m *EncryptionConfig) XXX_DiscardUnknown()

func (*EncryptionConfig) XXX_Marshal Uses

func (m *EncryptionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EncryptionConfig) XXX_Merge Uses

func (m *EncryptionConfig) XXX_Merge(src proto.Message)

func (*EncryptionConfig) XXX_Size Uses

func (m *EncryptionConfig) XXX_Size() int

func (*EncryptionConfig) XXX_Unmarshal Uses

func (m *EncryptionConfig) XXX_Unmarshal(b []byte) error

type GceClusterConfig Uses

type GceClusterConfig struct {
    // Optional. The zone where the Compute Engine cluster will be located.
    // On a create request, it is required in the "global" region. If omitted
    // in a non-global Cloud Dataproc region, the service will pick a zone in the
    // corresponding Compute Engine region. On a get request, zone will
    // always be present.
    //
    // A full URL, partial URI, or short name are valid. Examples:
    //
    // * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]`
    // * `projects/[project_id]/zones/[zone]`
    // * `us-central1-f`
    ZoneUri string `protobuf:"bytes,1,opt,name=zone_uri,json=zoneUri,proto3" json:"zone_uri,omitempty"`
    // Optional. The Compute Engine network to be used for machine
    // communications. Cannot be specified with subnetwork_uri. If neither
    // `network_uri` nor `subnetwork_uri` is specified, the "default" network of
    // the project is used, if it exists. Cannot be a "Custom Subnet Network" (see
    // [Using Subnetworks](/compute/docs/subnetworks) for more information).
    //
    // A full URL, partial URI, or short name are valid. Examples:
    //
    // * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/default`
    // * `projects/[project_id]/regions/global/default`
    // * `default`
    NetworkUri string `protobuf:"bytes,2,opt,name=network_uri,json=networkUri,proto3" json:"network_uri,omitempty"`
    // Optional. The Compute Engine subnetwork to be used for machine
    // communications. Cannot be specified with network_uri.
    //
    // A full URL, partial URI, or short name are valid. Examples:
    //
    // * `https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east1/subnetworks/sub0`
    // * `projects/[project_id]/regions/us-east1/subnetworks/sub0`
    // * `sub0`
    SubnetworkUri string `protobuf:"bytes,6,opt,name=subnetwork_uri,json=subnetworkUri,proto3" json:"subnetwork_uri,omitempty"`
    // Optional. If true, all instances in the cluster will only have internal IP
    // addresses. By default, clusters are not restricted to internal IP
    // addresses, and will have ephemeral external IP addresses assigned to each
    // instance. This `internal_ip_only` restriction can only be enabled for
    // subnetwork enabled networks, and all off-cluster dependencies must be
    // configured to be accessible without external IP addresses.
    InternalIpOnly bool `protobuf:"varint,7,opt,name=internal_ip_only,json=internalIpOnly,proto3" json:"internal_ip_only,omitempty"`
    // Optional. The service account of the instances. Defaults to the default
    // Compute Engine service account. Custom service accounts need
    // permissions equivalent to the following IAM roles:
    //
    // * roles/logging.logWriter
    // * roles/storage.objectAdmin
    //
    // (see
    // https://cloud.google.com/compute/docs/access/service-accounts#custom_service_accounts
    // for more information).
    // Example: `[account_id]@[project_id].iam.gserviceaccount.com`
    ServiceAccount string `protobuf:"bytes,8,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
    // Optional. The URIs of service account scopes to be included in
    // Compute Engine instances. The following base set of scopes is always
    // included:
    //
    // * https://www.googleapis.com/auth/cloud.useraccounts.readonly
    // * https://www.googleapis.com/auth/devstorage.read_write
    // * https://www.googleapis.com/auth/logging.write
    //
    // If no scopes are specified, the following defaults are also provided:
    //
    // * https://www.googleapis.com/auth/bigquery
    // * https://www.googleapis.com/auth/bigtable.admin.table
    // * https://www.googleapis.com/auth/bigtable.data
    // * https://www.googleapis.com/auth/devstorage.full_control
    ServiceAccountScopes []string `protobuf:"bytes,3,rep,name=service_account_scopes,json=serviceAccountScopes,proto3" json:"service_account_scopes,omitempty"`
    // The Compute Engine tags to add to all instances (see
    // [Tagging instances](/compute/docs/label-or-tag-resources#tags)).
    Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
    // The Compute Engine metadata entries to add to all instances (see
    // [Project and instance
    // metadata](https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_and_instance_metadata)).
    Metadata             map[string]string `protobuf:"bytes,5,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

Common config settings for resources of Compute Engine cluster instances, applicable to all instances in the cluster.

func (*GceClusterConfig) Descriptor Uses

func (*GceClusterConfig) Descriptor() ([]byte, []int)

func (*GceClusterConfig) GetInternalIpOnly Uses

func (m *GceClusterConfig) GetInternalIpOnly() bool

func (*GceClusterConfig) GetMetadata Uses

func (m *GceClusterConfig) GetMetadata() map[string]string

func (*GceClusterConfig) GetNetworkUri Uses

func (m *GceClusterConfig) GetNetworkUri() string

func (*GceClusterConfig) GetServiceAccount Uses

func (m *GceClusterConfig) GetServiceAccount() string

func (*GceClusterConfig) GetServiceAccountScopes Uses

func (m *GceClusterConfig) GetServiceAccountScopes() []string

func (*GceClusterConfig) GetSubnetworkUri Uses

func (m *GceClusterConfig) GetSubnetworkUri() string

func (*GceClusterConfig) GetTags Uses

func (m *GceClusterConfig) GetTags() []string

func (*GceClusterConfig) GetZoneUri Uses

func (m *GceClusterConfig) GetZoneUri() string

func (*GceClusterConfig) ProtoMessage Uses

func (*GceClusterConfig) ProtoMessage()

func (*GceClusterConfig) Reset Uses

func (m *GceClusterConfig) Reset()

func (*GceClusterConfig) String Uses

func (m *GceClusterConfig) String() string

func (*GceClusterConfig) XXX_DiscardUnknown Uses

func (m *GceClusterConfig) XXX_DiscardUnknown()

func (*GceClusterConfig) XXX_Marshal Uses

func (m *GceClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GceClusterConfig) XXX_Merge Uses

func (m *GceClusterConfig) XXX_Merge(src proto.Message)

func (*GceClusterConfig) XXX_Size Uses

func (m *GceClusterConfig) XXX_Size() int

func (*GceClusterConfig) XXX_Unmarshal Uses

func (m *GceClusterConfig) XXX_Unmarshal(b []byte) error

type GetClusterRequest Uses

type GetClusterRequest struct {
    // Required. The ID of the Google Cloud Platform project that the cluster
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The cluster name.
    ClusterName          string   `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Request to get the resource representation for a cluster in a project.

func (*GetClusterRequest) Descriptor Uses

func (*GetClusterRequest) Descriptor() ([]byte, []int)

func (*GetClusterRequest) GetClusterName Uses

func (m *GetClusterRequest) GetClusterName() string

func (*GetClusterRequest) GetProjectId Uses

func (m *GetClusterRequest) GetProjectId() string

func (*GetClusterRequest) GetRegion Uses

func (m *GetClusterRequest) GetRegion() string

func (*GetClusterRequest) ProtoMessage Uses

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) Reset Uses

func (m *GetClusterRequest) Reset()

func (*GetClusterRequest) String Uses

func (m *GetClusterRequest) String() string

func (*GetClusterRequest) XXX_DiscardUnknown Uses

func (m *GetClusterRequest) XXX_DiscardUnknown()

func (*GetClusterRequest) XXX_Marshal Uses

func (m *GetClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterRequest) XXX_Merge Uses

func (m *GetClusterRequest) XXX_Merge(src proto.Message)

func (*GetClusterRequest) XXX_Size Uses

func (m *GetClusterRequest) XXX_Size() int

func (*GetClusterRequest) XXX_Unmarshal Uses

func (m *GetClusterRequest) XXX_Unmarshal(b []byte) error

type GetJobRequest Uses

type GetJobRequest struct {
    // Required. The ID of the Google Cloud Platform project that the job
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The job ID.
    JobId                string   `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to get the resource representation for a job in a project.

func (*GetJobRequest) Descriptor Uses

func (*GetJobRequest) Descriptor() ([]byte, []int)

func (*GetJobRequest) GetJobId Uses

func (m *GetJobRequest) GetJobId() string

func (*GetJobRequest) GetProjectId Uses

func (m *GetJobRequest) GetProjectId() string

func (*GetJobRequest) GetRegion Uses

func (m *GetJobRequest) GetRegion() string

func (*GetJobRequest) ProtoMessage Uses

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset Uses

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String Uses

func (m *GetJobRequest) String() string

func (*GetJobRequest) XXX_DiscardUnknown Uses

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal Uses

func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobRequest) XXX_Merge Uses

func (m *GetJobRequest) XXX_Merge(src proto.Message)

func (*GetJobRequest) XXX_Size Uses

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal Uses

func (m *GetJobRequest) XXX_Unmarshal(b []byte) error

type GetWorkflowTemplateRequest Uses

type GetWorkflowTemplateRequest struct {
    // Required. The "resource name" of the workflow template, as described
    // in https://cloud.google.com/apis/design/resource_names of the form
    // `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Optional. The version of workflow template to retrieve. Only previously
    // instatiated versions can be retrieved.
    //
    // If unspecified, retrieves the current version.
    Version              int32    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to fetch a workflow template.

func (*GetWorkflowTemplateRequest) Descriptor Uses

func (*GetWorkflowTemplateRequest) Descriptor() ([]byte, []int)

func (*GetWorkflowTemplateRequest) GetName Uses

func (m *GetWorkflowTemplateRequest) GetName() string

func (*GetWorkflowTemplateRequest) GetVersion Uses

func (m *GetWorkflowTemplateRequest) GetVersion() int32

func (*GetWorkflowTemplateRequest) ProtoMessage Uses

func (*GetWorkflowTemplateRequest) ProtoMessage()

func (*GetWorkflowTemplateRequest) Reset Uses

func (m *GetWorkflowTemplateRequest) Reset()

func (*GetWorkflowTemplateRequest) String Uses

func (m *GetWorkflowTemplateRequest) String() string

func (*GetWorkflowTemplateRequest) XXX_DiscardUnknown Uses

func (m *GetWorkflowTemplateRequest) XXX_DiscardUnknown()

func (*GetWorkflowTemplateRequest) XXX_Marshal Uses

func (m *GetWorkflowTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkflowTemplateRequest) XXX_Merge Uses

func (m *GetWorkflowTemplateRequest) XXX_Merge(src proto.Message)

func (*GetWorkflowTemplateRequest) XXX_Size Uses

func (m *GetWorkflowTemplateRequest) XXX_Size() int

func (*GetWorkflowTemplateRequest) XXX_Unmarshal Uses

func (m *GetWorkflowTemplateRequest) XXX_Unmarshal(b []byte) error

type HadoopJob Uses

type HadoopJob struct {
    // Required. Indicates the location of the driver's main class. Specify
    // either the jar file that contains the main class or the main class name.
    // To specify both, add the jar file to `jar_file_uris`, and then specify
    // the main class name in this property.
    //
    // Types that are valid to be assigned to Driver:
    //	*HadoopJob_MainJarFileUri
    //	*HadoopJob_MainClass
    Driver isHadoopJob_Driver `protobuf_oneof:"driver"`
    // Optional. The arguments to pass to the driver. Do not
    // include arguments, such as `-libjars` or `-Dfoo=bar`, that can be set as
    // job properties, since a collision may occur that causes an incorrect job
    // submission.
    Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
    // Optional. Jar file URIs to add to the CLASSPATHs of the
    // Hadoop driver and tasks.
    JarFileUris []string `protobuf:"bytes,4,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"`
    // Optional. HCFS (Hadoop Compatible Filesystem) URIs of files to be copied
    // to the working directory of Hadoop drivers and distributed tasks. Useful
    // for naively parallel tasks.
    FileUris []string `protobuf:"bytes,5,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"`
    // Optional. HCFS URIs of archives to be extracted in the working directory of
    // Hadoop drivers and tasks. Supported file types:
    // .jar, .tar, .tar.gz, .tgz, or .zip.
    ArchiveUris []string `protobuf:"bytes,6,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"`
    // Optional. A mapping of property names to values, used to configure Hadoop.
    // Properties that conflict with values set by the Cloud Dataproc API may be
    // overwritten. Can include properties set in /etc/hadoop/conf/*-site and
    // classes in user code.
    Properties map[string]string `protobuf:"bytes,7,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. The runtime log config for job execution.
    LoggingConfig        *LoggingConfig `protobuf:"bytes,8,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

A Cloud Dataproc job for running [Apache Hadoop MapReduce](https://hadoop.apache.org/docs/current/hadoop-mapreduce-client/hadoop-mapreduce-client-core/MapReduceTutorial.html) jobs on [Apache Hadoop YARN](https://hadoop.apache.org/docs/r2.7.1/hadoop-yarn/hadoop-yarn-site/YARN.html).

func (*HadoopJob) Descriptor Uses

func (*HadoopJob) Descriptor() ([]byte, []int)

func (*HadoopJob) GetArchiveUris Uses

func (m *HadoopJob) GetArchiveUris() []string

func (*HadoopJob) GetArgs Uses

func (m *HadoopJob) GetArgs() []string

func (*HadoopJob) GetDriver Uses

func (m *HadoopJob) GetDriver() isHadoopJob_Driver

func (*HadoopJob) GetFileUris Uses

func (m *HadoopJob) GetFileUris() []string

func (*HadoopJob) GetJarFileUris Uses

func (m *HadoopJob) GetJarFileUris() []string

func (*HadoopJob) GetLoggingConfig Uses

func (m *HadoopJob) GetLoggingConfig() *LoggingConfig

func (*HadoopJob) GetMainClass Uses

func (m *HadoopJob) GetMainClass() string

func (*HadoopJob) GetMainJarFileUri Uses

func (m *HadoopJob) GetMainJarFileUri() string

func (*HadoopJob) GetProperties Uses

func (m *HadoopJob) GetProperties() map[string]string

func (*HadoopJob) ProtoMessage Uses

func (*HadoopJob) ProtoMessage()

func (*HadoopJob) Reset Uses

func (m *HadoopJob) Reset()

func (*HadoopJob) String Uses

func (m *HadoopJob) String() string

func (*HadoopJob) XXX_DiscardUnknown Uses

func (m *HadoopJob) XXX_DiscardUnknown()

func (*HadoopJob) XXX_Marshal Uses

func (m *HadoopJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HadoopJob) XXX_Merge Uses

func (m *HadoopJob) XXX_Merge(src proto.Message)

func (*HadoopJob) XXX_OneofWrappers Uses

func (*HadoopJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*HadoopJob) XXX_Size Uses

func (m *HadoopJob) XXX_Size() int

func (*HadoopJob) XXX_Unmarshal Uses

func (m *HadoopJob) XXX_Unmarshal(b []byte) error

type HadoopJob_MainClass Uses

type HadoopJob_MainClass struct {
    MainClass string `protobuf:"bytes,2,opt,name=main_class,json=mainClass,proto3,oneof"`
}

type HadoopJob_MainJarFileUri Uses

type HadoopJob_MainJarFileUri struct {
    MainJarFileUri string `protobuf:"bytes,1,opt,name=main_jar_file_uri,json=mainJarFileUri,proto3,oneof"`
}

type HiveJob Uses

type HiveJob struct {
    // Required. The sequence of Hive queries to execute, specified as either
    // an HCFS file URI or a list of queries.
    //
    // Types that are valid to be assigned to Queries:
    //	*HiveJob_QueryFileUri
    //	*HiveJob_QueryList
    Queries isHiveJob_Queries `protobuf_oneof:"queries"`
    // Optional. Whether to continue executing queries if a query fails.
    // The default value is `false`. Setting to `true` can be useful when
    // executing independent parallel queries.
    ContinueOnFailure bool `protobuf:"varint,3,opt,name=continue_on_failure,json=continueOnFailure,proto3" json:"continue_on_failure,omitempty"`
    // Optional. Mapping of query variable names to values (equivalent to the
    // Hive command: `SET name="value";`).
    ScriptVariables map[string]string `protobuf:"bytes,4,rep,name=script_variables,json=scriptVariables,proto3" json:"script_variables,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. A mapping of property names and values, used to configure Hive.
    // Properties that conflict with values set by the Cloud Dataproc API may be
    // overwritten. Can include properties set in /etc/hadoop/conf/*-site.xml,
    // /etc/hive/conf/hive-site.xml, and classes in user code.
    Properties map[string]string `protobuf:"bytes,5,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. HCFS URIs of jar files to add to the CLASSPATH of the
    // Hive server and Hadoop MapReduce (MR) tasks. Can contain Hive SerDes
    // and UDFs.
    JarFileUris          []string `protobuf:"bytes,6,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A Cloud Dataproc job for running [Apache Hive](https://hive.apache.org/) queries on YARN.

func (*HiveJob) Descriptor Uses

func (*HiveJob) Descriptor() ([]byte, []int)

func (*HiveJob) GetContinueOnFailure Uses

func (m *HiveJob) GetContinueOnFailure() bool

func (*HiveJob) GetJarFileUris Uses

func (m *HiveJob) GetJarFileUris() []string

func (*HiveJob) GetProperties Uses

func (m *HiveJob) GetProperties() map[string]string

func (*HiveJob) GetQueries Uses

func (m *HiveJob) GetQueries() isHiveJob_Queries

func (*HiveJob) GetQueryFileUri Uses

func (m *HiveJob) GetQueryFileUri() string

func (*HiveJob) GetQueryList Uses

func (m *HiveJob) GetQueryList() *QueryList

func (*HiveJob) GetScriptVariables Uses

func (m *HiveJob) GetScriptVariables() map[string]string

func (*HiveJob) ProtoMessage Uses

func (*HiveJob) ProtoMessage()

func (*HiveJob) Reset Uses

func (m *HiveJob) Reset()

func (*HiveJob) String Uses

func (m *HiveJob) String() string

func (*HiveJob) XXX_DiscardUnknown Uses

func (m *HiveJob) XXX_DiscardUnknown()

func (*HiveJob) XXX_Marshal Uses

func (m *HiveJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HiveJob) XXX_Merge Uses

func (m *HiveJob) XXX_Merge(src proto.Message)

func (*HiveJob) XXX_OneofWrappers Uses

func (*HiveJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*HiveJob) XXX_Size Uses

func (m *HiveJob) XXX_Size() int

func (*HiveJob) XXX_Unmarshal Uses

func (m *HiveJob) XXX_Unmarshal(b []byte) error

type HiveJob_QueryFileUri Uses

type HiveJob_QueryFileUri struct {
    QueryFileUri string `protobuf:"bytes,1,opt,name=query_file_uri,json=queryFileUri,proto3,oneof"`
}

type HiveJob_QueryList Uses

type HiveJob_QueryList struct {
    QueryList *QueryList `protobuf:"bytes,2,opt,name=query_list,json=queryList,proto3,oneof"`
}

type InstanceGroupConfig Uses

type InstanceGroupConfig struct {
    // Optional. The number of VM instances in the instance group.
    // For master instance groups, must be set to 1.
    NumInstances int32 `protobuf:"varint,1,opt,name=num_instances,json=numInstances,proto3" json:"num_instances,omitempty"`
    // Output only. The list of instance names. Cloud Dataproc derives the names
    // from `cluster_name`, `num_instances`, and the instance group.
    InstanceNames []string `protobuf:"bytes,2,rep,name=instance_names,json=instanceNames,proto3" json:"instance_names,omitempty"`
    // Optional. The Compute Engine image resource used for cluster
    // instances. It can be specified or may be inferred from
    // `SoftwareConfig.image_version`.
    ImageUri string `protobuf:"bytes,3,opt,name=image_uri,json=imageUri,proto3" json:"image_uri,omitempty"`
    // Optional. The Compute Engine machine type used for cluster instances.
    //
    // A full URL, partial URI, or short name are valid. Examples:
    //
    // * `https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2`
    // * `projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2`
    // * `n1-standard-2`
    //
    // **Auto Zone Exception**: If you are using the Cloud Dataproc
    // [Auto Zone
    // Placement](/dataproc/docs/concepts/configuring-clusters/auto-zone#using_auto_zone_placement)
    // feature, you must use the short name of the machine type
    // resource, for example, `n1-standard-2`.
    MachineTypeUri string `protobuf:"bytes,4,opt,name=machine_type_uri,json=machineTypeUri,proto3" json:"machine_type_uri,omitempty"`
    // Optional. Disk option config settings.
    DiskConfig *DiskConfig `protobuf:"bytes,5,opt,name=disk_config,json=diskConfig,proto3" json:"disk_config,omitempty"`
    // Optional. Specifies that this instance group contains preemptible
    // instances.
    IsPreemptible bool `protobuf:"varint,6,opt,name=is_preemptible,json=isPreemptible,proto3" json:"is_preemptible,omitempty"`
    // Output only. The config for Compute Engine Instance Group
    // Manager that manages this group.
    // This is only used for preemptible instance groups.
    ManagedGroupConfig *ManagedGroupConfig `protobuf:"bytes,7,opt,name=managed_group_config,json=managedGroupConfig,proto3" json:"managed_group_config,omitempty"`
    // Optional. The Compute Engine accelerator configuration for these
    // instances.
    //
    // **Beta Feature**: This feature is still under development. It may be
    // changed before final release.
    Accelerators         []*AcceleratorConfig `protobuf:"bytes,8,rep,name=accelerators,proto3" json:"accelerators,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

Optional. The config settings for Compute Engine resources in an instance group, such as a master or worker group.

func (*InstanceGroupConfig) Descriptor Uses

func (*InstanceGroupConfig) Descriptor() ([]byte, []int)

func (*InstanceGroupConfig) GetAccelerators Uses

func (m *InstanceGroupConfig) GetAccelerators() []*AcceleratorConfig

func (*InstanceGroupConfig) GetDiskConfig Uses

func (m *InstanceGroupConfig) GetDiskConfig() *DiskConfig

func (*InstanceGroupConfig) GetImageUri Uses

func (m *InstanceGroupConfig) GetImageUri() string

func (*InstanceGroupConfig) GetInstanceNames Uses

func (m *InstanceGroupConfig) GetInstanceNames() []string

func (*InstanceGroupConfig) GetIsPreemptible Uses

func (m *InstanceGroupConfig) GetIsPreemptible() bool

func (*InstanceGroupConfig) GetMachineTypeUri Uses

func (m *InstanceGroupConfig) GetMachineTypeUri() string

func (*InstanceGroupConfig) GetManagedGroupConfig Uses

func (m *InstanceGroupConfig) GetManagedGroupConfig() *ManagedGroupConfig

func (*InstanceGroupConfig) GetNumInstances Uses

func (m *InstanceGroupConfig) GetNumInstances() int32

func (*InstanceGroupConfig) ProtoMessage Uses

func (*InstanceGroupConfig) ProtoMessage()

func (*InstanceGroupConfig) Reset Uses

func (m *InstanceGroupConfig) Reset()

func (*InstanceGroupConfig) String Uses

func (m *InstanceGroupConfig) String() string

func (*InstanceGroupConfig) XXX_DiscardUnknown Uses

func (m *InstanceGroupConfig) XXX_DiscardUnknown()

func (*InstanceGroupConfig) XXX_Marshal Uses

func (m *InstanceGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceGroupConfig) XXX_Merge Uses

func (m *InstanceGroupConfig) XXX_Merge(src proto.Message)

func (*InstanceGroupConfig) XXX_Size Uses

func (m *InstanceGroupConfig) XXX_Size() int

func (*InstanceGroupConfig) XXX_Unmarshal Uses

func (m *InstanceGroupConfig) XXX_Unmarshal(b []byte) error

type InstantiateInlineWorkflowTemplateRequest Uses

type InstantiateInlineWorkflowTemplateRequest struct {
    // Required. The "resource name" of the workflow template region, as described
    // in https://cloud.google.com/apis/design/resource_names of the form
    // `projects/{project_id}/regions/{region}`
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Required. The workflow template to instantiate.
    Template *WorkflowTemplate `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
    // Optional. A tag that prevents multiple concurrent workflow
    // instances with the same tag from running. This mitigates risk of
    // concurrent instances started due to retries.
    //
    // It is recommended to always set this value to a
    // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier).
    //
    // The tag must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), and hyphens (-). The maximum length is 40 characters.
    RequestId            string   `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to instantiate an inline workflow template.

func (*InstantiateInlineWorkflowTemplateRequest) Descriptor Uses

func (*InstantiateInlineWorkflowTemplateRequest) Descriptor() ([]byte, []int)

func (*InstantiateInlineWorkflowTemplateRequest) GetParent Uses

func (m *InstantiateInlineWorkflowTemplateRequest) GetParent() string

func (*InstantiateInlineWorkflowTemplateRequest) GetRequestId Uses

func (m *InstantiateInlineWorkflowTemplateRequest) GetRequestId() string

func (*InstantiateInlineWorkflowTemplateRequest) GetTemplate Uses

func (m *InstantiateInlineWorkflowTemplateRequest) GetTemplate() *WorkflowTemplate

func (*InstantiateInlineWorkflowTemplateRequest) ProtoMessage Uses

func (*InstantiateInlineWorkflowTemplateRequest) ProtoMessage()

func (*InstantiateInlineWorkflowTemplateRequest) Reset Uses

func (m *InstantiateInlineWorkflowTemplateRequest) Reset()

func (*InstantiateInlineWorkflowTemplateRequest) String Uses

func (m *InstantiateInlineWorkflowTemplateRequest) String() string

func (*InstantiateInlineWorkflowTemplateRequest) XXX_DiscardUnknown Uses

func (m *InstantiateInlineWorkflowTemplateRequest) XXX_DiscardUnknown()

func (*InstantiateInlineWorkflowTemplateRequest) XXX_Marshal Uses

func (m *InstantiateInlineWorkflowTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstantiateInlineWorkflowTemplateRequest) XXX_Merge Uses

func (m *InstantiateInlineWorkflowTemplateRequest) XXX_Merge(src proto.Message)

func (*InstantiateInlineWorkflowTemplateRequest) XXX_Size Uses

func (m *InstantiateInlineWorkflowTemplateRequest) XXX_Size() int

func (*InstantiateInlineWorkflowTemplateRequest) XXX_Unmarshal Uses

func (m *InstantiateInlineWorkflowTemplateRequest) XXX_Unmarshal(b []byte) error

type InstantiateWorkflowTemplateRequest Uses

type InstantiateWorkflowTemplateRequest struct {
    // Required. The "resource name" of the workflow template, as described
    // in https://cloud.google.com/apis/design/resource_names of the form
    // `projects/{project_id}/regions/{region}/workflowTemplates/{template_id}`
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Optional. The version of workflow template to instantiate. If specified,
    // the workflow will be instantiated only if the current version of
    // the workflow template has the supplied version.
    //
    // This option cannot be used to instantiate a previous version of
    // workflow template.
    Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
    // Optional. A tag that prevents multiple concurrent workflow
    // instances with the same tag from running. This mitigates risk of
    // concurrent instances started due to retries.
    //
    // It is recommended to always set this value to a
    // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier).
    //
    // The tag must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), and hyphens (-). The maximum length is 40 characters.
    RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
    // Optional. Map from parameter names to values that should be used for those
    // parameters. Values may not exceed 100 characters.
    Parameters           map[string]string `protobuf:"bytes,6,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

A request to instantiate a workflow template.

func (*InstantiateWorkflowTemplateRequest) Descriptor Uses

func (*InstantiateWorkflowTemplateRequest) Descriptor() ([]byte, []int)

func (*InstantiateWorkflowTemplateRequest) GetName Uses

func (m *InstantiateWorkflowTemplateRequest) GetName() string

func (*InstantiateWorkflowTemplateRequest) GetParameters Uses

func (m *InstantiateWorkflowTemplateRequest) GetParameters() map[string]string

func (*InstantiateWorkflowTemplateRequest) GetRequestId Uses

func (m *InstantiateWorkflowTemplateRequest) GetRequestId() string

func (*InstantiateWorkflowTemplateRequest) GetVersion Uses

func (m *InstantiateWorkflowTemplateRequest) GetVersion() int32

func (*InstantiateWorkflowTemplateRequest) ProtoMessage Uses

func (*InstantiateWorkflowTemplateRequest) ProtoMessage()

func (*InstantiateWorkflowTemplateRequest) Reset Uses

func (m *InstantiateWorkflowTemplateRequest) Reset()

func (*InstantiateWorkflowTemplateRequest) String Uses

func (m *InstantiateWorkflowTemplateRequest) String() string

func (*InstantiateWorkflowTemplateRequest) XXX_DiscardUnknown Uses

func (m *InstantiateWorkflowTemplateRequest) XXX_DiscardUnknown()

func (*InstantiateWorkflowTemplateRequest) XXX_Marshal Uses

func (m *InstantiateWorkflowTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstantiateWorkflowTemplateRequest) XXX_Merge Uses

func (m *InstantiateWorkflowTemplateRequest) XXX_Merge(src proto.Message)

func (*InstantiateWorkflowTemplateRequest) XXX_Size Uses

func (m *InstantiateWorkflowTemplateRequest) XXX_Size() int

func (*InstantiateWorkflowTemplateRequest) XXX_Unmarshal Uses

func (m *InstantiateWorkflowTemplateRequest) XXX_Unmarshal(b []byte) error

type Job Uses

type Job struct {
    // Optional. The fully qualified reference to the job, which can be used to
    // obtain the equivalent REST path of the job resource. If this property
    // is not specified when a job is created, the server generates a
    // <code>job_id</code>.
    Reference *JobReference `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
    // Required. Job information, including how, when, and where to
    // run the job.
    Placement *JobPlacement `protobuf:"bytes,2,opt,name=placement,proto3" json:"placement,omitempty"`
    // Required. The application/framework-specific portion of the job.
    //
    // Types that are valid to be assigned to TypeJob:
    //	*Job_HadoopJob
    //	*Job_SparkJob
    //	*Job_PysparkJob
    //	*Job_HiveJob
    //	*Job_PigJob
    //	*Job_SparkSqlJob
    TypeJob isJob_TypeJob `protobuf_oneof:"type_job"`
    // Output only. The job status. Additional application-specific
    // status information may be contained in the <code>type_job</code>
    // and <code>yarn_applications</code> fields.
    Status *JobStatus `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
    // Output only. The previous job status.
    StatusHistory []*JobStatus `protobuf:"bytes,13,rep,name=status_history,json=statusHistory,proto3" json:"status_history,omitempty"`
    // Output only. The collection of YARN applications spun up by this job.
    //
    // **Beta** Feature: This report is available for testing purposes only. It
    // may be changed before final release.
    YarnApplications []*YarnApplication `protobuf:"bytes,9,rep,name=yarn_applications,json=yarnApplications,proto3" json:"yarn_applications,omitempty"`
    // Output only. A URI pointing to the location of the stdout of the job's
    // driver program.
    DriverOutputResourceUri string `protobuf:"bytes,17,opt,name=driver_output_resource_uri,json=driverOutputResourceUri,proto3" json:"driver_output_resource_uri,omitempty"`
    // Output only. If present, the location of miscellaneous control files
    // which may be used as part of job setup and handling. If not present,
    // control files may be placed in the same location as `driver_output_uri`.
    DriverControlFilesUri string `protobuf:"bytes,15,opt,name=driver_control_files_uri,json=driverControlFilesUri,proto3" json:"driver_control_files_uri,omitempty"`
    // Optional. The labels to associate with this job.
    // Label **keys** must contain 1 to 63 characters, and must conform to
    // [RFC 1035](https://www.ietf.org/rfc/rfc1035.txt).
    // Label **values** may be empty, but, if present, must contain 1 to 63
    // characters, and must conform to [RFC
    // 1035](https://www.ietf.org/rfc/rfc1035.txt). No more than 32 labels can be
    // associated with a job.
    Labels map[string]string `protobuf:"bytes,18,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. Job scheduling configuration.
    Scheduling *JobScheduling `protobuf:"bytes,20,opt,name=scheduling,proto3" json:"scheduling,omitempty"`
    // Output only. A UUID that uniquely identifies a job within the project
    // over time. This is in contrast to a user-settable reference.job_id that
    // may be reused over time.
    JobUuid              string   `protobuf:"bytes,22,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A Cloud Dataproc job resource.

func (*Job) Descriptor Uses

func (*Job) Descriptor() ([]byte, []int)

func (*Job) GetDriverControlFilesUri Uses

func (m *Job) GetDriverControlFilesUri() string

func (*Job) GetDriverOutputResourceUri Uses

func (m *Job) GetDriverOutputResourceUri() string

func (*Job) GetHadoopJob Uses

func (m *Job) GetHadoopJob() *HadoopJob

func (*Job) GetHiveJob Uses

func (m *Job) GetHiveJob() *HiveJob

func (*Job) GetJobUuid Uses

func (m *Job) GetJobUuid() string

func (*Job) GetLabels Uses

func (m *Job) GetLabels() map[string]string

func (*Job) GetPigJob Uses

func (m *Job) GetPigJob() *PigJob

func (*Job) GetPlacement Uses

func (m *Job) GetPlacement() *JobPlacement

func (*Job) GetPysparkJob Uses

func (m *Job) GetPysparkJob() *PySparkJob

func (*Job) GetReference Uses

func (m *Job) GetReference() *JobReference

func (*Job) GetScheduling Uses

func (m *Job) GetScheduling() *JobScheduling

func (*Job) GetSparkJob Uses

func (m *Job) GetSparkJob() *SparkJob

func (*Job) GetSparkSqlJob Uses

func (m *Job) GetSparkSqlJob() *SparkSqlJob

func (*Job) GetStatus Uses

func (m *Job) GetStatus() *JobStatus

func (*Job) GetStatusHistory Uses

func (m *Job) GetStatusHistory() []*JobStatus

func (*Job) GetTypeJob Uses

func (m *Job) GetTypeJob() isJob_TypeJob

func (*Job) GetYarnApplications Uses

func (m *Job) GetYarnApplications() []*YarnApplication

func (*Job) ProtoMessage Uses

func (*Job) ProtoMessage()

func (*Job) Reset Uses

func (m *Job) Reset()

func (*Job) String Uses

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown Uses

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal Uses

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge Uses

func (m *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_OneofWrappers Uses

func (*Job) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Job) XXX_Size Uses

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal Uses

func (m *Job) XXX_Unmarshal(b []byte) error

type JobControllerClient Uses

type JobControllerClient interface {
    // Submits a job to a cluster.
    SubmitJob(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*Job, error)
    // Gets the resource representation for a job in a project.
    GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
    // Lists regions/{region}/jobs in a project.
    ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
    // Updates a job in a project.
    UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*Job, error)
    // Starts a job cancellation request. To access the job resource
    // after cancellation, call
    // [regions/{region}/jobs.list](/dataproc/docs/reference/rest/v1/projects.regions.jobs/list)
    // or
    // [regions/{region}/jobs.get](/dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
    CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*Job, error)
    // Deletes the job from the project. If the job is active, the delete fails,
    // and the response returns `FAILED_PRECONDITION`.
    DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

JobControllerClient is the client API for JobController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewJobControllerClient Uses

func NewJobControllerClient(cc *grpc.ClientConn) JobControllerClient

type JobControllerServer Uses

type JobControllerServer interface {
    // Submits a job to a cluster.
    SubmitJob(context.Context, *SubmitJobRequest) (*Job, error)
    // Gets the resource representation for a job in a project.
    GetJob(context.Context, *GetJobRequest) (*Job, error)
    // Lists regions/{region}/jobs in a project.
    ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
    // Updates a job in a project.
    UpdateJob(context.Context, *UpdateJobRequest) (*Job, error)
    // Starts a job cancellation request. To access the job resource
    // after cancellation, call
    // [regions/{region}/jobs.list](/dataproc/docs/reference/rest/v1/projects.regions.jobs/list)
    // or
    // [regions/{region}/jobs.get](/dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
    CancelJob(context.Context, *CancelJobRequest) (*Job, error)
    // Deletes the job from the project. If the job is active, the delete fails,
    // and the response returns `FAILED_PRECONDITION`.
    DeleteJob(context.Context, *DeleteJobRequest) (*empty.Empty, error)
}

JobControllerServer is the server API for JobController service.

type JobPlacement Uses

type JobPlacement struct {
    // Required. The name of the cluster where the job will be submitted.
    ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    // Output only. A cluster UUID generated by the Cloud Dataproc service when
    // the job is submitted.
    ClusterUuid          string   `protobuf:"bytes,2,opt,name=cluster_uuid,json=clusterUuid,proto3" json:"cluster_uuid,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Cloud Dataproc job config.

func (*JobPlacement) Descriptor Uses

func (*JobPlacement) Descriptor() ([]byte, []int)

func (*JobPlacement) GetClusterName Uses

func (m *JobPlacement) GetClusterName() string

func (*JobPlacement) GetClusterUuid Uses

func (m *JobPlacement) GetClusterUuid() string

func (*JobPlacement) ProtoMessage Uses

func (*JobPlacement) ProtoMessage()

func (*JobPlacement) Reset Uses

func (m *JobPlacement) Reset()

func (*JobPlacement) String Uses

func (m *JobPlacement) String() string

func (*JobPlacement) XXX_DiscardUnknown Uses

func (m *JobPlacement) XXX_DiscardUnknown()

func (*JobPlacement) XXX_Marshal Uses

func (m *JobPlacement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobPlacement) XXX_Merge Uses

func (m *JobPlacement) XXX_Merge(src proto.Message)

func (*JobPlacement) XXX_Size Uses

func (m *JobPlacement) XXX_Size() int

func (*JobPlacement) XXX_Unmarshal Uses

func (m *JobPlacement) XXX_Unmarshal(b []byte) error

type JobReference Uses

type JobReference struct {
    // Required. The ID of the Google Cloud Platform project that the job
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Optional. The job ID, which must be unique within the project.
    //
    // The ID must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), or hyphens (-). The maximum length is 100 characters.
    //
    // If not specified by the caller, the job ID will be provided by the server.
    JobId                string   `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Encapsulates the full scoping used to reference a job.

func (*JobReference) Descriptor Uses

func (*JobReference) Descriptor() ([]byte, []int)

func (*JobReference) GetJobId Uses

func (m *JobReference) GetJobId() string

func (*JobReference) GetProjectId Uses

func (m *JobReference) GetProjectId() string

func (*JobReference) ProtoMessage Uses

func (*JobReference) ProtoMessage()

func (*JobReference) Reset Uses

func (m *JobReference) Reset()

func (*JobReference) String Uses

func (m *JobReference) String() string

func (*JobReference) XXX_DiscardUnknown Uses

func (m *JobReference) XXX_DiscardUnknown()

func (*JobReference) XXX_Marshal Uses

func (m *JobReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobReference) XXX_Merge Uses

func (m *JobReference) XXX_Merge(src proto.Message)

func (*JobReference) XXX_Size Uses

func (m *JobReference) XXX_Size() int

func (*JobReference) XXX_Unmarshal Uses

func (m *JobReference) XXX_Unmarshal(b []byte) error

type JobScheduling Uses

type JobScheduling struct {
    // Optional. Maximum number of times per hour a driver may be restarted as
    // a result of driver terminating with non-zero code before job is
    // reported failed.
    //
    // A job may be reported as thrashing if driver exits with non-zero code
    // 4 times within 10 minute window.
    //
    // Maximum value is 10.
    MaxFailuresPerHour   int32    `protobuf:"varint,1,opt,name=max_failures_per_hour,json=maxFailuresPerHour,proto3" json:"max_failures_per_hour,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Job scheduling options.

func (*JobScheduling) Descriptor Uses

func (*JobScheduling) Descriptor() ([]byte, []int)

func (*JobScheduling) GetMaxFailuresPerHour Uses

func (m *JobScheduling) GetMaxFailuresPerHour() int32

func (*JobScheduling) ProtoMessage Uses

func (*JobScheduling) ProtoMessage()

func (*JobScheduling) Reset Uses

func (m *JobScheduling) Reset()

func (*JobScheduling) String Uses

func (m *JobScheduling) String() string

func (*JobScheduling) XXX_DiscardUnknown Uses

func (m *JobScheduling) XXX_DiscardUnknown()

func (*JobScheduling) XXX_Marshal Uses

func (m *JobScheduling) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobScheduling) XXX_Merge Uses

func (m *JobScheduling) XXX_Merge(src proto.Message)

func (*JobScheduling) XXX_Size Uses

func (m *JobScheduling) XXX_Size() int

func (*JobScheduling) XXX_Unmarshal Uses

func (m *JobScheduling) XXX_Unmarshal(b []byte) error

type JobStatus Uses

type JobStatus struct {
    // Output only. A state message specifying the overall job state.
    State JobStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.dataproc.v1.JobStatus_State" json:"state,omitempty"`
    // Output only. Optional job state details, such as an error
    // description if the state is <code>ERROR</code>.
    Details string `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
    // Output only. The time when this state was entered.
    StateStartTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=state_start_time,json=stateStartTime,proto3" json:"state_start_time,omitempty"`
    // Output only. Additional state information, which includes
    // status reported by the agent.
    Substate             JobStatus_Substate `protobuf:"varint,7,opt,name=substate,proto3,enum=google.cloud.dataproc.v1.JobStatus_Substate" json:"substate,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

Cloud Dataproc job status.

func (*JobStatus) Descriptor Uses

func (*JobStatus) Descriptor() ([]byte, []int)

func (*JobStatus) GetDetails Uses

func (m *JobStatus) GetDetails() string

func (*JobStatus) GetState Uses

func (m *JobStatus) GetState() JobStatus_State

func (*JobStatus) GetStateStartTime Uses

func (m *JobStatus) GetStateStartTime() *timestamp.Timestamp

func (*JobStatus) GetSubstate Uses

func (m *JobStatus) GetSubstate() JobStatus_Substate

func (*JobStatus) ProtoMessage Uses

func (*JobStatus) ProtoMessage()

func (*JobStatus) Reset Uses

func (m *JobStatus) Reset()

func (*JobStatus) String Uses

func (m *JobStatus) String() string

func (*JobStatus) XXX_DiscardUnknown Uses

func (m *JobStatus) XXX_DiscardUnknown()

func (*JobStatus) XXX_Marshal Uses

func (m *JobStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStatus) XXX_Merge Uses

func (m *JobStatus) XXX_Merge(src proto.Message)

func (*JobStatus) XXX_Size Uses

func (m *JobStatus) XXX_Size() int

func (*JobStatus) XXX_Unmarshal Uses

func (m *JobStatus) XXX_Unmarshal(b []byte) error

type JobStatus_State Uses

type JobStatus_State int32

The job state.

const (
    // The job state is unknown.
    JobStatus_STATE_UNSPECIFIED JobStatus_State = 0
    // The job is pending; it has been submitted, but is not yet running.
    JobStatus_PENDING JobStatus_State = 1
    // Job has been received by the service and completed initial setup;
    // it will soon be submitted to the cluster.
    JobStatus_SETUP_DONE JobStatus_State = 8
    // The job is running on the cluster.
    JobStatus_RUNNING JobStatus_State = 2
    // A CancelJob request has been received, but is pending.
    JobStatus_CANCEL_PENDING JobStatus_State = 3
    // Transient in-flight resources have been canceled, and the request to
    // cancel the running job has been issued to the cluster.
    JobStatus_CANCEL_STARTED JobStatus_State = 7
    // The job cancellation was successful.
    JobStatus_CANCELLED JobStatus_State = 4
    // The job has completed successfully.
    JobStatus_DONE JobStatus_State = 5
    // The job has completed, but encountered an error.
    JobStatus_ERROR JobStatus_State = 6
    // Job attempt has failed. The detail field contains failure details for
    // this attempt.
    //
    // Applies to restartable jobs only.
    JobStatus_ATTEMPT_FAILURE JobStatus_State = 9
)

func (JobStatus_State) EnumDescriptor Uses

func (JobStatus_State) EnumDescriptor() ([]byte, []int)

func (JobStatus_State) String Uses

func (x JobStatus_State) String() string

type JobStatus_Substate Uses

type JobStatus_Substate int32

The job substate.

const (
    // The job substate is unknown.
    JobStatus_UNSPECIFIED JobStatus_Substate = 0
    // The Job is submitted to the agent.
    //
    // Applies to RUNNING state.
    JobStatus_SUBMITTED JobStatus_Substate = 1
    // The Job has been received and is awaiting execution (it may be waiting
    // for a condition to be met). See the "details" field for the reason for
    // the delay.
    //
    // Applies to RUNNING state.
    JobStatus_QUEUED JobStatus_Substate = 2
    // The agent-reported status is out of date, which may be caused by a
    // loss of communication between the agent and Cloud Dataproc. If the
    // agent does not send a timely update, the job will fail.
    //
    // Applies to RUNNING state.
    JobStatus_STALE_STATUS JobStatus_Substate = 3
)

func (JobStatus_Substate) EnumDescriptor Uses

func (JobStatus_Substate) EnumDescriptor() ([]byte, []int)

func (JobStatus_Substate) String Uses

func (x JobStatus_Substate) String() string

type Job_HadoopJob Uses

type Job_HadoopJob struct {
    HadoopJob *HadoopJob `protobuf:"bytes,3,opt,name=hadoop_job,json=hadoopJob,proto3,oneof"`
}

type Job_HiveJob Uses

type Job_HiveJob struct {
    HiveJob *HiveJob `protobuf:"bytes,6,opt,name=hive_job,json=hiveJob,proto3,oneof"`
}

type Job_PigJob Uses

type Job_PigJob struct {
    PigJob *PigJob `protobuf:"bytes,7,opt,name=pig_job,json=pigJob,proto3,oneof"`
}

type Job_PysparkJob Uses

type Job_PysparkJob struct {
    PysparkJob *PySparkJob `protobuf:"bytes,5,opt,name=pyspark_job,json=pysparkJob,proto3,oneof"`
}

type Job_SparkJob Uses

type Job_SparkJob struct {
    SparkJob *SparkJob `protobuf:"bytes,4,opt,name=spark_job,json=sparkJob,proto3,oneof"`
}

type Job_SparkSqlJob Uses

type Job_SparkSqlJob struct {
    SparkSqlJob *SparkSqlJob `protobuf:"bytes,12,opt,name=spark_sql_job,json=sparkSqlJob,proto3,oneof"`
}

type ListClustersRequest Uses

type ListClustersRequest struct {
    // Required. The ID of the Google Cloud Platform project that the cluster
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
    // Optional. A filter constraining the clusters to list. Filters are
    // case-sensitive and have the following syntax:
    //
    // field = value [AND [field = value]] ...
    //
    // where **field** is one of `status.state`, `clusterName`, or `labels.[KEY]`,
    // and `[KEY]` is a label key. **value** can be `*` to match all values.
    // `status.state` can be one of the following: `ACTIVE`, `INACTIVE`,
    // `CREATING`, `RUNNING`, `ERROR`, `DELETING`, or `UPDATING`. `ACTIVE`
    // contains the `CREATING`, `UPDATING`, and `RUNNING` states. `INACTIVE`
    // contains the `DELETING` and `ERROR` states.
    // `clusterName` is the name of the cluster provided at creation time.
    // Only the logical `AND` operator is supported; space-separated items are
    // treated as having an implicit `AND` operator.
    //
    // Example filter:
    //
    // status.state = ACTIVE AND clusterName = mycluster
    // AND labels.env = staging AND labels.starred = *
    Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
    // Optional. The standard List page size.
    PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
    // Optional. The standard List page token.
    PageToken            string   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to list the clusters in a project.

func (*ListClustersRequest) Descriptor Uses

func (*ListClustersRequest) Descriptor() ([]byte, []int)

func (*ListClustersRequest) GetFilter Uses

func (m *ListClustersRequest) GetFilter() string

func (*ListClustersRequest) GetPageSize Uses

func (m *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GetPageToken Uses

func (m *ListClustersRequest) GetPageToken() string

func (*ListClustersRequest) GetProjectId Uses

func (m *ListClustersRequest) GetProjectId() string

func (*ListClustersRequest) GetRegion Uses

func (m *ListClustersRequest) GetRegion() string

func (*ListClustersRequest) ProtoMessage Uses

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) Reset Uses

func (m *ListClustersRequest) Reset()

func (*ListClustersRequest) String Uses

func (m *ListClustersRequest) String() string

func (*ListClustersRequest) XXX_DiscardUnknown Uses

func (m *ListClustersRequest) XXX_DiscardUnknown()

func (*ListClustersRequest) XXX_Marshal Uses

func (m *ListClustersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListClustersRequest) XXX_Merge Uses

func (m *ListClustersRequest) XXX_Merge(src proto.Message)

func (*ListClustersRequest) XXX_Size Uses

func (m *ListClustersRequest) XXX_Size() int

func (*ListClustersRequest) XXX_Unmarshal Uses

func (m *ListClustersRequest) XXX_Unmarshal(b []byte) error

type ListClustersResponse Uses

type ListClustersResponse struct {
    // Output only. The clusters in the project.
    Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
    // Output only. This token is included in the response if there are more
    // results to fetch. To fetch additional results, provide this value as the
    // `page_token` in a subsequent `ListClustersRequest`.
    NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

The list of all clusters in a project.

func (*ListClustersResponse) Descriptor Uses

func (*ListClustersResponse) Descriptor() ([]byte, []int)

func (*ListClustersResponse) GetClusters Uses

func (m *ListClustersResponse) GetClusters() []*Cluster

func (*ListClustersResponse) GetNextPageToken Uses

func (m *ListClustersResponse) GetNextPageToken() string

func (*ListClustersResponse) ProtoMessage Uses

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) Reset Uses

func (m *ListClustersResponse) Reset()

func (*ListClustersResponse) String Uses

func (m *ListClustersResponse) String() string

func (*ListClustersResponse) XXX_DiscardUnknown Uses

func (m *ListClustersResponse) XXX_DiscardUnknown()

func (*ListClustersResponse) XXX_Marshal Uses

func (m *ListClustersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListClustersResponse) XXX_Merge Uses

func (m *ListClustersResponse) XXX_Merge(src proto.Message)

func (*ListClustersResponse) XXX_Size Uses

func (m *ListClustersResponse) XXX_Size() int

func (*ListClustersResponse) XXX_Unmarshal Uses

func (m *ListClustersResponse) XXX_Unmarshal(b []byte) error

type ListJobsRequest Uses

type ListJobsRequest struct {
    // Required. The ID of the Google Cloud Platform project that the job
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,6,opt,name=region,proto3" json:"region,omitempty"`
    // Optional. The number of results to return in each response.
    PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
    // Optional. The page token, returned by a previous call, to request the
    // next page of results.
    PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
    // Optional. If set, the returned jobs list includes only jobs that were
    // submitted to the named cluster.
    ClusterName string `protobuf:"bytes,4,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    // Optional. Specifies enumerated categories of jobs to list.
    // (default = match ALL jobs).
    //
    // If `filter` is provided, `jobStateMatcher` will be ignored.
    JobStateMatcher ListJobsRequest_JobStateMatcher `protobuf:"varint,5,opt,name=job_state_matcher,json=jobStateMatcher,proto3,enum=google.cloud.dataproc.v1.ListJobsRequest_JobStateMatcher" json:"job_state_matcher,omitempty"`
    // Optional. A filter constraining the jobs to list. Filters are
    // case-sensitive and have the following syntax:
    //
    // [field = value] AND [field [= value]] ...
    //
    // where **field** is `status.state` or `labels.[KEY]`, and `[KEY]` is a label
    // key. **value** can be `*` to match all values.
    // `status.state` can be either `ACTIVE` or `NON_ACTIVE`.
    // Only the logical `AND` operator is supported; space-separated items are
    // treated as having an implicit `AND` operator.
    //
    // Example filter:
    //
    // status.state = ACTIVE AND labels.env = staging AND labels.starred = *
    Filter               string   `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to list jobs in a project.

func (*ListJobsRequest) Descriptor Uses

func (*ListJobsRequest) Descriptor() ([]byte, []int)

func (*ListJobsRequest) GetClusterName Uses

func (m *ListJobsRequest) GetClusterName() string

func (*ListJobsRequest) GetFilter Uses

func (m *ListJobsRequest) GetFilter() string

func (*ListJobsRequest) GetJobStateMatcher Uses

func (m *ListJobsRequest) GetJobStateMatcher() ListJobsRequest_JobStateMatcher

func (*ListJobsRequest) GetPageSize Uses

func (m *ListJobsRequest) GetPageSize() int32

func (*ListJobsRequest) GetPageToken Uses

func (m *ListJobsRequest) GetPageToken() string

func (*ListJobsRequest) GetProjectId Uses

func (m *ListJobsRequest) GetProjectId() string

func (*ListJobsRequest) GetRegion Uses

func (m *ListJobsRequest) GetRegion() string

func (*ListJobsRequest) ProtoMessage Uses

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) Reset Uses

func (m *ListJobsRequest) Reset()

func (*ListJobsRequest) String Uses

func (m *ListJobsRequest) String() string

func (*ListJobsRequest) XXX_DiscardUnknown Uses

func (m *ListJobsRequest) XXX_DiscardUnknown()

func (*ListJobsRequest) XXX_Marshal Uses

func (m *ListJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobsRequest) XXX_Merge Uses

func (m *ListJobsRequest) XXX_Merge(src proto.Message)

func (*ListJobsRequest) XXX_Size Uses

func (m *ListJobsRequest) XXX_Size() int

func (*ListJobsRequest) XXX_Unmarshal Uses

func (m *ListJobsRequest) XXX_Unmarshal(b []byte) error

type ListJobsRequest_JobStateMatcher Uses

type ListJobsRequest_JobStateMatcher int32

A matcher that specifies categories of job states.

const (
    // Match all jobs, regardless of state.
    ListJobsRequest_ALL ListJobsRequest_JobStateMatcher = 0
    // Only match jobs in non-terminal states: PENDING, RUNNING, or
    // CANCEL_PENDING.
    ListJobsRequest_ACTIVE ListJobsRequest_JobStateMatcher = 1
    // Only match jobs in terminal states: CANCELLED, DONE, or ERROR.
    ListJobsRequest_NON_ACTIVE ListJobsRequest_JobStateMatcher = 2
)

func (ListJobsRequest_JobStateMatcher) EnumDescriptor Uses

func (ListJobsRequest_JobStateMatcher) EnumDescriptor() ([]byte, []int)

func (ListJobsRequest_JobStateMatcher) String Uses

func (x ListJobsRequest_JobStateMatcher) String() string

type ListJobsResponse Uses

type ListJobsResponse struct {
    // Output only. Jobs list.
    Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
    // Optional. This token is included in the response if there are more results
    // to fetch. To fetch additional results, provide this value as the
    // `page_token` in a subsequent <code>ListJobsRequest</code>.
    NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A list of jobs in a project.

func (*ListJobsResponse) Descriptor Uses

func (*ListJobsResponse) Descriptor() ([]byte, []int)

func (*ListJobsResponse) GetJobs Uses

func (m *ListJobsResponse) GetJobs() []*Job

func (*ListJobsResponse) GetNextPageToken Uses

func (m *ListJobsResponse) GetNextPageToken() string

func (*ListJobsResponse) ProtoMessage Uses

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) Reset Uses

func (m *ListJobsResponse) Reset()

func (*ListJobsResponse) String Uses

func (m *ListJobsResponse) String() string

func (*ListJobsResponse) XXX_DiscardUnknown Uses

func (m *ListJobsResponse) XXX_DiscardUnknown()

func (*ListJobsResponse) XXX_Marshal Uses

func (m *ListJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobsResponse) XXX_Merge Uses

func (m *ListJobsResponse) XXX_Merge(src proto.Message)

func (*ListJobsResponse) XXX_Size Uses

func (m *ListJobsResponse) XXX_Size() int

func (*ListJobsResponse) XXX_Unmarshal Uses

func (m *ListJobsResponse) XXX_Unmarshal(b []byte) error

type ListWorkflowTemplatesRequest Uses

type ListWorkflowTemplatesRequest struct {
    // Required. The "resource name" of the region, as described
    // in https://cloud.google.com/apis/design/resource_names of the form
    // `projects/{project_id}/regions/{region}`
    Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
    // Optional. The maximum number of results to return in each response.
    PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
    // Optional. The page token, returned by a previous call, to request the
    // next page of results.
    PageToken            string   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to list workflow templates in a project.

func (*ListWorkflowTemplatesRequest) Descriptor Uses

func (*ListWorkflowTemplatesRequest) Descriptor() ([]byte, []int)

func (*ListWorkflowTemplatesRequest) GetPageSize Uses

func (m *ListWorkflowTemplatesRequest) GetPageSize() int32

func (*ListWorkflowTemplatesRequest) GetPageToken Uses

func (m *ListWorkflowTemplatesRequest) GetPageToken() string

func (*ListWorkflowTemplatesRequest) GetParent Uses

func (m *ListWorkflowTemplatesRequest) GetParent() string

func (*ListWorkflowTemplatesRequest) ProtoMessage Uses

func (*ListWorkflowTemplatesRequest) ProtoMessage()

func (*ListWorkflowTemplatesRequest) Reset Uses

func (m *ListWorkflowTemplatesRequest) Reset()

func (*ListWorkflowTemplatesRequest) String Uses

func (m *ListWorkflowTemplatesRequest) String() string

func (*ListWorkflowTemplatesRequest) XXX_DiscardUnknown Uses

func (m *ListWorkflowTemplatesRequest) XXX_DiscardUnknown()

func (*ListWorkflowTemplatesRequest) XXX_Marshal Uses

func (m *ListWorkflowTemplatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListWorkflowTemplatesRequest) XXX_Merge Uses

func (m *ListWorkflowTemplatesRequest) XXX_Merge(src proto.Message)

func (*ListWorkflowTemplatesRequest) XXX_Size Uses

func (m *ListWorkflowTemplatesRequest) XXX_Size() int

func (*ListWorkflowTemplatesRequest) XXX_Unmarshal Uses

func (m *ListWorkflowTemplatesRequest) XXX_Unmarshal(b []byte) error

type ListWorkflowTemplatesResponse Uses

type ListWorkflowTemplatesResponse struct {
    // Output only. WorkflowTemplates list.
    Templates []*WorkflowTemplate `protobuf:"bytes,1,rep,name=templates,proto3" json:"templates,omitempty"`
    // Output only. This token is included in the response if there are more
    // results to fetch. To fetch additional results, provide this value as the
    // page_token in a subsequent <code>ListWorkflowTemplatesRequest</code>.
    NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A response to a request to list workflow templates in a project.

func (*ListWorkflowTemplatesResponse) Descriptor Uses

func (*ListWorkflowTemplatesResponse) Descriptor() ([]byte, []int)

func (*ListWorkflowTemplatesResponse) GetNextPageToken Uses

func (m *ListWorkflowTemplatesResponse) GetNextPageToken() string

func (*ListWorkflowTemplatesResponse) GetTemplates Uses

func (m *ListWorkflowTemplatesResponse) GetTemplates() []*WorkflowTemplate

func (*ListWorkflowTemplatesResponse) ProtoMessage Uses

func (*ListWorkflowTemplatesResponse) ProtoMessage()

func (*ListWorkflowTemplatesResponse) Reset Uses

func (m *ListWorkflowTemplatesResponse) Reset()

func (*ListWorkflowTemplatesResponse) String Uses

func (m *ListWorkflowTemplatesResponse) String() string

func (*ListWorkflowTemplatesResponse) XXX_DiscardUnknown Uses

func (m *ListWorkflowTemplatesResponse) XXX_DiscardUnknown()

func (*ListWorkflowTemplatesResponse) XXX_Marshal Uses

func (m *ListWorkflowTemplatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListWorkflowTemplatesResponse) XXX_Merge Uses

func (m *ListWorkflowTemplatesResponse) XXX_Merge(src proto.Message)

func (*ListWorkflowTemplatesResponse) XXX_Size Uses

func (m *ListWorkflowTemplatesResponse) XXX_Size() int

func (*ListWorkflowTemplatesResponse) XXX_Unmarshal Uses

func (m *ListWorkflowTemplatesResponse) XXX_Unmarshal(b []byte) error

type LoggingConfig Uses

type LoggingConfig struct {
    // The per-package log levels for the driver. This may include
    // "root" package name to configure rootLogger.
    // Examples:
    //   'com.google = FATAL', 'root = INFO', 'org.apache = DEBUG'
    DriverLogLevels      map[string]LoggingConfig_Level `protobuf:"bytes,2,rep,name=driver_log_levels,json=driverLogLevels,proto3" json:"driver_log_levels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3,enum=google.cloud.dataproc.v1.LoggingConfig_Level"`
    XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
    XXX_unrecognized     []byte                         `json:"-"`
    XXX_sizecache        int32                          `json:"-"`
}

The runtime logging config of the job.

func (*LoggingConfig) Descriptor Uses

func (*LoggingConfig) Descriptor() ([]byte, []int)

func (*LoggingConfig) GetDriverLogLevels Uses

func (m *LoggingConfig) GetDriverLogLevels() map[string]LoggingConfig_Level

func (*LoggingConfig) ProtoMessage Uses

func (*LoggingConfig) ProtoMessage()

func (*LoggingConfig) Reset Uses

func (m *LoggingConfig) Reset()

func (*LoggingConfig) String Uses

func (m *LoggingConfig) String() string

func (*LoggingConfig) XXX_DiscardUnknown Uses

func (m *LoggingConfig) XXX_DiscardUnknown()

func (*LoggingConfig) XXX_Marshal Uses

func (m *LoggingConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoggingConfig) XXX_Merge Uses

func (m *LoggingConfig) XXX_Merge(src proto.Message)

func (*LoggingConfig) XXX_Size Uses

func (m *LoggingConfig) XXX_Size() int

func (*LoggingConfig) XXX_Unmarshal Uses

func (m *LoggingConfig) XXX_Unmarshal(b []byte) error

type LoggingConfig_Level Uses

type LoggingConfig_Level int32

The Log4j level for job execution. When running an [Apache Hive](http://hive.apache.org/) job, Cloud Dataproc configures the Hive client to an equivalent verbosity level.

const (
    // Level is unspecified. Use default level for log4j.
    LoggingConfig_LEVEL_UNSPECIFIED LoggingConfig_Level = 0
    // Use ALL level for log4j.
    LoggingConfig_ALL LoggingConfig_Level = 1
    // Use TRACE level for log4j.
    LoggingConfig_TRACE LoggingConfig_Level = 2
    // Use DEBUG level for log4j.
    LoggingConfig_DEBUG LoggingConfig_Level = 3
    // Use INFO level for log4j.
    LoggingConfig_INFO LoggingConfig_Level = 4
    // Use WARN level for log4j.
    LoggingConfig_WARN LoggingConfig_Level = 5
    // Use ERROR level for log4j.
    LoggingConfig_ERROR LoggingConfig_Level = 6
    // Use FATAL level for log4j.
    LoggingConfig_FATAL LoggingConfig_Level = 7
    // Turn off log4j.
    LoggingConfig_OFF LoggingConfig_Level = 8
)

func (LoggingConfig_Level) EnumDescriptor Uses

func (LoggingConfig_Level) EnumDescriptor() ([]byte, []int)

func (LoggingConfig_Level) String Uses

func (x LoggingConfig_Level) String() string

type ManagedCluster Uses

type ManagedCluster struct {
    // Required. The cluster name prefix. A unique cluster name will be formed by
    // appending a random suffix.
    //
    // The name must contain only lower-case letters (a-z), numbers (0-9),
    // and hyphens (-). Must begin with a letter. Cannot begin or end with
    // hyphen. Must consist of between 2 and 35 characters.
    ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    // Required. The cluster configuration.
    Config *ClusterConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
    // Optional. The labels to associate with this cluster.
    //
    // Label keys must be between 1 and 63 characters long, and must conform to
    // the following PCRE regular expression:
    // [\p{Ll}\p{Lo}][\p{Ll}\p{Lo}\p{N}_-]{0,62}
    //
    // Label values must be between 1 and 63 characters long, and must conform to
    // the following PCRE regular expression: [\p{Ll}\p{Lo}\p{N}_-]{0,63}
    //
    // No more than 32 labels can be associated with a given cluster.
    Labels               map[string]string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

Cluster that is managed by the workflow.

func (*ManagedCluster) Descriptor Uses

func (*ManagedCluster) Descriptor() ([]byte, []int)

func (*ManagedCluster) GetClusterName Uses

func (m *ManagedCluster) GetClusterName() string

func (*ManagedCluster) GetConfig Uses

func (m *ManagedCluster) GetConfig() *ClusterConfig

func (*ManagedCluster) GetLabels Uses

func (m *ManagedCluster) GetLabels() map[string]string

func (*ManagedCluster) ProtoMessage Uses

func (*ManagedCluster) ProtoMessage()

func (*ManagedCluster) Reset Uses

func (m *ManagedCluster) Reset()

func (*ManagedCluster) String Uses

func (m *ManagedCluster) String() string

func (*ManagedCluster) XXX_DiscardUnknown Uses

func (m *ManagedCluster) XXX_DiscardUnknown()

func (*ManagedCluster) XXX_Marshal Uses

func (m *ManagedCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ManagedCluster) XXX_Merge Uses

func (m *ManagedCluster) XXX_Merge(src proto.Message)

func (*ManagedCluster) XXX_Size Uses

func (m *ManagedCluster) XXX_Size() int

func (*ManagedCluster) XXX_Unmarshal Uses

func (m *ManagedCluster) XXX_Unmarshal(b []byte) error

type ManagedGroupConfig Uses

type ManagedGroupConfig struct {
    // Output only. The name of the Instance Template used for the Managed
    // Instance Group.
    InstanceTemplateName string `protobuf:"bytes,1,opt,name=instance_template_name,json=instanceTemplateName,proto3" json:"instance_template_name,omitempty"`
    // Output only. The name of the Instance Group Manager for this group.
    InstanceGroupManagerName string   `protobuf:"bytes,2,opt,name=instance_group_manager_name,json=instanceGroupManagerName,proto3" json:"instance_group_manager_name,omitempty"`
    XXX_NoUnkeyedLiteral     struct{} `json:"-"`
    XXX_unrecognized         []byte   `json:"-"`
    XXX_sizecache            int32    `json:"-"`
}

Specifies the resources used to actively manage an instance group.

func (*ManagedGroupConfig) Descriptor Uses

func (*ManagedGroupConfig) Descriptor() ([]byte, []int)

func (*ManagedGroupConfig) GetInstanceGroupManagerName Uses

func (m *ManagedGroupConfig) GetInstanceGroupManagerName() string

func (*ManagedGroupConfig) GetInstanceTemplateName Uses

func (m *ManagedGroupConfig) GetInstanceTemplateName() string

func (*ManagedGroupConfig) ProtoMessage Uses

func (*ManagedGroupConfig) ProtoMessage()

func (*ManagedGroupConfig) Reset Uses

func (m *ManagedGroupConfig) Reset()

func (*ManagedGroupConfig) String Uses

func (m *ManagedGroupConfig) String() string

func (*ManagedGroupConfig) XXX_DiscardUnknown Uses

func (m *ManagedGroupConfig) XXX_DiscardUnknown()

func (*ManagedGroupConfig) XXX_Marshal Uses

func (m *ManagedGroupConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ManagedGroupConfig) XXX_Merge Uses

func (m *ManagedGroupConfig) XXX_Merge(src proto.Message)

func (*ManagedGroupConfig) XXX_Size Uses

func (m *ManagedGroupConfig) XXX_Size() int

func (*ManagedGroupConfig) XXX_Unmarshal Uses

func (m *ManagedGroupConfig) XXX_Unmarshal(b []byte) error

type NodeInitializationAction Uses

type NodeInitializationAction struct {
    // Required. Cloud Storage URI of executable file.
    ExecutableFile string `protobuf:"bytes,1,opt,name=executable_file,json=executableFile,proto3" json:"executable_file,omitempty"`
    // Optional. Amount of time executable has to complete. Default is
    // 10 minutes. Cluster creation fails with an explanatory error message (the
    // name of the executable that caused the error and the exceeded timeout
    // period) if the executable is not completed at end of the timeout period.
    ExecutionTimeout     *duration.Duration `protobuf:"bytes,2,opt,name=execution_timeout,json=executionTimeout,proto3" json:"execution_timeout,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

Specifies an executable to run on a fully configured node and a timeout period for executable completion.

func (*NodeInitializationAction) Descriptor Uses

func (*NodeInitializationAction) Descriptor() ([]byte, []int)

func (*NodeInitializationAction) GetExecutableFile Uses

func (m *NodeInitializationAction) GetExecutableFile() string

func (*NodeInitializationAction) GetExecutionTimeout Uses

func (m *NodeInitializationAction) GetExecutionTimeout() *duration.Duration

func (*NodeInitializationAction) ProtoMessage Uses

func (*NodeInitializationAction) ProtoMessage()

func (*NodeInitializationAction) Reset Uses

func (m *NodeInitializationAction) Reset()

func (*NodeInitializationAction) String Uses

func (m *NodeInitializationAction) String() string

func (*NodeInitializationAction) XXX_DiscardUnknown Uses

func (m *NodeInitializationAction) XXX_DiscardUnknown()

func (*NodeInitializationAction) XXX_Marshal Uses

func (m *NodeInitializationAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeInitializationAction) XXX_Merge Uses

func (m *NodeInitializationAction) XXX_Merge(src proto.Message)

func (*NodeInitializationAction) XXX_Size Uses

func (m *NodeInitializationAction) XXX_Size() int

func (*NodeInitializationAction) XXX_Unmarshal Uses

func (m *NodeInitializationAction) XXX_Unmarshal(b []byte) error

type OrderedJob Uses

type OrderedJob struct {
    // Required. The step id. The id must be unique among all jobs
    // within the template.
    //
    // The step id is used as prefix for job id, as job
    // `goog-dataproc-workflow-step-id` label, and in
    // [prerequisiteStepIds][google.cloud.dataproc.v1.OrderedJob.prerequisite_step_ids] field from other
    // steps.
    //
    // The id must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), and hyphens (-). Cannot begin or end with underscore
    // or hyphen. Must consist of between 3 and 50 characters.
    StepId string `protobuf:"bytes,1,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
    // Required. The job definition.
    //
    // Types that are valid to be assigned to JobType:
    //	*OrderedJob_HadoopJob
    //	*OrderedJob_SparkJob
    //	*OrderedJob_PysparkJob
    //	*OrderedJob_HiveJob
    //	*OrderedJob_PigJob
    //	*OrderedJob_SparkSqlJob
    JobType isOrderedJob_JobType `protobuf_oneof:"job_type"`
    // Optional. The labels to associate with this job.
    //
    // Label keys must be between 1 and 63 characters long, and must conform to
    // the following regular expression:
    // [\p{Ll}\p{Lo}][\p{Ll}\p{Lo}\p{N}_-]{0,62}
    //
    // Label values must be between 1 and 63 characters long, and must conform to
    // the following regular expression: [\p{Ll}\p{Lo}\p{N}_-]{0,63}
    //
    // No more than 32 labels can be associated with a given job.
    Labels map[string]string `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. Job scheduling configuration.
    Scheduling *JobScheduling `protobuf:"bytes,9,opt,name=scheduling,proto3" json:"scheduling,omitempty"`
    // Optional. The optional list of prerequisite job step_ids.
    // If not specified, the job will start at the beginning of workflow.
    PrerequisiteStepIds  []string `protobuf:"bytes,10,rep,name=prerequisite_step_ids,json=prerequisiteStepIds,proto3" json:"prerequisite_step_ids,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A job executed by the workflow.

func (*OrderedJob) Descriptor Uses

func (*OrderedJob) Descriptor() ([]byte, []int)

func (*OrderedJob) GetHadoopJob Uses

func (m *OrderedJob) GetHadoopJob() *HadoopJob

func (*OrderedJob) GetHiveJob Uses

func (m *OrderedJob) GetHiveJob() *HiveJob

func (*OrderedJob) GetJobType Uses

func (m *OrderedJob) GetJobType() isOrderedJob_JobType

func (*OrderedJob) GetLabels Uses

func (m *OrderedJob) GetLabels() map[string]string

func (*OrderedJob) GetPigJob Uses

func (m *OrderedJob) GetPigJob() *PigJob

func (*OrderedJob) GetPrerequisiteStepIds Uses

func (m *OrderedJob) GetPrerequisiteStepIds() []string

func (*OrderedJob) GetPysparkJob Uses

func (m *OrderedJob) GetPysparkJob() *PySparkJob

func (*OrderedJob) GetScheduling Uses

func (m *OrderedJob) GetScheduling() *JobScheduling

func (*OrderedJob) GetSparkJob Uses

func (m *OrderedJob) GetSparkJob() *SparkJob

func (*OrderedJob) GetSparkSqlJob Uses

func (m *OrderedJob) GetSparkSqlJob() *SparkSqlJob

func (*OrderedJob) GetStepId Uses

func (m *OrderedJob) GetStepId() string

func (*OrderedJob) ProtoMessage Uses

func (*OrderedJob) ProtoMessage()

func (*OrderedJob) Reset Uses

func (m *OrderedJob) Reset()

func (*OrderedJob) String Uses

func (m *OrderedJob) String() string

func (*OrderedJob) XXX_DiscardUnknown Uses

func (m *OrderedJob) XXX_DiscardUnknown()

func (*OrderedJob) XXX_Marshal Uses

func (m *OrderedJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderedJob) XXX_Merge Uses

func (m *OrderedJob) XXX_Merge(src proto.Message)

func (*OrderedJob) XXX_OneofWrappers Uses

func (*OrderedJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OrderedJob) XXX_Size Uses

func (m *OrderedJob) XXX_Size() int

func (*OrderedJob) XXX_Unmarshal Uses

func (m *OrderedJob) XXX_Unmarshal(b []byte) error

type OrderedJob_HadoopJob Uses

type OrderedJob_HadoopJob struct {
    HadoopJob *HadoopJob `protobuf:"bytes,2,opt,name=hadoop_job,json=hadoopJob,proto3,oneof"`
}

type OrderedJob_HiveJob Uses

type OrderedJob_HiveJob struct {
    HiveJob *HiveJob `protobuf:"bytes,5,opt,name=hive_job,json=hiveJob,proto3,oneof"`
}

type OrderedJob_PigJob Uses

type OrderedJob_PigJob struct {
    PigJob *PigJob `protobuf:"bytes,6,opt,name=pig_job,json=pigJob,proto3,oneof"`
}

type OrderedJob_PysparkJob Uses

type OrderedJob_PysparkJob struct {
    PysparkJob *PySparkJob `protobuf:"bytes,4,opt,name=pyspark_job,json=pysparkJob,proto3,oneof"`
}

type OrderedJob_SparkJob Uses

type OrderedJob_SparkJob struct {
    SparkJob *SparkJob `protobuf:"bytes,3,opt,name=spark_job,json=sparkJob,proto3,oneof"`
}

type OrderedJob_SparkSqlJob Uses

type OrderedJob_SparkSqlJob struct {
    SparkSqlJob *SparkSqlJob `protobuf:"bytes,7,opt,name=spark_sql_job,json=sparkSqlJob,proto3,oneof"`
}

type ParameterValidation Uses

type ParameterValidation struct {
    // Required. The type of validation to be performed.
    //
    // Types that are valid to be assigned to ValidationType:
    //	*ParameterValidation_Regex
    //	*ParameterValidation_Values
    ValidationType       isParameterValidation_ValidationType `protobuf_oneof:"validation_type"`
    XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
    XXX_unrecognized     []byte                               `json:"-"`
    XXX_sizecache        int32                                `json:"-"`
}

Configuration for parameter validation.

func (*ParameterValidation) Descriptor Uses

func (*ParameterValidation) Descriptor() ([]byte, []int)

func (*ParameterValidation) GetRegex Uses

func (m *ParameterValidation) GetRegex() *RegexValidation

func (*ParameterValidation) GetValidationType Uses

func (m *ParameterValidation) GetValidationType() isParameterValidation_ValidationType

func (*ParameterValidation) GetValues Uses

func (m *ParameterValidation) GetValues() *ValueValidation

func (*ParameterValidation) ProtoMessage Uses

func (*ParameterValidation) ProtoMessage()

func (*ParameterValidation) Reset Uses

func (m *ParameterValidation) Reset()

func (*ParameterValidation) String Uses

func (m *ParameterValidation) String() string

func (*ParameterValidation) XXX_DiscardUnknown Uses

func (m *ParameterValidation) XXX_DiscardUnknown()

func (*ParameterValidation) XXX_Marshal Uses

func (m *ParameterValidation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParameterValidation) XXX_Merge Uses

func (m *ParameterValidation) XXX_Merge(src proto.Message)

func (*ParameterValidation) XXX_OneofWrappers Uses

func (*ParameterValidation) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ParameterValidation) XXX_Size Uses

func (m *ParameterValidation) XXX_Size() int

func (*ParameterValidation) XXX_Unmarshal Uses

func (m *ParameterValidation) XXX_Unmarshal(b []byte) error

type ParameterValidation_Regex Uses

type ParameterValidation_Regex struct {
    Regex *RegexValidation `protobuf:"bytes,1,opt,name=regex,proto3,oneof"`
}

type ParameterValidation_Values Uses

type ParameterValidation_Values struct {
    Values *ValueValidation `protobuf:"bytes,2,opt,name=values,proto3,oneof"`
}

type PigJob Uses

type PigJob struct {
    // Required. The sequence of Pig queries to execute, specified as an HCFS
    // file URI or a list of queries.
    //
    // Types that are valid to be assigned to Queries:
    //	*PigJob_QueryFileUri
    //	*PigJob_QueryList
    Queries isPigJob_Queries `protobuf_oneof:"queries"`
    // Optional. Whether to continue executing queries if a query fails.
    // The default value is `false`. Setting to `true` can be useful when
    // executing independent parallel queries.
    ContinueOnFailure bool `protobuf:"varint,3,opt,name=continue_on_failure,json=continueOnFailure,proto3" json:"continue_on_failure,omitempty"`
    // Optional. Mapping of query variable names to values (equivalent to the Pig
    // command: `name=[value]`).
    ScriptVariables map[string]string `protobuf:"bytes,4,rep,name=script_variables,json=scriptVariables,proto3" json:"script_variables,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. A mapping of property names to values, used to configure Pig.
    // Properties that conflict with values set by the Cloud Dataproc API may be
    // overwritten. Can include properties set in /etc/hadoop/conf/*-site.xml,
    // /etc/pig/conf/pig.properties, and classes in user code.
    Properties map[string]string `protobuf:"bytes,5,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. HCFS URIs of jar files to add to the CLASSPATH of
    // the Pig Client and Hadoop MapReduce (MR) tasks. Can contain Pig UDFs.
    JarFileUris []string `protobuf:"bytes,6,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"`
    // Optional. The runtime log config for job execution.
    LoggingConfig        *LoggingConfig `protobuf:"bytes,7,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

A Cloud Dataproc job for running [Apache Pig](https://pig.apache.org/) queries on YARN.

func (*PigJob) Descriptor Uses

func (*PigJob) Descriptor() ([]byte, []int)

func (*PigJob) GetContinueOnFailure Uses

func (m *PigJob) GetContinueOnFailure() bool

func (*PigJob) GetJarFileUris Uses

func (m *PigJob) GetJarFileUris() []string

func (*PigJob) GetLoggingConfig Uses

func (m *PigJob) GetLoggingConfig() *LoggingConfig

func (*PigJob) GetProperties Uses

func (m *PigJob) GetProperties() map[string]string

func (*PigJob) GetQueries Uses

func (m *PigJob) GetQueries() isPigJob_Queries

func (*PigJob) GetQueryFileUri Uses

func (m *PigJob) GetQueryFileUri() string

func (*PigJob) GetQueryList Uses

func (m *PigJob) GetQueryList() *QueryList

func (*PigJob) GetScriptVariables Uses

func (m *PigJob) GetScriptVariables() map[string]string

func (*PigJob) ProtoMessage Uses

func (*PigJob) ProtoMessage()

func (*PigJob) Reset Uses

func (m *PigJob) Reset()

func (*PigJob) String Uses

func (m *PigJob) String() string

func (*PigJob) XXX_DiscardUnknown Uses

func (m *PigJob) XXX_DiscardUnknown()

func (*PigJob) XXX_Marshal Uses

func (m *PigJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PigJob) XXX_Merge Uses

func (m *PigJob) XXX_Merge(src proto.Message)

func (*PigJob) XXX_OneofWrappers Uses

func (*PigJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PigJob) XXX_Size Uses

func (m *PigJob) XXX_Size() int

func (*PigJob) XXX_Unmarshal Uses

func (m *PigJob) XXX_Unmarshal(b []byte) error

type PigJob_QueryFileUri Uses

type PigJob_QueryFileUri struct {
    QueryFileUri string `protobuf:"bytes,1,opt,name=query_file_uri,json=queryFileUri,proto3,oneof"`
}

type PigJob_QueryList Uses

type PigJob_QueryList struct {
    QueryList *QueryList `protobuf:"bytes,2,opt,name=query_list,json=queryList,proto3,oneof"`
}

type PySparkJob Uses

type PySparkJob struct {
    // Required. The HCFS URI of the main Python file to use as the driver. Must
    // be a .py file.
    MainPythonFileUri string `protobuf:"bytes,1,opt,name=main_python_file_uri,json=mainPythonFileUri,proto3" json:"main_python_file_uri,omitempty"`
    // Optional. The arguments to pass to the driver.  Do not include arguments,
    // such as `--conf`, that can be set as job properties, since a collision may
    // occur that causes an incorrect job submission.
    Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
    // Optional. HCFS file URIs of Python files to pass to the PySpark
    // framework. Supported file types: .py, .egg, and .zip.
    PythonFileUris []string `protobuf:"bytes,3,rep,name=python_file_uris,json=pythonFileUris,proto3" json:"python_file_uris,omitempty"`
    // Optional. HCFS URIs of jar files to add to the CLASSPATHs of the
    // Python driver and tasks.
    JarFileUris []string `protobuf:"bytes,4,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"`
    // Optional. HCFS URIs of files to be copied to the working directory of
    // Python drivers and distributed tasks. Useful for naively parallel tasks.
    FileUris []string `protobuf:"bytes,5,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"`
    // Optional. HCFS URIs of archives to be extracted in the working directory of
    // .jar, .tar, .tar.gz, .tgz, and .zip.
    ArchiveUris []string `protobuf:"bytes,6,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"`
    // Optional. A mapping of property names to values, used to configure PySpark.
    // Properties that conflict with values set by the Cloud Dataproc API may be
    // overwritten. Can include properties set in
    // /etc/spark/conf/spark-defaults.conf and classes in user code.
    Properties map[string]string `protobuf:"bytes,7,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. The runtime log config for job execution.
    LoggingConfig        *LoggingConfig `protobuf:"bytes,8,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

A Cloud Dataproc job for running [Apache PySpark](https://spark.apache.org/docs/0.9.0/python-programming-guide.html) applications on YARN.

func (*PySparkJob) Descriptor Uses

func (*PySparkJob) Descriptor() ([]byte, []int)

func (*PySparkJob) GetArchiveUris Uses

func (m *PySparkJob) GetArchiveUris() []string

func (*PySparkJob) GetArgs Uses

func (m *PySparkJob) GetArgs() []string

func (*PySparkJob) GetFileUris Uses

func (m *PySparkJob) GetFileUris() []string

func (*PySparkJob) GetJarFileUris Uses

func (m *PySparkJob) GetJarFileUris() []string

func (*PySparkJob) GetLoggingConfig Uses

func (m *PySparkJob) GetLoggingConfig() *LoggingConfig

func (*PySparkJob) GetMainPythonFileUri Uses

func (m *PySparkJob) GetMainPythonFileUri() string

func (*PySparkJob) GetProperties Uses

func (m *PySparkJob) GetProperties() map[string]string

func (*PySparkJob) GetPythonFileUris Uses

func (m *PySparkJob) GetPythonFileUris() []string

func (*PySparkJob) ProtoMessage Uses

func (*PySparkJob) ProtoMessage()

func (*PySparkJob) Reset Uses

func (m *PySparkJob) Reset()

func (*PySparkJob) String Uses

func (m *PySparkJob) String() string

func (*PySparkJob) XXX_DiscardUnknown Uses

func (m *PySparkJob) XXX_DiscardUnknown()

func (*PySparkJob) XXX_Marshal Uses

func (m *PySparkJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PySparkJob) XXX_Merge Uses

func (m *PySparkJob) XXX_Merge(src proto.Message)

func (*PySparkJob) XXX_Size Uses

func (m *PySparkJob) XXX_Size() int

func (*PySparkJob) XXX_Unmarshal Uses

func (m *PySparkJob) XXX_Unmarshal(b []byte) error

type QueryList Uses

type QueryList struct {
    // Required. The queries to execute. You do not need to terminate a query
    // with a semicolon. Multiple queries can be specified in one string
    // by separating each with a semicolon. Here is an example of an Cloud
    // Dataproc API snippet that uses a QueryList to specify a HiveJob:
    //
    //     "hiveJob": {
    //       "queryList": {
    //         "queries": [
    //           "query1",
    //           "query2",
    //           "query3;query4",
    //         ]
    //       }
    //     }
    Queries              []string `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A list of queries to run on a cluster.

func (*QueryList) Descriptor Uses

func (*QueryList) Descriptor() ([]byte, []int)

func (*QueryList) GetQueries Uses

func (m *QueryList) GetQueries() []string

func (*QueryList) ProtoMessage Uses

func (*QueryList) ProtoMessage()

func (*QueryList) Reset Uses

func (m *QueryList) Reset()

func (*QueryList) String Uses

func (m *QueryList) String() string

func (*QueryList) XXX_DiscardUnknown Uses

func (m *QueryList) XXX_DiscardUnknown()

func (*QueryList) XXX_Marshal Uses

func (m *QueryList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryList) XXX_Merge Uses

func (m *QueryList) XXX_Merge(src proto.Message)

func (*QueryList) XXX_Size Uses

func (m *QueryList) XXX_Size() int

func (*QueryList) XXX_Unmarshal Uses

func (m *QueryList) XXX_Unmarshal(b []byte) error

type RegexValidation Uses

type RegexValidation struct {
    // Required. RE2 regular expressions used to validate the parameter's value.
    // The value must match the regex in its entirety (substring
    // matches are not sufficient).
    Regexes              []string `protobuf:"bytes,1,rep,name=regexes,proto3" json:"regexes,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Validation based on regular expressions.

func (*RegexValidation) Descriptor Uses

func (*RegexValidation) Descriptor() ([]byte, []int)

func (*RegexValidation) GetRegexes Uses

func (m *RegexValidation) GetRegexes() []string

func (*RegexValidation) ProtoMessage Uses

func (*RegexValidation) ProtoMessage()

func (*RegexValidation) Reset Uses

func (m *RegexValidation) Reset()

func (*RegexValidation) String Uses

func (m *RegexValidation) String() string

func (*RegexValidation) XXX_DiscardUnknown Uses

func (m *RegexValidation) XXX_DiscardUnknown()

func (*RegexValidation) XXX_Marshal Uses

func (m *RegexValidation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegexValidation) XXX_Merge Uses

func (m *RegexValidation) XXX_Merge(src proto.Message)

func (*RegexValidation) XXX_Size Uses

func (m *RegexValidation) XXX_Size() int

func (*RegexValidation) XXX_Unmarshal Uses

func (m *RegexValidation) XXX_Unmarshal(b []byte) error

type SoftwareConfig Uses

type SoftwareConfig struct {
    // Optional. The version of software inside the cluster. It must be one of the
    // supported [Cloud Dataproc
    // Versions](/dataproc/docs/concepts/versioning/dataproc-versions#supported_cloud_dataproc_versions),
    // such as "1.2" (including a subminor version, such as "1.2.29"), or the
    // ["preview"
    // version](/dataproc/docs/concepts/versioning/dataproc-versions#other_versions).
    // If unspecified, it defaults to the latest Debian version.
    ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`
    // Optional. The properties to set on daemon config files.
    //
    // Property keys are specified in `prefix:property` format, for example
    // `core:hadoop.tmp.dir`. The following are supported prefixes
    // and their mappings:
    //
    // * capacity-scheduler: `capacity-scheduler.xml`
    // * core:   `core-site.xml`
    // * distcp: `distcp-default.xml`
    // * hdfs:   `hdfs-site.xml`
    // * hive:   `hive-site.xml`
    // * mapred: `mapred-site.xml`
    // * pig:    `pig.properties`
    // * spark:  `spark-defaults.conf`
    // * yarn:   `yarn-site.xml`
    //
    // For more information, see
    // [Cluster properties](/dataproc/docs/concepts/cluster-properties).
    Properties map[string]string `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // The set of optional components to activate on the cluster.
    OptionalComponents   []Component `protobuf:"varint,3,rep,packed,name=optional_components,json=optionalComponents,proto3,enum=google.cloud.dataproc.v1.Component" json:"optional_components,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

Specifies the selection and config of software inside the cluster.

func (*SoftwareConfig) Descriptor Uses

func (*SoftwareConfig) Descriptor() ([]byte, []int)

func (*SoftwareConfig) GetImageVersion Uses

func (m *SoftwareConfig) GetImageVersion() string

func (*SoftwareConfig) GetOptionalComponents Uses

func (m *SoftwareConfig) GetOptionalComponents() []Component

func (*SoftwareConfig) GetProperties Uses

func (m *SoftwareConfig) GetProperties() map[string]string

func (*SoftwareConfig) ProtoMessage Uses

func (*SoftwareConfig) ProtoMessage()

func (*SoftwareConfig) Reset Uses

func (m *SoftwareConfig) Reset()

func (*SoftwareConfig) String Uses

func (m *SoftwareConfig) String() string

func (*SoftwareConfig) XXX_DiscardUnknown Uses

func (m *SoftwareConfig) XXX_DiscardUnknown()

func (*SoftwareConfig) XXX_Marshal Uses

func (m *SoftwareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SoftwareConfig) XXX_Merge Uses

func (m *SoftwareConfig) XXX_Merge(src proto.Message)

func (*SoftwareConfig) XXX_Size Uses

func (m *SoftwareConfig) XXX_Size() int

func (*SoftwareConfig) XXX_Unmarshal Uses

func (m *SoftwareConfig) XXX_Unmarshal(b []byte) error

type SparkJob Uses

type SparkJob struct {
    // Required. The specification of the main method to call to drive the job.
    // Specify either the jar file that contains the main class or the main class
    // name. To pass both a main jar and a main class in that jar, add the jar to
    // `CommonJob.jar_file_uris`, and then specify the main class name in
    // `main_class`.
    //
    // Types that are valid to be assigned to Driver:
    //	*SparkJob_MainJarFileUri
    //	*SparkJob_MainClass
    Driver isSparkJob_Driver `protobuf_oneof:"driver"`
    // Optional. The arguments to pass to the driver. Do not include arguments,
    // such as `--conf`, that can be set as job properties, since a collision may
    // occur that causes an incorrect job submission.
    Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
    // Optional. HCFS URIs of jar files to add to the CLASSPATHs of the
    // Spark driver and tasks.
    JarFileUris []string `protobuf:"bytes,4,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"`
    // Optional. HCFS URIs of files to be copied to the working directory of
    // Spark drivers and distributed tasks. Useful for naively parallel tasks.
    FileUris []string `protobuf:"bytes,5,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"`
    // Optional. HCFS URIs of archives to be extracted in the working directory
    // of Spark drivers and tasks. Supported file types:
    // .jar, .tar, .tar.gz, .tgz, and .zip.
    ArchiveUris []string `protobuf:"bytes,6,rep,name=archive_uris,json=archiveUris,proto3" json:"archive_uris,omitempty"`
    // Optional. A mapping of property names to values, used to configure Spark.
    // Properties that conflict with values set by the Cloud Dataproc API may be
    // overwritten. Can include properties set in
    // /etc/spark/conf/spark-defaults.conf and classes in user code.
    Properties map[string]string `protobuf:"bytes,7,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. The runtime log config for job execution.
    LoggingConfig        *LoggingConfig `protobuf:"bytes,8,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

A Cloud Dataproc job for running [Apache Spark](http://spark.apache.org/) applications on YARN.

func (*SparkJob) Descriptor Uses

func (*SparkJob) Descriptor() ([]byte, []int)

func (*SparkJob) GetArchiveUris Uses

func (m *SparkJob) GetArchiveUris() []string

func (*SparkJob) GetArgs Uses

func (m *SparkJob) GetArgs() []string

func (*SparkJob) GetDriver Uses

func (m *SparkJob) GetDriver() isSparkJob_Driver

func (*SparkJob) GetFileUris Uses

func (m *SparkJob) GetFileUris() []string

func (*SparkJob) GetJarFileUris Uses

func (m *SparkJob) GetJarFileUris() []string

func (*SparkJob) GetLoggingConfig Uses

func (m *SparkJob) GetLoggingConfig() *LoggingConfig

func (*SparkJob) GetMainClass Uses

func (m *SparkJob) GetMainClass() string

func (*SparkJob) GetMainJarFileUri Uses

func (m *SparkJob) GetMainJarFileUri() string

func (*SparkJob) GetProperties Uses

func (m *SparkJob) GetProperties() map[string]string

func (*SparkJob) ProtoMessage Uses

func (*SparkJob) ProtoMessage()

func (*SparkJob) Reset Uses

func (m *SparkJob) Reset()

func (*SparkJob) String Uses

func (m *SparkJob) String() string

func (*SparkJob) XXX_DiscardUnknown Uses

func (m *SparkJob) XXX_DiscardUnknown()

func (*SparkJob) XXX_Marshal Uses

func (m *SparkJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SparkJob) XXX_Merge Uses

func (m *SparkJob) XXX_Merge(src proto.Message)

func (*SparkJob) XXX_OneofWrappers Uses

func (*SparkJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SparkJob) XXX_Size Uses

func (m *SparkJob) XXX_Size() int

func (*SparkJob) XXX_Unmarshal Uses

func (m *SparkJob) XXX_Unmarshal(b []byte) error

type SparkJob_MainClass Uses

type SparkJob_MainClass struct {
    MainClass string `protobuf:"bytes,2,opt,name=main_class,json=mainClass,proto3,oneof"`
}

type SparkJob_MainJarFileUri Uses

type SparkJob_MainJarFileUri struct {
    MainJarFileUri string `protobuf:"bytes,1,opt,name=main_jar_file_uri,json=mainJarFileUri,proto3,oneof"`
}

type SparkSqlJob Uses

type SparkSqlJob struct {
    // Required. The sequence of Spark SQL queries to execute, specified as
    // either an HCFS file URI or as a list of queries.
    //
    // Types that are valid to be assigned to Queries:
    //	*SparkSqlJob_QueryFileUri
    //	*SparkSqlJob_QueryList
    Queries isSparkSqlJob_Queries `protobuf_oneof:"queries"`
    // Optional. Mapping of query variable names to values (equivalent to the
    // Spark SQL command: SET `name="value";`).
    ScriptVariables map[string]string `protobuf:"bytes,3,rep,name=script_variables,json=scriptVariables,proto3" json:"script_variables,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. A mapping of property names to values, used to configure
    // Spark SQL's SparkConf. Properties that conflict with values set by the
    // Cloud Dataproc API may be overwritten.
    Properties map[string]string `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH.
    JarFileUris []string `protobuf:"bytes,56,rep,name=jar_file_uris,json=jarFileUris,proto3" json:"jar_file_uris,omitempty"`
    // Optional. The runtime log config for job execution.
    LoggingConfig        *LoggingConfig `protobuf:"bytes,6,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

A Cloud Dataproc job for running [Apache Spark SQL](http://spark.apache.org/sql/) queries.

func (*SparkSqlJob) Descriptor Uses

func (*SparkSqlJob) Descriptor() ([]byte, []int)

func (*SparkSqlJob) GetJarFileUris Uses

func (m *SparkSqlJob) GetJarFileUris() []string

func (*SparkSqlJob) GetLoggingConfig Uses

func (m *SparkSqlJob) GetLoggingConfig() *LoggingConfig

func (*SparkSqlJob) GetProperties Uses

func (m *SparkSqlJob) GetProperties() map[string]string

func (*SparkSqlJob) GetQueries Uses

func (m *SparkSqlJob) GetQueries() isSparkSqlJob_Queries

func (*SparkSqlJob) GetQueryFileUri Uses

func (m *SparkSqlJob) GetQueryFileUri() string

func (*SparkSqlJob) GetQueryList Uses

func (m *SparkSqlJob) GetQueryList() *QueryList

func (*SparkSqlJob) GetScriptVariables Uses

func (m *SparkSqlJob) GetScriptVariables() map[string]string

func (*SparkSqlJob) ProtoMessage Uses

func (*SparkSqlJob) ProtoMessage()

func (*SparkSqlJob) Reset Uses

func (m *SparkSqlJob) Reset()

func (*SparkSqlJob) String Uses

func (m *SparkSqlJob) String() string

func (*SparkSqlJob) XXX_DiscardUnknown Uses

func (m *SparkSqlJob) XXX_DiscardUnknown()

func (*SparkSqlJob) XXX_Marshal Uses

func (m *SparkSqlJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SparkSqlJob) XXX_Merge Uses

func (m *SparkSqlJob) XXX_Merge(src proto.Message)

func (*SparkSqlJob) XXX_OneofWrappers Uses

func (*SparkSqlJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SparkSqlJob) XXX_Size Uses

func (m *SparkSqlJob) XXX_Size() int

func (*SparkSqlJob) XXX_Unmarshal Uses

func (m *SparkSqlJob) XXX_Unmarshal(b []byte) error

type SparkSqlJob_QueryFileUri Uses

type SparkSqlJob_QueryFileUri struct {
    QueryFileUri string `protobuf:"bytes,1,opt,name=query_file_uri,json=queryFileUri,proto3,oneof"`
}

type SparkSqlJob_QueryList Uses

type SparkSqlJob_QueryList struct {
    QueryList *QueryList `protobuf:"bytes,2,opt,name=query_list,json=queryList,proto3,oneof"`
}

type SubmitJobRequest Uses

type SubmitJobRequest struct {
    // Required. The ID of the Google Cloud Platform project that the job
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The job resource.
    Job *Job `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
    // Optional. A unique id used to identify the request. If the server
    // receives two [SubmitJobRequest][google.cloud.dataproc.v1.SubmitJobRequest] requests  with the same
    // id, then the second request will be ignored and the
    // first [Job][google.cloud.dataproc.v1.Job] created and stored in the backend
    // is returned.
    //
    // It is recommended to always set this value to a
    // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier).
    //
    // The id must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), and hyphens (-). The maximum length is 40 characters.
    RequestId            string   `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to submit a job.

func (*SubmitJobRequest) Descriptor Uses

func (*SubmitJobRequest) Descriptor() ([]byte, []int)

func (*SubmitJobRequest) GetJob Uses

func (m *SubmitJobRequest) GetJob() *Job

func (*SubmitJobRequest) GetProjectId Uses

func (m *SubmitJobRequest) GetProjectId() string

func (*SubmitJobRequest) GetRegion Uses

func (m *SubmitJobRequest) GetRegion() string

func (*SubmitJobRequest) GetRequestId Uses

func (m *SubmitJobRequest) GetRequestId() string

func (*SubmitJobRequest) ProtoMessage Uses

func (*SubmitJobRequest) ProtoMessage()

func (*SubmitJobRequest) Reset Uses

func (m *SubmitJobRequest) Reset()

func (*SubmitJobRequest) String Uses

func (m *SubmitJobRequest) String() string

func (*SubmitJobRequest) XXX_DiscardUnknown Uses

func (m *SubmitJobRequest) XXX_DiscardUnknown()

func (*SubmitJobRequest) XXX_Marshal Uses

func (m *SubmitJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubmitJobRequest) XXX_Merge Uses

func (m *SubmitJobRequest) XXX_Merge(src proto.Message)

func (*SubmitJobRequest) XXX_Size Uses

func (m *SubmitJobRequest) XXX_Size() int

func (*SubmitJobRequest) XXX_Unmarshal Uses

func (m *SubmitJobRequest) XXX_Unmarshal(b []byte) error

type TemplateParameter Uses

type TemplateParameter struct {
    // Required.  Parameter name.
    // The parameter name is used as the key, and paired with the
    // parameter value, which are passed to the template when the template
    // is instantiated.
    // The name must contain only capital letters (A-Z), numbers (0-9), and
    // underscores (_), and must not start with a number. The maximum length is
    // 40 characters.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Required. Paths to all fields that the parameter replaces.
    // A field is allowed to appear in at most one parameter's list of field
    // paths.
    //
    // A field path is similar in syntax to a [google.protobuf.FieldMask][google.protobuf.FieldMask].
    // For example, a field path that references the zone field of a workflow
    // template's cluster selector would be specified as
    // `placement.clusterSelector.zone`.
    //
    // Also, field paths can reference fields using the following syntax:
    //
    // * Values in maps can be referenced by key:
    //     * labels['key']
    //     * placement.clusterSelector.clusterLabels['key']
    //     * placement.managedCluster.labels['key']
    //     * placement.clusterSelector.clusterLabels['key']
    //     * jobs['step-id'].labels['key']
    //
    // * Jobs in the jobs list can be referenced by step-id:
    //     * jobs['step-id'].hadoopJob.mainJarFileUri
    //     * jobs['step-id'].hiveJob.queryFileUri
    //     * jobs['step-id'].pySparkJob.mainPythonFileUri
    //     * jobs['step-id'].hadoopJob.jarFileUris[0]
    //     * jobs['step-id'].hadoopJob.archiveUris[0]
    //     * jobs['step-id'].hadoopJob.fileUris[0]
    //     * jobs['step-id'].pySparkJob.pythonFileUris[0]
    //
    // * Items in repeated fields can be referenced by a zero-based index:
    //     * jobs['step-id'].sparkJob.args[0]
    //
    // * Other examples:
    //     * jobs['step-id'].hadoopJob.properties['key']
    //     * jobs['step-id'].hadoopJob.args[0]
    //     * jobs['step-id'].hiveJob.scriptVariables['key']
    //     * jobs['step-id'].hadoopJob.mainJarFileUri
    //     * placement.clusterSelector.zone
    //
    // It may not be possible to parameterize maps and repeated fields in their
    // entirety since only individual map values and individual items in repeated
    // fields can be referenced. For example, the following field paths are
    // invalid:
    //
    // - placement.clusterSelector.clusterLabels
    // - jobs['step-id'].sparkJob.args
    Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
    // Optional. Brief description of the parameter.
    // Must not exceed 1024 characters.
    Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
    // Optional. Validation rules to be applied to this parameter's value.
    Validation           *ParameterValidation `protobuf:"bytes,4,opt,name=validation,proto3" json:"validation,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

A configurable parameter that replaces one or more fields in the template. Parameterizable fields: - Labels - File uris - Job properties - Job arguments - Script variables - Main class (in HadoopJob and SparkJob) - Zone (in ClusterSelector)

func (*TemplateParameter) Descriptor Uses

func (*TemplateParameter) Descriptor() ([]byte, []int)

func (*TemplateParameter) GetDescription Uses

func (m *TemplateParameter) GetDescription() string

func (*TemplateParameter) GetFields Uses

func (m *TemplateParameter) GetFields() []string

func (*TemplateParameter) GetName Uses

func (m *TemplateParameter) GetName() string

func (*TemplateParameter) GetValidation Uses

func (m *TemplateParameter) GetValidation() *ParameterValidation

func (*TemplateParameter) ProtoMessage Uses

func (*TemplateParameter) ProtoMessage()

func (*TemplateParameter) Reset Uses

func (m *TemplateParameter) Reset()

func (*TemplateParameter) String Uses

func (m *TemplateParameter) String() string

func (*TemplateParameter) XXX_DiscardUnknown Uses

func (m *TemplateParameter) XXX_DiscardUnknown()

func (*TemplateParameter) XXX_Marshal Uses

func (m *TemplateParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TemplateParameter) XXX_Merge Uses

func (m *TemplateParameter) XXX_Merge(src proto.Message)

func (*TemplateParameter) XXX_Size Uses

func (m *TemplateParameter) XXX_Size() int

func (*TemplateParameter) XXX_Unmarshal Uses

func (m *TemplateParameter) XXX_Unmarshal(b []byte) error

type UpdateClusterRequest Uses

type UpdateClusterRequest struct {
    // Required. The ID of the Google Cloud Platform project the
    // cluster belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,5,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The cluster name.
    ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    // Required. The changes to the cluster.
    Cluster *Cluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
    // Optional. Timeout for graceful YARN decomissioning. Graceful
    // decommissioning allows removing nodes from the cluster without
    // interrupting jobs in progress. Timeout specifies how long to wait for jobs
    // in progress to finish before forcefully removing nodes (and potentially
    // interrupting jobs). Default timeout is 0 (for forceful decommission), and
    // the maximum allowed timeout is 1 day.
    //
    // Only supported on Dataproc image versions 1.2 and higher.
    GracefulDecommissionTimeout *duration.Duration `protobuf:"bytes,6,opt,name=graceful_decommission_timeout,json=gracefulDecommissionTimeout,proto3" json:"graceful_decommission_timeout,omitempty"`
    // Required. Specifies the path, relative to `Cluster`, of
    // the field to update. For example, to change the number of workers
    // in a cluster to 5, the `update_mask` parameter would be
    // specified as `config.worker_config.num_instances`,
    // and the `PATCH` request body would specify the new value, as follows:
    //
    //     {
    //       "config":{
    //         "workerConfig":{
    //           "numInstances":"5"
    //         }
    //       }
    //     }
    // Similarly, to change the number of preemptible workers in a cluster to 5,
    // the `update_mask` parameter would be
    // `config.secondary_worker_config.num_instances`, and the `PATCH` request
    // body would be set as follows:
    //
    //     {
    //       "config":{
    //         "secondaryWorkerConfig":{
    //           "numInstances":"5"
    //         }
    //       }
    //     }
    // <strong>Note:</strong> Currently, only the following fields can be updated:
    //
    //  <table>
    //  <tbody>
    //  <tr>
    //  <td><strong>Mask</strong></td>
    //  <td><strong>Purpose</strong></td>
    //  </tr>
    //  <tr>
    //  <td><strong><em>labels</em></strong></td>
    //  <td>Update labels</td>
    //  </tr>
    //  <tr>
    //  <td><strong><em>config.worker_config.num_instances</em></strong></td>
    //  <td>Resize primary worker group</td>
    //  </tr>
    //  <tr>
    //  <td><strong><em>config.secondary_worker_config.num_instances</em></strong></td>
    //  <td>Resize secondary worker group</td>
    //  </tr>
    //  </tbody>
    //  </table>
    UpdateMask *field_mask.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
    // Optional. A unique id used to identify the request. If the server
    // receives two [UpdateClusterRequest][google.cloud.dataproc.v1.UpdateClusterRequest] requests  with the same
    // id, then the second request will be ignored and the
    // first [google.longrunning.Operation][google.longrunning.Operation] created and stored in the
    // backend is returned.
    //
    // It is recommended to always set this value to a
    // [UUID](https://en.wikipedia.org/wiki/Universally_unique_identifier).
    //
    // The id must contain only letters (a-z, A-Z), numbers (0-9),
    // underscores (_), and hyphens (-). The maximum length is 40 characters.
    RequestId            string   `protobuf:"bytes,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A request to update a cluster.

func (*UpdateClusterRequest) Descriptor Uses

func (*UpdateClusterRequest) Descriptor() ([]byte, []int)

func (*UpdateClusterRequest) GetCluster Uses

func (m *UpdateClusterRequest) GetCluster() *Cluster

func (*UpdateClusterRequest) GetClusterName Uses

func (m *UpdateClusterRequest) GetClusterName() string

func (*UpdateClusterRequest) GetGracefulDecommissionTimeout Uses

func (m *UpdateClusterRequest) GetGracefulDecommissionTimeout() *duration.Duration

func (*UpdateClusterRequest) GetProjectId Uses

func (m *UpdateClusterRequest) GetProjectId() string

func (*UpdateClusterRequest) GetRegion Uses

func (m *UpdateClusterRequest) GetRegion() string

func (*UpdateClusterRequest) GetRequestId Uses

func (m *UpdateClusterRequest) GetRequestId() string

func (*UpdateClusterRequest) GetUpdateMask Uses

func (m *UpdateClusterRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateClusterRequest) ProtoMessage Uses

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) Reset Uses

func (m *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String Uses

func (m *UpdateClusterRequest) String() string

func (*UpdateClusterRequest) XXX_DiscardUnknown Uses

func (m *UpdateClusterRequest) XXX_DiscardUnknown()

func (*UpdateClusterRequest) XXX_Marshal Uses

func (m *UpdateClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateClusterRequest) XXX_Merge Uses

func (m *UpdateClusterRequest) XXX_Merge(src proto.Message)

func (*UpdateClusterRequest) XXX_Size Uses

func (m *UpdateClusterRequest) XXX_Size() int

func (*UpdateClusterRequest) XXX_Unmarshal Uses

func (m *UpdateClusterRequest) XXX_Unmarshal(b []byte) error

type UpdateJobRequest Uses

type UpdateJobRequest struct {
    // Required. The ID of the Google Cloud Platform project that the job
    // belongs to.
    ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
    // Required. The Cloud Dataproc region in which to handle the request.
    Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
    // Required. The job ID.
    JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
    // Required. The changes to the job.
    Job *Job `protobuf:"bytes,4,opt,name=job,proto3" json:"job,omitempty"`
    // Required. Specifies the path, relative to <code>Job</code>, of
    // the field to update. For example, to update the labels of a Job the
    // <code>update_mask</code> parameter would be specified as
    // <code>labels</code>, and the `PATCH` request body would specify the new
    // value. <strong>Note:</strong> Currently, <code>labels</code> is the only
    // field that can be updated.
    UpdateMask           *field_mask.FieldMask `protobuf:"bytes,5,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

A request to update a job.

func (*UpdateJobRequest) Descriptor Uses

func (*UpdateJobRequest) Descriptor() ([]byte, []int)

func (*UpdateJobRequest) GetJob Uses

func (m *UpdateJobRequest) GetJob() *Job

func (*UpdateJobRequest) GetJobId Uses

func (m *UpdateJobRequest) GetJobId() string

func (*UpdateJobRequest) GetProjectId Uses

func (m *UpdateJobRequest) GetProjectId() string

func (*UpdateJobRequest) GetRegion Uses

func (m *UpdateJobRequest) GetRegion() string

func (*UpdateJobRequest) GetUpdateMask Uses

func (m *UpdateJobRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateJobRequest) ProtoMessage Uses

func (*UpdateJobRequest) ProtoMessage()

func (*UpdateJobRequest) Reset Uses

func (m *UpdateJobRequest) Reset()

func (*UpdateJobRequest) String Uses

func (m *UpdateJobRequest) String() string

func (*UpdateJobRequest) XXX_DiscardUnknown Uses

func (m *UpdateJobRequest) XXX_DiscardUnknown()

func (*UpdateJobRequest) XXX_Marshal Uses

func (m *UpdateJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateJobRequest) XXX_Merge Uses

func (m *UpdateJobRequest) XXX_Merge(src proto.Message)

func (*UpdateJobRequest) XXX_Size Uses

func (m *UpdateJobRequest) XXX_Size() int

func (*UpdateJobRequest) XXX_Unmarshal Uses

func (m *