Class PipelineServiceGrpc.PipelineServiceFutureStub (3.10.0)

Version 3.10.0

• 3.56.0 (latest)
• 3.55.0
• 3.54.0
• 3.53.0
• 3.52.0
• 3.50.0
• 3.49.0
• 3.48.0
• 3.47.0
• 3.46.0
• 3.45.0
• 3.44.0
• 3.43.0
• 3.42.0
• 3.41.0
• 3.40.0
• 3.38.0
• 3.37.0
• 3.36.0
• 3.35.0
• 3.34.0
• 3.33.0
• 3.32.0
• 3.31.0
• 3.30.0
• 3.29.0
• 3.28.0
• 3.25.0
• 3.24.0
• 3.23.0
• 3.22.0
• 3.21.0
• 3.20.0
• 3.19.0
• 3.18.0
• 3.17.0
• 3.16.0
• 3.15.0
• 3.14.0
• 3.13.0
• 3.12.0
• 3.11.0
• 3.10.0
• 3.9.0
• 3.8.0
• 3.7.0
• 3.6.0
• 3.5.0
• 3.4.2
• 3.3.0
• 3.2.0
• 3.0.0
• 2.9.8
• 2.8.9
• 2.7.4
• 2.5.3
• 2.4.0

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 AI 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()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

build(Channel channel, CallOptions callOptions)

protected PipelineServiceGrpc.PipelineServiceFutureStub build(Channel channel, CallOptions callOptions)

Parameters

Name	Description
channel	io.grpc.Channel
callOptions	io.grpc.CallOptions

Returns

Type	Description
PipelineServiceGrpc.PipelineServiceFutureStub

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

cancelPipelineJob(CancelPipelineJobRequest request)

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.

Parameter

Name	Description
request	CancelPipelineJobRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<Empty>

cancelTrainingPipeline(CancelTrainingPipelineRequest request)

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.

Parameter

Name	Description
request	CancelTrainingPipelineRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<Empty>

createPipelineJob(CreatePipelineJobRequest request)

public ListenableFuture<PipelineJob> createPipelineJob(CreatePipelineJobRequest request)

Creates a PipelineJob. A PipelineJob will run immediately when created.

Parameter

Name	Description
request	CreatePipelineJobRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<PipelineJob>

createTrainingPipeline(CreateTrainingPipelineRequest request)

public ListenableFuture<TrainingPipeline> createTrainingPipeline(CreateTrainingPipelineRequest request)

Creates a TrainingPipeline. A created TrainingPipeline right away will be attempted to be run.

Parameter

Name	Description
request	CreateTrainingPipelineRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<TrainingPipeline>

deletePipelineJob(DeletePipelineJobRequest request)

public ListenableFuture<Operation> deletePipelineJob(DeletePipelineJobRequest request)

Deletes a PipelineJob.

Parameter

Name	Description
request	DeletePipelineJobRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

deleteTrainingPipeline(DeleteTrainingPipelineRequest request)

public ListenableFuture<Operation> deleteTrainingPipeline(DeleteTrainingPipelineRequest request)

Deletes a TrainingPipeline.

Parameter

Name	Description
request	DeleteTrainingPipelineRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<Operation>

getPipelineJob(GetPipelineJobRequest request)

public ListenableFuture<PipelineJob> getPipelineJob(GetPipelineJobRequest request)

Gets a PipelineJob.

Parameter

Name	Description
request	GetPipelineJobRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<PipelineJob>

getTrainingPipeline(GetTrainingPipelineRequest request)

public ListenableFuture<TrainingPipeline> getTrainingPipeline(GetTrainingPipelineRequest request)

Gets a TrainingPipeline.

Parameter

Name	Description
request	GetTrainingPipelineRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<TrainingPipeline>

listPipelineJobs(ListPipelineJobsRequest request)

public ListenableFuture<ListPipelineJobsResponse> listPipelineJobs(ListPipelineJobsRequest request)

Lists PipelineJobs in a Location.

Parameter

Name	Description
request	ListPipelineJobsRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<ListPipelineJobsResponse>

listTrainingPipelines(ListTrainingPipelinesRequest request)

public ListenableFuture<ListTrainingPipelinesResponse> listTrainingPipelines(ListTrainingPipelinesRequest request)

Lists TrainingPipelines in a Location.

Parameter

Name	Description
request	ListTrainingPipelinesRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<ListTrainingPipelinesResponse>