public sealed class JobControllerClientImpl : JobControllerClientJobController client wrapper implementation, for convenient use.
Namespace
Google.Cloud.Dataproc.V1Assembly
Google.Cloud.Dataproc.V1.dll
Remarks
The JobController provides methods to manage jobs.
Constructors
JobControllerClientImpl(JobController.JobControllerClient, JobControllerSettings, ILogger)
public JobControllerClientImpl(JobController.JobControllerClient grpcClient, JobControllerSettings settings, ILogger logger)Constructs a client wrapper for the JobController service, with the specified gRPC client and settings.
| Parameters | |
|---|---|
| Name | Description |
grpcClient |
JobController.JobControllerClientThe underlying gRPC client. |
settings |
JobControllerSettingsThe base JobControllerSettings used within this client. |
logger |
ILoggerOptional ILogger to use within this client. |
Properties
GrpcClient
public override JobController.JobControllerClient GrpcClient { get; }The underlying gRPC JobController client
| Property Value | |
|---|---|
| Type | Description |
JobController.JobControllerClient |
|
SubmitJobAsOperationOperationsClient
public override OperationsClient SubmitJobAsOperationOperationsClient { get; }The long-running operations client for SubmitJobAsOperation.
| Property Value | |
|---|---|
| Type | Description |
OperationsClient |
|
Methods
CancelJob(CancelJobRequest, CallSettings)
public override Job CancelJob(CancelJobRequest request, CallSettings callSettings = null)Starts a job cancellation request. To access the job resource after cancellation, call regions/{region}/jobs.list or regions/{region}/jobs.get.
| Parameters | |
|---|---|
| Name | Description |
request |
CancelJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Job |
The RPC response. |
CancelJobAsync(CancelJobRequest, CallSettings)
public override Task<Job> CancelJobAsync(CancelJobRequest request, CallSettings callSettings = null)Starts a job cancellation request. To access the job resource after cancellation, call regions/{region}/jobs.list or regions/{region}/jobs.get.
| Parameters | |
|---|---|
| Name | Description |
request |
CancelJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Task<Job> |
A Task containing the RPC response. |
DeleteJob(DeleteJobRequest, CallSettings)
public override void DeleteJob(DeleteJobRequest request, CallSettings callSettings = null)Deletes the job from the project. If the job is active, the delete fails,
and the response returns FAILED_PRECONDITION.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
DeleteJobAsync(DeleteJobRequest, CallSettings)
public override Task DeleteJobAsync(DeleteJobRequest request, CallSettings callSettings = null)Deletes the job from the project. If the job is active, the delete fails,
and the response returns FAILED_PRECONDITION.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Task |
A Task containing the RPC response. |
GetJob(GetJobRequest, CallSettings)
public override Job GetJob(GetJobRequest request, CallSettings callSettings = null)Gets the resource representation for a job in a project.
| Parameters | |
|---|---|
| Name | Description |
request |
GetJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Job |
The RPC response. |
GetJobAsync(GetJobRequest, CallSettings)
public override Task<Job> GetJobAsync(GetJobRequest request, CallSettings callSettings = null)Gets the resource representation for a job in a project.
| Parameters | |
|---|---|
| Name | Description |
request |
GetJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Task<Job> |
A Task containing the RPC response. |
ListJobs(ListJobsRequest, CallSettings)
public override PagedEnumerable<ListJobsResponse, Job> ListJobs(ListJobsRequest request, CallSettings callSettings = null)Lists regions/{region}/jobs in a project.
| Parameters | |
|---|---|
| Name | Description |
request |
ListJobsRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
PagedEnumerable<ListJobsResponse, Job> |
A pageable sequence of Job resources. |
ListJobsAsync(ListJobsRequest, CallSettings)
public override PagedAsyncEnumerable<ListJobsResponse, Job> ListJobsAsync(ListJobsRequest request, CallSettings callSettings = null)Lists regions/{region}/jobs in a project.
| Parameters | |
|---|---|
| Name | Description |
request |
ListJobsRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
PagedAsyncEnumerable<ListJobsResponse, Job> |
A pageable asynchronous sequence of Job resources. |
SubmitJob(SubmitJobRequest, CallSettings)
public override Job SubmitJob(SubmitJobRequest request, CallSettings callSettings = null)Submits a job to a cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
SubmitJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Job |
The RPC response. |
SubmitJobAsOperation(SubmitJobRequest, CallSettings)
public override Operation<Job, JobMetadata> SubmitJobAsOperation(SubmitJobRequest request, CallSettings callSettings = null)Submits job to a cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
SubmitJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Operation<Job, JobMetadata> |
The RPC response. |
SubmitJobAsOperationAsync(SubmitJobRequest, CallSettings)
public override async Task<Operation<Job, JobMetadata>> SubmitJobAsOperationAsync(SubmitJobRequest request, CallSettings callSettings = null)Submits job to a cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
SubmitJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Task<Operation<Job, JobMetadata>> |
A Task containing the RPC response. |
SubmitJobAsync(SubmitJobRequest, CallSettings)
public override Task<Job> SubmitJobAsync(SubmitJobRequest request, CallSettings callSettings = null)Submits a job to a cluster.
| Parameters | |
|---|---|
| Name | Description |
request |
SubmitJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Task<Job> |
A Task containing the RPC response. |
UpdateJob(UpdateJobRequest, CallSettings)
public override Job UpdateJob(UpdateJobRequest request, CallSettings callSettings = null)Updates a job in a project.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Job |
The RPC response. |
UpdateJobAsync(UpdateJobRequest, CallSettings)
public override Task<Job> UpdateJobAsync(UpdateJobRequest request, CallSettings callSettings = null)Updates a job in a project.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateJobRequestThe request object containing all of the parameters for the API call. |
callSettings |
CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Task<Job> |
A Task containing the RPC response. |