Class PipelineServiceGrpc.PipelineServiceBlockingStub (3.77.0)
public static final class PipelineServiceGrpc.PipelineServiceBlockingStub extends AbstractBlockingStub<PipelineServiceGrpc.PipelineServiceBlockingStub>
A stub to allow clients to do limited synchronous rpc calls to service PipelineService.
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.AbstractBlockingStub >
PipelineServiceGrpc.PipelineServiceBlockingStub
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<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(java.time.Duration)
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.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
public Operation batchCancelPipelineJobs(BatchCancelPipelineJobsRequest request)
Batch cancel PipelineJobs.
Firstly the server will check if all the jobs are in non-terminal states,
and skip the jobs that are already terminated.
If the operation failed, none of the pipeline jobs are cancelled.
The server will poll the states of all the pipeline jobs periodically
to check the cancellation status.
This operation will return an LRO.
public Operation batchDeletePipelineJobs(BatchDeletePipelineJobsRequest request)
Batch deletes PipelineJobs
The Operation is atomic. If it fails, none of the PipelineJobs are deleted.
If it succeeds, all of the PipelineJobs are deleted.
protected PipelineServiceGrpc.PipelineServiceBlockingStub build(Channel channel, CallOptions callOptions)
| Parameters |
| Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
public 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.
| Returns |
| Type |
Description |
Empty |
|
public 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.
| Returns |
| Type |
Description |
Empty |
|
public PipelineJob createPipelineJob(CreatePipelineJobRequest request)
Creates a PipelineJob. A PipelineJob will run immediately when created.
public TrainingPipeline createTrainingPipeline(CreateTrainingPipelineRequest request)
Creates a TrainingPipeline. A created TrainingPipeline right away will be
attempted to be run.
public Operation deletePipelineJob(DeletePipelineJobRequest request)
public Operation deleteTrainingPipeline(DeleteTrainingPipelineRequest request)
Deletes a TrainingPipeline.
public PipelineJob getPipelineJob(GetPipelineJobRequest request)
public TrainingPipeline getTrainingPipeline(GetTrainingPipelineRequest request)
public ListPipelineJobsResponse listPipelineJobs(ListPipelineJobsRequest request)
Lists PipelineJobs in a Location.
public ListTrainingPipelinesResponse listTrainingPipelines(ListTrainingPipelinesRequest request)
Lists TrainingPipelines in a Location.
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-10-11 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-10-11 UTC."],[],[]]
