module Google::Cloud::Dataproc

Constants

VERSION

Public Class Methods

autoscaling_policy_service(version: :v1, &block) click to toggle source

Create a new client object for AutoscalingPolicyService.

By default, this returns an instance of [Google::Cloud::Dataproc::V1::AutoscalingPolicyService::Client](googleapis.dev/ruby/google-cloud-dataproc-v1/latest/Google/Cloud/Dataproc/V1/AutoscalingPolicyService/Client.html) for version V1 of the API. However, you can specify specify a different API version by passing it in the `version` parameter. If the AutoscalingPolicyService service is supported by that API version, and the corresponding gem is available, the appropriate versioned client will be returned.

## About AutoscalingPolicyService

The API interface for managing autoscaling policies in the Dataproc API.

@param version [::String, ::Symbol] The API version to connect to. Optional.

Defaults to `:v1`.

@return [AutoscalingPolicyService::Client] A client object for the specified version.

# File lib/google/cloud/dataproc.rb, line 67
def self.autoscaling_policy_service version: :v1, &block
  require "google/cloud/dataproc/#{version.to_s.downcase}"

  package_name = Google::Cloud::Dataproc
                 .constants
                 .select { |sym| sym.to_s.downcase == version.to_s.downcase.tr("_", "") }
                 .first
  package_module = Google::Cloud::Dataproc.const_get package_name
  package_module.const_get(:AutoscalingPolicyService).const_get(:Client).new(&block)
end
cluster_controller(version: :v1, &block) click to toggle source

Create a new client object for ClusterController.

By default, this returns an instance of [Google::Cloud::Dataproc::V1::ClusterController::Client](googleapis.dev/ruby/google-cloud-dataproc-v1/latest/Google/Cloud/Dataproc/V1/ClusterController/Client.html) for version V1 of the API. However, you can specify specify a different API version by passing it in the `version` parameter. If the ClusterController service is supported by that API version, and the corresponding gem is available, the appropriate versioned client will be returned.

## About ClusterController

The ClusterControllerService provides methods to manage clusters of Compute Engine instances.

@param version [::String, ::Symbol] The API version to connect to. Optional.

Defaults to `:v1`.

@return [ClusterController::Client] A client object for the specified version.

# File lib/google/cloud/dataproc.rb, line 98
def self.cluster_controller version: :v1, &block
  require "google/cloud/dataproc/#{version.to_s.downcase}"

  package_name = Google::Cloud::Dataproc
                 .constants
                 .select { |sym| sym.to_s.downcase == version.to_s.downcase.tr("_", "") }
                 .first
  package_module = Google::Cloud::Dataproc.const_get package_name
  package_module.const_get(:ClusterController).const_get(:Client).new(&block)
end
configure() { |configure.dataproc| ... } click to toggle source

Configure the google-cloud-dataproc library.

The following configuration parameters are supported:

  • `credentials` (type: `String, Hash, Google::Auth::Credentials`) - The path to the keyfile as a String, the contents of the keyfile as a Hash, or a Google::Auth::Credentials object.

  • `lib_name` (type: `String`) - The library name as recorded in instrumentation and logging.

  • `lib_version` (type: `String`) - The library version as recorded in instrumentation and logging.

  • `interceptors` (type: `Array<GRPC::ClientInterceptor>`) - An array of interceptors that are run before calls are executed.

  • `timeout` (type: `Numeric`) - Default timeout in seconds.

  • `metadata` (type: `Hash{Symbol=>String}`) - Additional gRPC headers to be sent with the call.

  • `retry_policy` (type: `Hash`) - The retry policy. The value is a hash with the following keys:

    * `:initial_delay` (*type:* `Numeric`) - The initial delay in seconds.
    * `:max_delay` (*type:* `Numeric`) - The max delay in seconds.
    * `:multiplier` (*type:* `Numeric`) - The incremental backoff multiplier.
    * `:retry_codes` (*type:* `Array<String>`) -
      The error codes that should trigger a retry.

@return [::Google::Cloud::Config] The default configuration used by this library

# File lib/google/cloud/dataproc.rb, line 198
def self.configure
  yield ::Google::Cloud.configure.dataproc if block_given?

  ::Google::Cloud.configure.dataproc
end
job_controller(version: :v1, &block) click to toggle source

Create a new client object for JobController.

By default, this returns an instance of [Google::Cloud::Dataproc::V1::JobController::Client](googleapis.dev/ruby/google-cloud-dataproc-v1/latest/Google/Cloud/Dataproc/V1/JobController/Client.html) for version V1 of the API. However, you can specify specify a different API version by passing it in the `version` parameter. If the JobController service is supported by that API version, and the corresponding gem is available, the appropriate versioned client will be returned.

## About JobController

The JobController provides methods to manage jobs.

@param version [::String, ::Symbol] The API version to connect to. Optional.

Defaults to `:v1`.

@return [JobController::Client] A client object for the specified version.

# File lib/google/cloud/dataproc.rb, line 128
def self.job_controller version: :v1, &block
  require "google/cloud/dataproc/#{version.to_s.downcase}"

  package_name = Google::Cloud::Dataproc
                 .constants
                 .select { |sym| sym.to_s.downcase == version.to_s.downcase.tr("_", "") }
                 .first
  package_module = Google::Cloud::Dataproc.const_get package_name
  package_module.const_get(:JobController).const_get(:Client).new(&block)
end
workflow_template_service(version: :v1, &block) click to toggle source

Create a new client object for WorkflowTemplateService.

By default, this returns an instance of [Google::Cloud::Dataproc::V1::WorkflowTemplateService::Client](googleapis.dev/ruby/google-cloud-dataproc-v1/latest/Google/Cloud/Dataproc/V1/WorkflowTemplateService/Client.html) for version V1 of the API. However, you can specify specify a different API version by passing it in the `version` parameter. If the WorkflowTemplateService service is supported by that API version, and the corresponding gem is available, the appropriate versioned client will be returned.

## About WorkflowTemplateService

The API interface for managing Workflow Templates in the Dataproc API.

@param version [::String, ::Symbol] The API version to connect to. Optional.

Defaults to `:v1`.

@return [WorkflowTemplateService::Client] A client object for the specified version.

# File lib/google/cloud/dataproc.rb, line 159
def self.workflow_template_service version: :v1, &block
  require "google/cloud/dataproc/#{version.to_s.downcase}"

  package_name = Google::Cloud::Dataproc
                 .constants
                 .select { |sym| sym.to_s.downcase == version.to_s.downcase.tr("_", "") }
                 .first
  package_module = Google::Cloud::Dataproc.const_get package_name
  package_module.const_get(:WorkflowTemplateService).const_get(:Client).new(&block)
end