Class DatastreamGrpc.DatastreamFutureStub (1.6.0)
1.86.0 (latest)
1.84.0
1.82.0
1.81.0
1.80.0
1.79.0
1.77.0
1.75.0
1.74.0
1.73.0
1.72.0
1.71.0
1.69.0
1.67.0
1.66.0
1.63.0
1.62.0
1.61.0
1.59.0
1.58.0
1.57.0
1.56.0
1.55.0
1.54.0
1.53.0
1.52.0
1.51.0
1.50.0
1.48.0
1.47.0
1.46.0
1.45.0
1.44.0
1.43.0
1.42.0
1.41.0
1.40.0
1.39.0
1.38.0
1.36.0
1.35.0
1.34.0
1.33.0
1.32.0
1.31.0
1.30.0
1.29.0
1.28.0
1.27.0
1.26.0
1.23.0
1.22.0
1.21.0
1.20.0
1.19.0
1.18.0
1.17.0
1.16.0
1.15.0
1.14.0
1.13.0
1.12.0
1.11.0
1.10.0
1.8.0
1.7.0
1.6.0
1.5.0
1.4.0
1.3.0
1.2.2
1.1.1
1.0.0
0.4.2
public static final class DatastreamGrpc . DatastreamFutureStub extends AbstractFutureStub<DatastreamGrpc . DatastreamFutureStub >
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
DatastreamGrpc.DatastreamFutureStub
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 DatastreamGrpc . DatastreamFutureStub 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)
createConnectionProfile(CreateConnectionProfileRequest request)
public ListenableFuture<Operation> createConnectionProfile ( CreateConnectionProfileRequest request )
Use this method to create a connection profile in a project and location.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
createPrivateConnection(CreatePrivateConnectionRequest request)
public ListenableFuture<Operation> createPrivateConnection ( CreatePrivateConnectionRequest request )
Use this method to create a private connectivity configuration.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
createRoute(CreateRouteRequest request)
public ListenableFuture<Operation> createRoute ( CreateRouteRequest request )
Use this method to create a route for a private connectivity in a project
and location.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
createStream(CreateStreamRequest request)
public ListenableFuture<Operation> createStream ( CreateStreamRequest request )
Use this method to create a stream.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
deleteConnectionProfile(DeleteConnectionProfileRequest request)
public ListenableFuture<Operation> deleteConnectionProfile ( DeleteConnectionProfileRequest request )
Use this method to delete a connection profile..
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
deletePrivateConnection(DeletePrivateConnectionRequest request)
public ListenableFuture<Operation> deletePrivateConnection ( DeletePrivateConnectionRequest request )
Use this method to delete a private connectivity configuration.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
deleteRoute(DeleteRouteRequest request)
public ListenableFuture<Operation> deleteRoute ( DeleteRouteRequest request )
Use this method to delete a route.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
deleteStream(DeleteStreamRequest request)
public ListenableFuture<Operation> deleteStream ( DeleteStreamRequest request )
Use this method to delete a stream.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
discoverConnectionProfile(DiscoverConnectionProfileRequest request)
public ListenableFuture<DiscoverConnectionProfileResponse> discoverConnectionProfile ( DiscoverConnectionProfileRequest request )
Use this method to discover a connection profile.
The discover API call exposes the data objects and metadata belonging to
the profile. Typically, a request returns children data objects under a
parent data object that's optionally supplied in the request.
Parameter
Returns
fetchErrors(FetchErrorsRequest request)
public ListenableFuture<Operation> fetchErrors ( FetchErrorsRequest request )
Use this method to fetch any errors associated with a stream.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
fetchStaticIps(FetchStaticIpsRequest request)
public ListenableFuture<FetchStaticIpsResponse> fetchStaticIps ( FetchStaticIpsRequest request )
The FetchStaticIps API call exposes the static ips used by Datastream.
Typically, a request returns children data objects under
a parent data object that's optionally supplied in the request.
Parameter
Returns
getConnectionProfile(GetConnectionProfileRequest request)
public ListenableFuture<ConnectionProfile> getConnectionProfile ( GetConnectionProfileRequest request )
Use this method to get details about a connection profile.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <ConnectionProfile >
getPrivateConnection(GetPrivateConnectionRequest request)
public ListenableFuture<PrivateConnection> getPrivateConnection ( GetPrivateConnectionRequest request )
Use this method to get details about a private connectivity configuration.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <PrivateConnection >
getRoute(GetRouteRequest request)
public ListenableFuture<Route> getRoute ( GetRouteRequest request )
Use this method to get details about a route.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Route >
getStream(GetStreamRequest request)
public ListenableFuture<Stream> getStream ( GetStreamRequest request )
Use this method to get details about a stream.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Stream >
listConnectionProfiles(ListConnectionProfilesRequest request)
public ListenableFuture<ListConnectionProfilesResponse> listConnectionProfiles ( ListConnectionProfilesRequest request )
Use this method to list connection profiles created in a project and
location.
Parameter
Returns
listPrivateConnections(ListPrivateConnectionsRequest request)
public ListenableFuture<ListPrivateConnectionsResponse> listPrivateConnections ( ListPrivateConnectionsRequest request )
Use this method to list private connectivity configurations in a project
and location.
Parameter
Returns
listRoutes(ListRoutesRequest request)
public ListenableFuture<ListRoutesResponse> listRoutes ( ListRoutesRequest request )
Use this method to list routes created for a private connectivity in a
project and location.
Parameter
Returns
listStreams(ListStreamsRequest request)
public ListenableFuture<ListStreamsResponse> listStreams ( ListStreamsRequest request )
Use this method to list streams in a project and location.
Parameter
Returns
updateConnectionProfile(UpdateConnectionProfileRequest request)
public ListenableFuture<Operation> updateConnectionProfile ( UpdateConnectionProfileRequest request )
Use this method to update the parameters of a connection profile.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
updateStream(UpdateStreamRequest request)
public ListenableFuture<Operation> updateStream ( UpdateStreamRequest request )
Use this method to update the configuration of a stream.
Parameter
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
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 2026-03-14 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2026-03-14 UTC."],[],[]]
