public static final class PipelineServiceGrpc.PipelineServiceFutureStub extends AbstractFutureStub<PipelineServiceGrpc.PipelineServiceFutureStub>
A service for creating and managing Vertex AI's pipelines. This includes both
TrainingPipeline resources (used for AutoML and custom training) and
PipelineJob resources (used for Vertex Pipelines).
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
PipelineServiceGrpc.PipelineServiceFutureStub
Inherited Members
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
protected PipelineServiceGrpc.PipelineServiceFutureStub build(Channel channel, CallOptions callOptions)
Parameters
| Name | Description |
| channel | io.grpc.Channel
|
| callOptions | io.grpc.CallOptions
|
Returns
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
public ListenableFuture<Empty> cancelPipelineJob(CancelPipelineJobRequest request)
Cancels a PipelineJob.
Starts asynchronous cancellation on the PipelineJob. The server
makes a best effort to cancel the pipeline, but success is not
guaranteed. Clients can use PipelineService.GetPipelineJob or
other methods to check whether the cancellation succeeded or whether the
pipeline completed despite cancellation. On successful cancellation,
the PipelineJob is not deleted; instead it becomes a pipeline with
a PipelineJob.error value with a google.rpc.Status.code of 1,
corresponding to Code.CANCELLED, and PipelineJob.state is set to
CANCELLED.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<Empty> | |
public ListenableFuture<Empty> cancelTrainingPipeline(CancelTrainingPipelineRequest request)
Cancels a TrainingPipeline.
Starts asynchronous cancellation on the TrainingPipeline. The server
makes a best effort to cancel the pipeline, but success is not
guaranteed. Clients can use PipelineService.GetTrainingPipeline or
other methods to check whether the cancellation succeeded or whether the
pipeline completed despite cancellation. On successful cancellation,
the TrainingPipeline is not deleted; instead it becomes a pipeline with
a TrainingPipeline.error value with a google.rpc.Status.code of 1,
corresponding to Code.CANCELLED, and TrainingPipeline.state is set to
CANCELLED.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<Empty> | |
public ListenableFuture<PipelineJob> createPipelineJob(CreatePipelineJobRequest request)
Creates a PipelineJob. A PipelineJob will run immediately when created.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<PipelineJob> | |
public ListenableFuture<TrainingPipeline> createTrainingPipeline(CreateTrainingPipelineRequest request)
Creates a TrainingPipeline. A created TrainingPipeline right away will be
attempted to be run.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<TrainingPipeline> | |
public ListenableFuture<Operation> deletePipelineJob(DeletePipelineJobRequest request)
Parameter
Returns
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<Operation> | |
public ListenableFuture<Operation> deleteTrainingPipeline(DeleteTrainingPipelineRequest request)
Deletes a TrainingPipeline.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<Operation> | |
public ListenableFuture<PipelineJob> getPipelineJob(GetPipelineJobRequest request)
Parameter
Returns
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<PipelineJob> | |
public ListenableFuture<TrainingPipeline> getTrainingPipeline(GetTrainingPipelineRequest request)
Parameter
Returns
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<TrainingPipeline> | |
public ListenableFuture<ListPipelineJobsResponse> listPipelineJobs(ListPipelineJobsRequest request)
Lists PipelineJobs in a Location.
public ListenableFuture<ListTrainingPipelinesResponse> listTrainingPipelines(ListTrainingPipelinesRequest request)
Lists TrainingPipelines in a Location.
