public static final class DataTransferServiceGrpc.DataTransferServiceFutureStub extends AbstractFutureStub<DataTransferServiceGrpc.DataTransferServiceFutureStub>
This API allows users to manage their data transfers into BigQuery.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
DataTransferServiceGrpc.DataTransferServiceFutureStub
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
build(Channel channel, CallOptions callOptions)
protected DataTransferServiceGrpc.DataTransferServiceFutureStub 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)
checkValidCreds(CheckValidCredsRequest request)
public ListenableFuture<CheckValidCredsResponse> checkValidCreds(CheckValidCredsRequest request)
Returns true if valid credentials exist for the given data source and
requesting user.
createTransferConfig(CreateTransferConfigRequest request)
public ListenableFuture<TransferConfig> createTransferConfig(CreateTransferConfigRequest request)
Creates a new data transfer configuration.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<TransferConfig> | |
deleteTransferConfig(DeleteTransferConfigRequest request)
public ListenableFuture<Empty> deleteTransferConfig(DeleteTransferConfigRequest request)
Deletes a data transfer configuration, including any associated transfer
runs and logs.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<Empty> | |
deleteTransferRun(DeleteTransferRunRequest request)
public ListenableFuture<Empty> deleteTransferRun(DeleteTransferRunRequest request)
Deletes the specified transfer run.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<Empty> | |
enrollDataSources(EnrollDataSourcesRequest request)
public ListenableFuture<Empty> enrollDataSources(EnrollDataSourcesRequest request)
Parameter
Returns
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<Empty> | |
getDataSource(GetDataSourceRequest request)
public ListenableFuture<DataSource> getDataSource(GetDataSourceRequest request)
Retrieves a supported data source and returns its settings.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<DataSource> | |
getTransferConfig(GetTransferConfigRequest request)
public ListenableFuture<TransferConfig> getTransferConfig(GetTransferConfigRequest request)
Returns information about a data transfer config.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<TransferConfig> | |
getTransferRun(GetTransferRunRequest request)
public ListenableFuture<TransferRun> getTransferRun(GetTransferRunRequest request)
Returns information about the particular transfer run.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<TransferRun> | |
listDataSources(ListDataSourcesRequest request)
public ListenableFuture<ListDataSourcesResponse> listDataSources(ListDataSourcesRequest request)
Lists supported data sources and returns their settings.
listTransferConfigs(ListTransferConfigsRequest request)
public ListenableFuture<ListTransferConfigsResponse> listTransferConfigs(ListTransferConfigsRequest request)
Returns information about all transfer configs owned by a project in the
specified location.
listTransferLogs(ListTransferLogsRequest request)
public ListenableFuture<ListTransferLogsResponse> listTransferLogs(ListTransferLogsRequest request)
Returns log messages for the transfer run.
listTransferRuns(ListTransferRunsRequest request)
public ListenableFuture<ListTransferRunsResponse> listTransferRuns(ListTransferRunsRequest request)
Returns information about running and completed transfer runs.
scheduleTransferRuns(ScheduleTransferRunsRequest request)
public ListenableFuture<ScheduleTransferRunsResponse> scheduleTransferRuns(ScheduleTransferRunsRequest request)
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.
startManualTransferRuns(StartManualTransferRunsRequest request)
public ListenableFuture<StartManualTransferRunsResponse> startManualTransferRuns(StartManualTransferRunsRequest request)
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.
updateTransferConfig(UpdateTransferConfigRequest request)
public ListenableFuture<TransferConfig> updateTransferConfig(UpdateTransferConfigRequest request)
Updates a data transfer configuration.
All fields must be set, even if they are not updated.
| Type | Description |
| com.google.common.util.concurrent.ListenableFuture<TransferConfig> | |
