diff --git a/java/grpc-google-cloud-dataproc-v1/0.1.29/apidocs/allclasses-frame.html b/java/grpc-google-cloud-dataproc-v1/0.1.29/apidocs/allclasses-frame.html new file mode 100644 index 0000000000..14d6ae4492 --- /dev/null +++ b/java/grpc-google-cloud-dataproc-v1/0.1.29/apidocs/allclasses-frame.html @@ -0,0 +1,28 @@ + + + +
+ +public static final class ClusterControllerGrpc.ClusterControllerBlockingStub +extends io.grpc.stub.AbstractStub<ClusterControllerGrpc.ClusterControllerBlockingStub>+
+ The ClusterControllerService provides methods to manage clusters + of Google Compute Engine instances. +
| Modifier and Type | +Method and Description | +
|---|---|
protected ClusterControllerGrpc.ClusterControllerBlockingStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.longrunning.Operation |
+createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request)
+
+ Creates a cluster in a project.
+ |
+
com.google.longrunning.Operation |
+deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request)
+
+ Deletes a cluster in a project.
+ |
+
com.google.longrunning.Operation |
+diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request)
+
+ Gets cluster diagnostic information.
+ |
+
com.google.cloud.dataproc.v1.Cluster |
+getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request)
+
+ Gets the resource representation for a cluster in a project.
+ |
+
com.google.cloud.dataproc.v1.ListClustersResponse |
+listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request)
+
+ Lists all regions/{region}/clusters in a project.
+ |
+
com.google.longrunning.Operation |
+updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request)
+
+ Updates a cluster in a project.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected ClusterControllerGrpc.ClusterControllerBlockingStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<ClusterControllerGrpc.ClusterControllerBlockingStub>public com.google.longrunning.Operation createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request)+
+ Creates a cluster in a project. +
public com.google.longrunning.Operation updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request)+
+ Updates a cluster in a project. +
public com.google.longrunning.Operation deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request)+
+ Deletes a cluster in a project. +
public com.google.cloud.dataproc.v1.Cluster getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request)+
+ Gets the resource representation for a cluster in a project. +
public com.google.cloud.dataproc.v1.ListClustersResponse listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request)+
+ Lists all regions/{region}/clusters in a project.
+ public com.google.longrunning.Operation diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request)+
+ Gets cluster diagnostic information. + After the operation completes, the Operation.response field + contains `DiagnoseClusterOutputLocation`. +
public static final class ClusterControllerGrpc.ClusterControllerFutureStub +extends io.grpc.stub.AbstractStub<ClusterControllerGrpc.ClusterControllerFutureStub>+
+ The ClusterControllerService provides methods to manage clusters + of Google Compute Engine instances. +
| Modifier and Type | +Method and Description | +
|---|---|
protected ClusterControllerGrpc.ClusterControllerFutureStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> |
+createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request)
+
+ Creates a cluster in a project.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> |
+deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request)
+
+ Deletes a cluster in a project.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> |
+diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request)
+
+ Gets cluster diagnostic information.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Cluster> |
+getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request)
+
+ Gets the resource representation for a cluster in a project.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.ListClustersResponse> |
+listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request)
+
+ Lists all regions/{region}/clusters in a project.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> |
+updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request)
+
+ Updates a cluster in a project.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected ClusterControllerGrpc.ClusterControllerFutureStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<ClusterControllerGrpc.ClusterControllerFutureStub>public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request)+
+ Creates a cluster in a project. +
public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request)+
+ Updates a cluster in a project. +
public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request)+
+ Deletes a cluster in a project. +
public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Cluster> getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request)+
+ Gets the resource representation for a cluster in a project. +
public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.ListClustersResponse> listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request)+
+ Lists all regions/{region}/clusters in a project.
+ public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request)+
+ Gets cluster diagnostic information. + After the operation completes, the Operation.response field + contains `DiagnoseClusterOutputLocation`. +
public abstract static class ClusterControllerGrpc.ClusterControllerImplBase
+extends java.lang.Object
+implements io.grpc.BindableService
++ The ClusterControllerService provides methods to manage clusters + of Google Compute Engine instances. +
| Constructor and Description | +
|---|
ClusterControllerImplBase() |
+
| Modifier and Type | +Method and Description | +
|---|---|
io.grpc.ServerServiceDefinition |
+bindService() |
+
void |
+createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Creates a cluster in a project.
+ |
+
void |
+deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Deletes a cluster in a project.
+ |
+
void |
+diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Gets cluster diagnostic information.
+ |
+
void |
+getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Cluster> responseObserver)
+
+ Gets the resource representation for a cluster in a project.
+ |
+
void |
+listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListClustersResponse> responseObserver)
+
+ Lists all regions/{region}/clusters in a project.
+ |
+
void |
+updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Updates a cluster in a project.
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic ClusterControllerImplBase()+
public void createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Creates a cluster in a project. +
public void updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Updates a cluster in a project. +
public void deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Deletes a cluster in a project. +
public void getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Cluster> responseObserver)+
+ Gets the resource representation for a cluster in a project. +
public void listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListClustersResponse> responseObserver)+
+ Lists all regions/{region}/clusters in a project.
+ public void diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Gets cluster diagnostic information. + After the operation completes, the Operation.response field + contains `DiagnoseClusterOutputLocation`. +
public final io.grpc.ServerServiceDefinition bindService()+
bindService in interface io.grpc.BindableServicepublic static final class ClusterControllerGrpc.ClusterControllerStub +extends io.grpc.stub.AbstractStub<ClusterControllerGrpc.ClusterControllerStub>+
+ The ClusterControllerService provides methods to manage clusters + of Google Compute Engine instances. +
| Modifier and Type | +Method and Description | +
|---|---|
protected ClusterControllerGrpc.ClusterControllerStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
void |
+createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Creates a cluster in a project.
+ |
+
void |
+deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Deletes a cluster in a project.
+ |
+
void |
+diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Gets cluster diagnostic information.
+ |
+
void |
+getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Cluster> responseObserver)
+
+ Gets the resource representation for a cluster in a project.
+ |
+
void |
+listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListClustersResponse> responseObserver)
+
+ Lists all regions/{region}/clusters in a project.
+ |
+
void |
+updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request,
+ io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
+
+ Updates a cluster in a project.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected ClusterControllerGrpc.ClusterControllerStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<ClusterControllerGrpc.ClusterControllerStub>public void createCluster(com.google.cloud.dataproc.v1.CreateClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Creates a cluster in a project. +
public void updateCluster(com.google.cloud.dataproc.v1.UpdateClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Updates a cluster in a project. +
public void deleteCluster(com.google.cloud.dataproc.v1.DeleteClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Deletes a cluster in a project. +
public void getCluster(com.google.cloud.dataproc.v1.GetClusterRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Cluster> responseObserver)+
+ Gets the resource representation for a cluster in a project. +
public void listClusters(com.google.cloud.dataproc.v1.ListClustersRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListClustersResponse> responseObserver)+
+ Lists all regions/{region}/clusters in a project.
+ public void diagnoseCluster(com.google.cloud.dataproc.v1.DiagnoseClusterRequest request, + io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)+
+ Gets cluster diagnostic information. + After the operation completes, the Operation.response field + contains `DiagnoseClusterOutputLocation`. +
@Generated(value="by gRPC proto compiler (version 1.2.0)",
+ comments="Source: google/cloud/dataproc/v1/clusters.proto")
+public final class ClusterControllerGrpc
+extends java.lang.Object
++ The ClusterControllerService provides methods to manage clusters + of Google Compute Engine instances. +
| Modifier and Type | +Class and Description | +
|---|---|
static class |
+ClusterControllerGrpc.ClusterControllerBlockingStub
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
static class |
+ClusterControllerGrpc.ClusterControllerFutureStub
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
static class |
+ClusterControllerGrpc.ClusterControllerImplBase
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
static class |
+ClusterControllerGrpc.ClusterControllerStub
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
| Modifier and Type | +Field and Description | +
|---|---|
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.CreateClusterRequest,com.google.longrunning.Operation> |
+METHOD_CREATE_CLUSTER |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.DeleteClusterRequest,com.google.longrunning.Operation> |
+METHOD_DELETE_CLUSTER |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.DiagnoseClusterRequest,com.google.longrunning.Operation> |
+METHOD_DIAGNOSE_CLUSTER |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.GetClusterRequest,com.google.cloud.dataproc.v1.Cluster> |
+METHOD_GET_CLUSTER |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.ListClustersRequest,com.google.cloud.dataproc.v1.ListClustersResponse> |
+METHOD_LIST_CLUSTERS |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.UpdateClusterRequest,com.google.longrunning.Operation> |
+METHOD_UPDATE_CLUSTER |
+
static java.lang.String |
+SERVICE_NAME |
+
| Modifier and Type | +Method and Description | +
|---|---|
static io.grpc.ServiceDescriptor |
+getServiceDescriptor() |
+
static ClusterControllerGrpc.ClusterControllerBlockingStub |
+newBlockingStub(io.grpc.Channel channel)
+Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ |
+
static ClusterControllerGrpc.ClusterControllerFutureStub |
+newFutureStub(io.grpc.Channel channel)
+Creates a new ListenableFuture-style stub that supports unary and streaming output calls on the service
+ |
+
static ClusterControllerGrpc.ClusterControllerStub |
+newStub(io.grpc.Channel channel)
+Creates a new async stub that supports all call types for the service
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static final java.lang.String SERVICE_NAME+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.CreateClusterRequest,com.google.longrunning.Operation> METHOD_CREATE_CLUSTER+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.UpdateClusterRequest,com.google.longrunning.Operation> METHOD_UPDATE_CLUSTER+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.DeleteClusterRequest,com.google.longrunning.Operation> METHOD_DELETE_CLUSTER+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.GetClusterRequest,com.google.cloud.dataproc.v1.Cluster> METHOD_GET_CLUSTER+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.ListClustersRequest,com.google.cloud.dataproc.v1.ListClustersResponse> METHOD_LIST_CLUSTERS+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.DiagnoseClusterRequest,com.google.longrunning.Operation> METHOD_DIAGNOSE_CLUSTER+
public static ClusterControllerGrpc.ClusterControllerStub newStub(io.grpc.Channel channel)+
public static ClusterControllerGrpc.ClusterControllerBlockingStub newBlockingStub(io.grpc.Channel channel)+
public static ClusterControllerGrpc.ClusterControllerFutureStub newFutureStub(io.grpc.Channel channel)+
public static io.grpc.ServiceDescriptor getServiceDescriptor()+
public static final class JobControllerGrpc.JobControllerBlockingStub +extends io.grpc.stub.AbstractStub<JobControllerGrpc.JobControllerBlockingStub>+
+ The JobController provides methods to manage jobs. +
| Modifier and Type | +Method and Description | +
|---|---|
protected JobControllerGrpc.JobControllerBlockingStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.cloud.dataproc.v1.Job |
+cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request)
+
+ Starts a job cancellation request.
+ |
+
com.google.protobuf.Empty |
+deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request)
+
+ Deletes the job from the project.
+ |
+
com.google.cloud.dataproc.v1.Job |
+getJob(com.google.cloud.dataproc.v1.GetJobRequest request)
+
+ Gets the resource representation for a job in a project.
+ |
+
com.google.cloud.dataproc.v1.ListJobsResponse |
+listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request)
+
+ Lists regions/{region}/jobs in a project.
+ |
+
com.google.cloud.dataproc.v1.Job |
+submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request)
+
+ Submits a job to a cluster.
+ |
+
com.google.cloud.dataproc.v1.Job |
+updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request)
+
+ Updates a job in a project.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected JobControllerGrpc.JobControllerBlockingStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<JobControllerGrpc.JobControllerBlockingStub>public com.google.cloud.dataproc.v1.Job submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request)+
+ Submits a job to a cluster. +
public com.google.cloud.dataproc.v1.Job getJob(com.google.cloud.dataproc.v1.GetJobRequest request)+
+ Gets the resource representation for a job in a project. +
public com.google.cloud.dataproc.v1.ListJobsResponse listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request)+
+ Lists regions/{region}/jobs in a project.
+ public com.google.cloud.dataproc.v1.Job updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request)+
+ Updates a job in a project. +
public com.google.cloud.dataproc.v1.Job cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request)+
+ 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).
+ public com.google.protobuf.Empty deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request)+
+ Deletes the job from the project. If the job is active, the delete fails, + and the response returns `FAILED_PRECONDITION`. +
public static final class JobControllerGrpc.JobControllerFutureStub +extends io.grpc.stub.AbstractStub<JobControllerGrpc.JobControllerFutureStub>+
+ The JobController provides methods to manage jobs. +
| Modifier and Type | +Method and Description | +
|---|---|
protected JobControllerGrpc.JobControllerFutureStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> |
+cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request)
+
+ Starts a job cancellation request.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> |
+deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request)
+
+ Deletes the job from the project.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> |
+getJob(com.google.cloud.dataproc.v1.GetJobRequest request)
+
+ Gets the resource representation for a job in a project.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.ListJobsResponse> |
+listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request)
+
+ Lists regions/{region}/jobs in a project.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> |
+submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request)
+
+ Submits a job to a cluster.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> |
+updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request)
+
+ Updates a job in a project.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected JobControllerGrpc.JobControllerFutureStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<JobControllerGrpc.JobControllerFutureStub>public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request)+
+ Submits a job to a cluster. +
public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> getJob(com.google.cloud.dataproc.v1.GetJobRequest request)+
+ Gets the resource representation for a job in a project. +
public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.ListJobsResponse> listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request)+
+ Lists regions/{region}/jobs in a project.
+ public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request)+
+ Updates a job in a project. +
public com.google.common.util.concurrent.ListenableFuture<com.google.cloud.dataproc.v1.Job> cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request)+
+ 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).
+ public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request)+
+ Deletes the job from the project. If the job is active, the delete fails, + and the response returns `FAILED_PRECONDITION`. +
public abstract static class JobControllerGrpc.JobControllerImplBase
+extends java.lang.Object
+implements io.grpc.BindableService
++ The JobController provides methods to manage jobs. +
| Constructor and Description | +
|---|
JobControllerImplBase() |
+
| Modifier and Type | +Method and Description | +
|---|---|
io.grpc.ServerServiceDefinition |
+bindService() |
+
void |
+cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Starts a job cancellation request.
+ |
+
void |
+deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Deletes the job from the project.
+ |
+
void |
+getJob(com.google.cloud.dataproc.v1.GetJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Gets the resource representation for a job in a project.
+ |
+
void |
+listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse> responseObserver)
+
+ Lists regions/{region}/jobs in a project.
+ |
+
void |
+submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Submits a job to a cluster.
+ |
+
void |
+updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Updates a job in a project.
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic void submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ Submits a job to a cluster. +
public void getJob(com.google.cloud.dataproc.v1.GetJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ Gets the resource representation for a job in a project. +
public void listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse> responseObserver)+
+ Lists regions/{region}/jobs in a project.
+ public void updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ Updates a job in a project. +
public void cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ 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).
+ public void deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Deletes the job from the project. If the job is active, the delete fails, + and the response returns `FAILED_PRECONDITION`. +
public final io.grpc.ServerServiceDefinition bindService()+
bindService in interface io.grpc.BindableServicepublic static final class JobControllerGrpc.JobControllerStub +extends io.grpc.stub.AbstractStub<JobControllerGrpc.JobControllerStub>+
+ The JobController provides methods to manage jobs. +
| Modifier and Type | +Method and Description | +
|---|---|
protected JobControllerGrpc.JobControllerStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
void |
+cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Starts a job cancellation request.
+ |
+
void |
+deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Deletes the job from the project.
+ |
+
void |
+getJob(com.google.cloud.dataproc.v1.GetJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Gets the resource representation for a job in a project.
+ |
+
void |
+listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse> responseObserver)
+
+ Lists regions/{region}/jobs in a project.
+ |
+
void |
+submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Submits a job to a cluster.
+ |
+
void |
+updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request,
+ io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)
+
+ Updates a job in a project.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected JobControllerGrpc.JobControllerStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<JobControllerGrpc.JobControllerStub>public void submitJob(com.google.cloud.dataproc.v1.SubmitJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ Submits a job to a cluster. +
public void getJob(com.google.cloud.dataproc.v1.GetJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ Gets the resource representation for a job in a project. +
public void listJobs(com.google.cloud.dataproc.v1.ListJobsRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.ListJobsResponse> responseObserver)+
+ Lists regions/{region}/jobs in a project.
+ public void updateJob(com.google.cloud.dataproc.v1.UpdateJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ Updates a job in a project. +
public void cancelJob(com.google.cloud.dataproc.v1.CancelJobRequest request, + io.grpc.stub.StreamObserver<com.google.cloud.dataproc.v1.Job> responseObserver)+
+ 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).
+ public void deleteJob(com.google.cloud.dataproc.v1.DeleteJobRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Deletes the job from the project. If the job is active, the delete fails, + and the response returns `FAILED_PRECONDITION`. +
@Generated(value="by gRPC proto compiler (version 1.2.0)",
+ comments="Source: google/cloud/dataproc/v1/jobs.proto")
+public final class JobControllerGrpc
+extends java.lang.Object
++ The JobController provides methods to manage jobs. +
| Modifier and Type | +Class and Description | +
|---|---|
static class |
+JobControllerGrpc.JobControllerBlockingStub
+
+ The JobController provides methods to manage jobs.
+ |
+
static class |
+JobControllerGrpc.JobControllerFutureStub
+
+ The JobController provides methods to manage jobs.
+ |
+
static class |
+JobControllerGrpc.JobControllerImplBase
+
+ The JobController provides methods to manage jobs.
+ |
+
static class |
+JobControllerGrpc.JobControllerStub
+
+ The JobController provides methods to manage jobs.
+ |
+
| Modifier and Type | +Field and Description | +
|---|---|
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.CancelJobRequest,com.google.cloud.dataproc.v1.Job> |
+METHOD_CANCEL_JOB |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.DeleteJobRequest,com.google.protobuf.Empty> |
+METHOD_DELETE_JOB |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.GetJobRequest,com.google.cloud.dataproc.v1.Job> |
+METHOD_GET_JOB |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.ListJobsRequest,com.google.cloud.dataproc.v1.ListJobsResponse> |
+METHOD_LIST_JOBS |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.SubmitJobRequest,com.google.cloud.dataproc.v1.Job> |
+METHOD_SUBMIT_JOB |
+
static io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.UpdateJobRequest,com.google.cloud.dataproc.v1.Job> |
+METHOD_UPDATE_JOB |
+
static java.lang.String |
+SERVICE_NAME |
+
| Modifier and Type | +Method and Description | +
|---|---|
static io.grpc.ServiceDescriptor |
+getServiceDescriptor() |
+
static JobControllerGrpc.JobControllerBlockingStub |
+newBlockingStub(io.grpc.Channel channel)
+Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ |
+
static JobControllerGrpc.JobControllerFutureStub |
+newFutureStub(io.grpc.Channel channel)
+Creates a new ListenableFuture-style stub that supports unary and streaming output calls on the service
+ |
+
static JobControllerGrpc.JobControllerStub |
+newStub(io.grpc.Channel channel)
+Creates a new async stub that supports all call types for the service
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static final java.lang.String SERVICE_NAME+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.SubmitJobRequest,com.google.cloud.dataproc.v1.Job> METHOD_SUBMIT_JOB+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.GetJobRequest,com.google.cloud.dataproc.v1.Job> METHOD_GET_JOB+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.ListJobsRequest,com.google.cloud.dataproc.v1.ListJobsResponse> METHOD_LIST_JOBS+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.UpdateJobRequest,com.google.cloud.dataproc.v1.Job> METHOD_UPDATE_JOB+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.CancelJobRequest,com.google.cloud.dataproc.v1.Job> METHOD_CANCEL_JOB+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.cloud.dataproc.v1.DeleteJobRequest,com.google.protobuf.Empty> METHOD_DELETE_JOB+
public static JobControllerGrpc.JobControllerStub newStub(io.grpc.Channel channel)+
public static JobControllerGrpc.JobControllerBlockingStub newBlockingStub(io.grpc.Channel channel)+
public static JobControllerGrpc.JobControllerFutureStub newFutureStub(io.grpc.Channel channel)+
public static io.grpc.ServiceDescriptor getServiceDescriptor()+
| Class | +Description | +
|---|---|
| ClusterControllerGrpc | +
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
| ClusterControllerGrpc.ClusterControllerBlockingStub | +
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
| ClusterControllerGrpc.ClusterControllerFutureStub | +
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
| ClusterControllerGrpc.ClusterControllerImplBase | +
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
| ClusterControllerGrpc.ClusterControllerStub | +
+
+ The ClusterControllerService provides methods to manage clusters
+ of Google Compute Engine instances.
+ |
+
| JobControllerGrpc | +
+
+ The JobController provides methods to manage jobs.
+ |
+
| JobControllerGrpc.JobControllerBlockingStub | +
+
+ The JobController provides methods to manage jobs.
+ |
+
| JobControllerGrpc.JobControllerFutureStub | +
+
+ The JobController provides methods to manage jobs.
+ |
+
| JobControllerGrpc.JobControllerImplBase | +
+
+ The JobController provides methods to manage jobs.
+ |
+
| JobControllerGrpc.JobControllerStub | +
+
+ The JobController provides methods to manage jobs.
+ |
+
| Modifier and Type | +Constant Field | +Value | +
|---|---|---|
+
+public static final java.lang.String |
+SERVICE_NAME |
+"google.cloud.dataproc.v1.ClusterController" |
+
| Modifier and Type | +Constant Field | +Value | +
|---|---|---|
+
+public static final java.lang.String |
+SERVICE_NAME |
+"google.cloud.dataproc.v1.JobController" |
+
Each package has a page that contains a list of its classes and interfaces, with a summary for each. This page can contain six categories:
+Each class, interface, nested class and nested interface has its own separate page. Each of these pages has three sections consisting of a class/interface description, summary tables, and detailed member descriptions:
+Each summary entry contains the first sentence from the detailed description for that item. The summary entries are alphabetical, while the detailed descriptions are in the order they appear in the source code. This preserves the logical groupings established by the programmer.
+Each annotation type has its own separate page with the following sections:
+Each enum has its own separate page with the following sections:
+There is a Class Hierarchy page for all packages, plus a hierarchy for each package. Each hierarchy page contains a list of classes and a list of interfaces. The classes are organized by inheritance structure starting with java.lang.Object. The interfaces do not inherit from java.lang.Object.
The Deprecated API page lists all of the API that have been deprecated. A deprecated API is not recommended for use, generally due to improvements, and a replacement API is usually given. Deprecated APIs may be removed in future implementations.
+The Index contains an alphabetic list of all classes, interfaces, constructors, methods, and fields.
+These links take you to the next or previous class, interface, package, or related page.
+These links show and hide the HTML frames. All pages are available with or without frames.
+The All Classes link shows all classes and interfaces except non-static nested types.
+Each serializable or externalizable class has a description of its serialization fields and methods. This information is of interest to re-implementors, not to developers using the API. While there is no link in the navigation bar, you can get to this information by going to any serialized class and clicking "Serialized Form" in the "See also" section of the class description.
+The Constant Field Values page lists the static final fields and their values.
+