Class DataTransferServiceGrpc.DataTransferServiceStub (2.0.27)

public static final class DataTransferServiceGrpc.DataTransferServiceStub extends AbstractAsyncStub<DataTransferServiceGrpc.DataTransferServiceStub>

The Google BigQuery Data Transfer Service API enables BigQuery users to configure the transfer of their data from other Google Products into BigQuery. This service contains methods that are end user exposed. It backs up the frontend.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > DataTransferServiceGrpc.DataTransferServiceStub

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<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 DataTransferServiceGrpc.DataTransferServiceStub build(Channel channel, CallOptions callOptions)

Parameters

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

Returns

Type	Description
DataTransferServiceGrpc.DataTransferServiceStub

Overrides

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

checkValidCreds(CheckValidCredsRequest request, StreamObserver<CheckValidCredsResponse> responseObserver)

public void checkValidCreds(CheckValidCredsRequest request, StreamObserver<CheckValidCredsResponse> responseObserver)

Returns true if valid credentials exist for the given data source and requesting user. Some data sources doesn't support service account, so we need to talk to them on behalf of the end user. This API just checks whether we have OAuth token for the particular user, which is a pre-requisite before user can create a transfer config.

Parameters

Name	Description
request	`CheckValidCredsRequest`
responseObserver	`io.grpc.stub.StreamObserver<CheckValidCredsResponse>`

createTransferConfig(CreateTransferConfigRequest request, StreamObserver<TransferConfig> responseObserver)

public void createTransferConfig(CreateTransferConfigRequest request, StreamObserver<TransferConfig> responseObserver)

Creates a new data transfer configuration.

Parameters

Name	Description
request	`CreateTransferConfigRequest`
responseObserver	`io.grpc.stub.StreamObserver<TransferConfig>`

deleteTransferConfig(DeleteTransferConfigRequest request, StreamObserver<Empty> responseObserver)

public void deleteTransferConfig(DeleteTransferConfigRequest request, StreamObserver<Empty> responseObserver)

Deletes a data transfer configuration, including any associated transfer runs and logs.

Parameters

Name	Description
request	`DeleteTransferConfigRequest`
responseObserver	`io.grpc.stub.StreamObserver<Empty>`

deleteTransferRun(DeleteTransferRunRequest request, StreamObserver<Empty> responseObserver)

public void deleteTransferRun(DeleteTransferRunRequest request, StreamObserver<Empty> responseObserver)

Deletes the specified transfer run.

Parameters

Name	Description
request	`DeleteTransferRunRequest`
responseObserver	`io.grpc.stub.StreamObserver<Empty>`

getDataSource(GetDataSourceRequest request, StreamObserver<DataSource> responseObserver)

public void getDataSource(GetDataSourceRequest request, StreamObserver<DataSource> responseObserver)

Retrieves a supported data source and returns its settings, which can be used for UI rendering.

Parameters

Name	Description
request	`GetDataSourceRequest`
responseObserver	`io.grpc.stub.StreamObserver<DataSource>`

getTransferConfig(GetTransferConfigRequest request, StreamObserver<TransferConfig> responseObserver)

public void getTransferConfig(GetTransferConfigRequest request, StreamObserver<TransferConfig> responseObserver)

Returns information about a data transfer config.

Parameters

Name	Description
request	`GetTransferConfigRequest`
responseObserver	`io.grpc.stub.StreamObserver<TransferConfig>`

getTransferRun(GetTransferRunRequest request, StreamObserver<TransferRun> responseObserver)

public void getTransferRun(GetTransferRunRequest request, StreamObserver<TransferRun> responseObserver)

Returns information about the particular transfer run.

Parameters

Name	Description
request	`GetTransferRunRequest`
responseObserver	`io.grpc.stub.StreamObserver<TransferRun>`

listDataSources(ListDataSourcesRequest request, StreamObserver<ListDataSourcesResponse> responseObserver)

public void listDataSources(ListDataSourcesRequest request, StreamObserver<ListDataSourcesResponse> responseObserver)

Lists supported data sources and returns their settings, which can be used for UI rendering.

Parameters

Name	Description
request	`ListDataSourcesRequest`
responseObserver	`io.grpc.stub.StreamObserver<ListDataSourcesResponse>`

listTransferConfigs(ListTransferConfigsRequest request, StreamObserver<ListTransferConfigsResponse> responseObserver)

public void listTransferConfigs(ListTransferConfigsRequest request, StreamObserver<ListTransferConfigsResponse> responseObserver)

Returns information about all transfer configs owned by a project in the specified location.

Parameters

Name	Description
request	`ListTransferConfigsRequest`
responseObserver	`io.grpc.stub.StreamObserver<ListTransferConfigsResponse>`

listTransferLogs(ListTransferLogsRequest request, StreamObserver<ListTransferLogsResponse> responseObserver)

public void listTransferLogs(ListTransferLogsRequest request, StreamObserver<ListTransferLogsResponse> responseObserver)

Returns user facing log messages for the data transfer run.

Parameters

Name	Description
request	`ListTransferLogsRequest`
responseObserver	`io.grpc.stub.StreamObserver<ListTransferLogsResponse>`

listTransferRuns(ListTransferRunsRequest request, StreamObserver<ListTransferRunsResponse> responseObserver)

public void listTransferRuns(ListTransferRunsRequest request, StreamObserver<ListTransferRunsResponse> responseObserver)

Returns information about running and completed jobs.

Parameters

Name	Description
request	`ListTransferRunsRequest`
responseObserver	`io.grpc.stub.StreamObserver<ListTransferRunsResponse>`

scheduleTransferRuns(ScheduleTransferRunsRequest request, StreamObserver<ScheduleTransferRunsResponse> responseObserver)

public void scheduleTransferRuns(ScheduleTransferRunsRequest request, StreamObserver<ScheduleTransferRunsResponse> responseObserver)

Creates transfer runs for a time range [start_time, end_time]. For each date - or whatever granularity the data source supports - in the range, one transfer run is created. Note that runs are created per UTC time in the time range. DEPRECATED: use StartManualTransferRuns instead.

Parameters

Name	Description
request	`ScheduleTransferRunsRequest`
responseObserver	`io.grpc.stub.StreamObserver<ScheduleTransferRunsResponse>`

startManualTransferRuns(StartManualTransferRunsRequest request, StreamObserver<StartManualTransferRunsResponse> responseObserver)

public void startManualTransferRuns(StartManualTransferRunsRequest request, StreamObserver<StartManualTransferRunsResponse> responseObserver)

Start manual transfer runs to be executed now with schedule_time equal to current time. The transfer runs can be created for a time range where the run_time is between start_time (inclusive) and end_time (exclusive), or for a specific run_time.

Parameters

Name	Description
request	`StartManualTransferRunsRequest`
responseObserver	`io.grpc.stub.StreamObserver<StartManualTransferRunsResponse>`

updateTransferConfig(UpdateTransferConfigRequest request, StreamObserver<TransferConfig> responseObserver)

public void updateTransferConfig(UpdateTransferConfigRequest request, StreamObserver<TransferConfig> responseObserver)

Updates a data transfer configuration. All fields must be set, even if they are not updated.

Parameters

Name	Description
request	`UpdateTransferConfigRequest`
responseObserver	`io.grpc.stub.StreamObserver<TransferConfig>`