Uses of Class
com.google.dataflow.v1beta3.Job
-
Packages that use Job Package Description com.google.dataflow.v1beta3 A client to Dataflow APIcom.google.dataflow.v1beta3.stub -
-
Uses of Job in com.google.dataflow.v1beta3
Methods in com.google.dataflow.v1beta3 that return Job Modifier and Type Method Description Job
Job.Builder. build()
Job
Job.Builder. buildPartial()
Job
JobsV1Beta3Client. createJob(CreateJobRequest request)
Creates a Cloud Dataflow job.Job
JobsV1Beta3Grpc.JobsV1Beta3BlockingStub. createJob(CreateJobRequest request)
Creates a Cloud Dataflow job.Job
TemplatesServiceClient. createJobFromTemplate(CreateJobFromTemplateRequest request)
Creates a Cloud Dataflow job from a template.Job
TemplatesServiceGrpc.TemplatesServiceBlockingStub. createJobFromTemplate(CreateJobFromTemplateRequest request)
Creates a Cloud Dataflow job from a template.static Job
Job. getDefaultInstance()
Job
Job.Builder. getDefaultInstanceForType()
Job
Job. getDefaultInstanceForType()
Job
CreateJobRequest.Builder. getJob()
The job to create.Job
CreateJobRequest. getJob()
The job to create.Job
CreateJobRequestOrBuilder. getJob()
The job to create.Job
JobsV1Beta3Client. getJob(GetJobRequest request)
Gets the state of the specified Cloud Dataflow job.Job
JobsV1Beta3Grpc.JobsV1Beta3BlockingStub. getJob(GetJobRequest request)
Gets the state of the specified Cloud Dataflow job.Job
LaunchFlexTemplateResponse.Builder. getJob()
The job that was launched, if the request was not a dry run and the job was successfully launched.Job
LaunchFlexTemplateResponse. getJob()
The job that was launched, if the request was not a dry run and the job was successfully launched.Job
LaunchFlexTemplateResponseOrBuilder. getJob()
The job that was launched, if the request was not a dry run and the job was successfully launched.Job
LaunchTemplateResponse.Builder. getJob()
The job that was launched, if the request was not a dry run and the job was successfully launched.Job
LaunchTemplateResponse. getJob()
The job that was launched, if the request was not a dry run and the job was successfully launched.Job
LaunchTemplateResponseOrBuilder. getJob()
The job that was launched, if the request was not a dry run and the job was successfully launched.Job
UpdateJobRequest.Builder. getJob()
The updated job.Job
UpdateJobRequest. getJob()
The updated job.Job
UpdateJobRequestOrBuilder. getJob()
The updated job.Job
ListJobsResponse.Builder. getJobs(int index)
A subset of the requested job information.Job
ListJobsResponse. getJobs(int index)
A subset of the requested job information.Job
ListJobsResponseOrBuilder. getJobs(int index)
A subset of the requested job information.static Job
Job. parseDelimitedFrom(InputStream input)
static Job
Job. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Job
Job. parseFrom(byte[] data)
static Job
Job. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Job
Job. parseFrom(com.google.protobuf.ByteString data)
static Job
Job. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Job
Job. parseFrom(com.google.protobuf.CodedInputStream input)
static Job
Job. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Job
Job. parseFrom(InputStream input)
static Job
Job. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Job
Job. parseFrom(ByteBuffer data)
static Job
Job. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
Job
JobsV1Beta3Client. updateJob(UpdateJobRequest request)
Updates the state of an existing Cloud Dataflow job.Job
JobsV1Beta3Grpc.JobsV1Beta3BlockingStub. updateJob(UpdateJobRequest request)
Updates the state of an existing Cloud Dataflow job.Methods in com.google.dataflow.v1beta3 that return types with arguments of type Job Modifier and Type Method Description com.google.common.util.concurrent.ListenableFuture<Job>
JobsV1Beta3Grpc.JobsV1Beta3FutureStub. createJob(CreateJobRequest request)
Creates a Cloud Dataflow job.com.google.api.gax.rpc.UnaryCallable<CreateJobRequest,Job>
JobsV1Beta3Client. createJobCallable()
Creates a Cloud Dataflow job.com.google.common.util.concurrent.ListenableFuture<Job>
TemplatesServiceGrpc.TemplatesServiceFutureStub. createJobFromTemplate(CreateJobFromTemplateRequest request)
Creates a Cloud Dataflow job from a template.com.google.api.gax.rpc.UnaryCallable<CreateJobFromTemplateRequest,Job>
TemplatesServiceClient. createJobFromTemplateCallable()
Creates a Cloud Dataflow job from a template.com.google.api.gax.rpc.UnaryCallSettings.Builder<CreateJobFromTemplateRequest,Job>
TemplatesServiceSettings.Builder. createJobFromTemplateSettings()
Returns the builder for the settings used for calls to createJobFromTemplate.com.google.api.gax.rpc.UnaryCallSettings<CreateJobFromTemplateRequest,Job>
TemplatesServiceSettings. createJobFromTemplateSettings()
Returns the object with the settings used for calls to createJobFromTemplate.com.google.api.gax.rpc.UnaryCallSettings.Builder<CreateJobRequest,Job>
JobsV1Beta3Settings.Builder. createJobSettings()
Returns the builder for the settings used for calls to createJob.com.google.api.gax.rpc.UnaryCallSettings<CreateJobRequest,Job>
JobsV1Beta3Settings. createJobSettings()
Returns the object with the settings used for calls to createJob.static io.grpc.MethodDescriptor<CreateJobFromTemplateRequest,Job>
TemplatesServiceGrpc. getCreateJobFromTemplateMethod()
static io.grpc.MethodDescriptor<CreateJobRequest,Job>
JobsV1Beta3Grpc. getCreateJobMethod()
static io.grpc.MethodDescriptor<GetJobRequest,Job>
JobsV1Beta3Grpc. getGetJobMethod()
com.google.common.util.concurrent.ListenableFuture<Job>
JobsV1Beta3Grpc.JobsV1Beta3FutureStub. getJob(GetJobRequest request)
Gets the state of the specified Cloud Dataflow job.com.google.api.gax.rpc.UnaryCallable<GetJobRequest,Job>
JobsV1Beta3Client. getJobCallable()
Gets the state of the specified Cloud Dataflow job.com.google.api.gax.rpc.UnaryCallSettings.Builder<GetJobRequest,Job>
JobsV1Beta3Settings.Builder. getJobSettings()
Returns the builder for the settings used for calls to getJob.com.google.api.gax.rpc.UnaryCallSettings<GetJobRequest,Job>
JobsV1Beta3Settings. getJobSettings()
Returns the object with the settings used for calls to getJob.List<Job>
ListJobsResponse.Builder. getJobsList()
A subset of the requested job information.List<Job>
ListJobsResponse. getJobsList()
A subset of the requested job information.List<Job>
ListJobsResponseOrBuilder. getJobsList()
A subset of the requested job information.com.google.protobuf.Parser<Job>
Job. getParserForType()
static io.grpc.MethodDescriptor<UpdateJobRequest,Job>
JobsV1Beta3Grpc. getUpdateJobMethod()
static com.google.protobuf.Parser<Job>
Job. parser()
com.google.common.util.concurrent.ListenableFuture<Job>
JobsV1Beta3Grpc.JobsV1Beta3FutureStub. updateJob(UpdateJobRequest request)
Updates the state of an existing Cloud Dataflow job.com.google.api.gax.rpc.UnaryCallable<UpdateJobRequest,Job>
JobsV1Beta3Client. updateJobCallable()
Updates the state of an existing Cloud Dataflow job.com.google.api.gax.rpc.UnaryCallSettings.Builder<UpdateJobRequest,Job>
JobsV1Beta3Settings.Builder. updateJobSettings()
Returns the builder for the settings used for calls to updateJob.com.google.api.gax.rpc.UnaryCallSettings<UpdateJobRequest,Job>
JobsV1Beta3Settings. updateJobSettings()
Returns the object with the settings used for calls to updateJob.Methods in com.google.dataflow.v1beta3 with parameters of type Job Modifier and Type Method Description ListJobsResponse.Builder
ListJobsResponse.Builder. addJobs(int index, Job value)
A subset of the requested job information.ListJobsResponse.Builder
ListJobsResponse.Builder. addJobs(Job value)
A subset of the requested job information.Job.Builder
Job.Builder. mergeFrom(Job other)
CreateJobRequest.Builder
CreateJobRequest.Builder. mergeJob(Job value)
The job to create.LaunchFlexTemplateResponse.Builder
LaunchFlexTemplateResponse.Builder. mergeJob(Job value)
The job that was launched, if the request was not a dry run and the job was successfully launched.LaunchTemplateResponse.Builder
LaunchTemplateResponse.Builder. mergeJob(Job value)
The job that was launched, if the request was not a dry run and the job was successfully launched.UpdateJobRequest.Builder
UpdateJobRequest.Builder. mergeJob(Job value)
The updated job.static Job.Builder
Job. newBuilder(Job prototype)
CreateJobRequest.Builder
CreateJobRequest.Builder. setJob(Job value)
The job to create.LaunchFlexTemplateResponse.Builder
LaunchFlexTemplateResponse.Builder. setJob(Job value)
The job that was launched, if the request was not a dry run and the job was successfully launched.LaunchTemplateResponse.Builder
LaunchTemplateResponse.Builder. setJob(Job value)
The job that was launched, if the request was not a dry run and the job was successfully launched.UpdateJobRequest.Builder
UpdateJobRequest.Builder. setJob(Job value)
The updated job.ListJobsResponse.Builder
ListJobsResponse.Builder. setJobs(int index, Job value)
A subset of the requested job information.Method parameters in com.google.dataflow.v1beta3 with type arguments of type Job Modifier and Type Method Description ListJobsResponse.Builder
ListJobsResponse.Builder. addAllJobs(Iterable<? extends Job> values)
A subset of the requested job information.static com.google.api.core.ApiFuture<JobsV1Beta3Client.AggregatedListJobsPagedResponse>
JobsV1Beta3Client.AggregatedListJobsPagedResponse. createAsync(com.google.api.gax.rpc.PageContext<ListJobsRequest,ListJobsResponse,Job> context, com.google.api.core.ApiFuture<ListJobsResponse> futureResponse)
static com.google.api.core.ApiFuture<JobsV1Beta3Client.ListJobsPagedResponse>
JobsV1Beta3Client.ListJobsPagedResponse. createAsync(com.google.api.gax.rpc.PageContext<ListJobsRequest,ListJobsResponse,Job> context, com.google.api.core.ApiFuture<ListJobsResponse> futureResponse)
default void
JobsV1Beta3Grpc.AsyncService. createJob(CreateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Creates a Cloud Dataflow job.void
JobsV1Beta3Grpc.JobsV1Beta3Stub. createJob(CreateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Creates a Cloud Dataflow job.default void
TemplatesServiceGrpc.AsyncService. createJobFromTemplate(CreateJobFromTemplateRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Creates a Cloud Dataflow job from a template.void
TemplatesServiceGrpc.TemplatesServiceStub. createJobFromTemplate(CreateJobFromTemplateRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Creates a Cloud Dataflow job from a template.protected JobsV1Beta3Client.AggregatedListJobsPage
JobsV1Beta3Client.AggregatedListJobsPage. createPage(com.google.api.gax.rpc.PageContext<ListJobsRequest,ListJobsResponse,Job> context, ListJobsResponse response)
protected JobsV1Beta3Client.ListJobsPage
JobsV1Beta3Client.ListJobsPage. createPage(com.google.api.gax.rpc.PageContext<ListJobsRequest,ListJobsResponse,Job> context, ListJobsResponse response)
com.google.api.core.ApiFuture<JobsV1Beta3Client.AggregatedListJobsPage>
JobsV1Beta3Client.AggregatedListJobsPage. createPageAsync(com.google.api.gax.rpc.PageContext<ListJobsRequest,ListJobsResponse,Job> context, com.google.api.core.ApiFuture<ListJobsResponse> futureResponse)
com.google.api.core.ApiFuture<JobsV1Beta3Client.ListJobsPage>
JobsV1Beta3Client.ListJobsPage. createPageAsync(com.google.api.gax.rpc.PageContext<ListJobsRequest,ListJobsResponse,Job> context, com.google.api.core.ApiFuture<ListJobsResponse> futureResponse)
default void
JobsV1Beta3Grpc.AsyncService. getJob(GetJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Gets the state of the specified Cloud Dataflow job.void
JobsV1Beta3Grpc.JobsV1Beta3Stub. getJob(GetJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Gets the state of the specified Cloud Dataflow job.default void
JobsV1Beta3Grpc.AsyncService. updateJob(UpdateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Updates the state of an existing Cloud Dataflow job.void
JobsV1Beta3Grpc.JobsV1Beta3Stub. updateJob(UpdateJobRequest request, io.grpc.stub.StreamObserver<Job> responseObserver)
Updates the state of an existing Cloud Dataflow job. -
Uses of Job in com.google.dataflow.v1beta3.stub
Methods in com.google.dataflow.v1beta3.stub that return types with arguments of type Job Modifier and Type Method Description com.google.api.gax.rpc.UnaryCallable<CreateJobRequest,Job>
GrpcJobsV1Beta3Stub. createJobCallable()
com.google.api.gax.rpc.UnaryCallable<CreateJobRequest,Job>
HttpJsonJobsV1Beta3Stub. createJobCallable()
com.google.api.gax.rpc.UnaryCallable<CreateJobRequest,Job>
JobsV1Beta3Stub. createJobCallable()
com.google.api.gax.rpc.UnaryCallable<CreateJobFromTemplateRequest,Job>
GrpcTemplatesServiceStub. createJobFromTemplateCallable()
com.google.api.gax.rpc.UnaryCallable<CreateJobFromTemplateRequest,Job>
HttpJsonTemplatesServiceStub. createJobFromTemplateCallable()
com.google.api.gax.rpc.UnaryCallable<CreateJobFromTemplateRequest,Job>
TemplatesServiceStub. createJobFromTemplateCallable()
com.google.api.gax.rpc.UnaryCallSettings.Builder<CreateJobFromTemplateRequest,Job>
TemplatesServiceStubSettings.Builder. createJobFromTemplateSettings()
Returns the builder for the settings used for calls to createJobFromTemplate.com.google.api.gax.rpc.UnaryCallSettings<CreateJobFromTemplateRequest,Job>
TemplatesServiceStubSettings. createJobFromTemplateSettings()
Returns the object with the settings used for calls to createJobFromTemplate.com.google.api.gax.rpc.UnaryCallSettings.Builder<CreateJobRequest,Job>
JobsV1Beta3StubSettings.Builder. createJobSettings()
Returns the builder for the settings used for calls to createJob.com.google.api.gax.rpc.UnaryCallSettings<CreateJobRequest,Job>
JobsV1Beta3StubSettings. createJobSettings()
Returns the object with the settings used for calls to createJob.com.google.api.gax.rpc.UnaryCallable<GetJobRequest,Job>
GrpcJobsV1Beta3Stub. getJobCallable()
com.google.api.gax.rpc.UnaryCallable<GetJobRequest,Job>
HttpJsonJobsV1Beta3Stub. getJobCallable()
com.google.api.gax.rpc.UnaryCallable<GetJobRequest,Job>
JobsV1Beta3Stub. getJobCallable()
com.google.api.gax.rpc.UnaryCallSettings.Builder<GetJobRequest,Job>
JobsV1Beta3StubSettings.Builder. getJobSettings()
Returns the builder for the settings used for calls to getJob.com.google.api.gax.rpc.UnaryCallSettings<GetJobRequest,Job>
JobsV1Beta3StubSettings. getJobSettings()
Returns the object with the settings used for calls to getJob.com.google.api.gax.rpc.UnaryCallable<UpdateJobRequest,Job>
GrpcJobsV1Beta3Stub. updateJobCallable()
com.google.api.gax.rpc.UnaryCallable<UpdateJobRequest,Job>
HttpJsonJobsV1Beta3Stub. updateJobCallable()
com.google.api.gax.rpc.UnaryCallable<UpdateJobRequest,Job>
JobsV1Beta3Stub. updateJobCallable()
com.google.api.gax.rpc.UnaryCallSettings.Builder<UpdateJobRequest,Job>
JobsV1Beta3StubSettings.Builder. updateJobSettings()
Returns the builder for the settings used for calls to updateJob.com.google.api.gax.rpc.UnaryCallSettings<UpdateJobRequest,Job>
JobsV1Beta3StubSettings. updateJobSettings()
Returns the object with the settings used for calls to updateJob.
-