Class StreamsServiceClient (0.2.0)

Version latest

• 0.2.0 (latest)
• 0.1.0

GitHub Repository

Product Reference

RPC Documentation

Service Description: Service describing handlers for resources. Vision API and Vision AI API are two independent APIs developed by the same team. Vision API is for people to annotate their image while Vision AI is an e2e solution for customer to build their own computer vision application.

This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName name = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   Cluster response = streamsServiceClient.getCluster(name);
 }
 

Note: close() needs to be called on the StreamsServiceClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().

Methods

Method	Description	Method Variants
ListClusters	Lists Clusters in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. listClusters(ListClustersRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. listClusters(LocationName parent) listClusters(String parent) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. listClustersPagedCallable() listClustersCallable()
GetCluster	Gets details of a single Cluster.	Request object method variants only take one parameter, a request object, which must be constructed before the call. getCluster(GetClusterRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. getCluster(ClusterName name) getCluster(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. getClusterCallable()
CreateCluster	Creates a new Cluster in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. createClusterAsync(CreateClusterRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. createClusterAsync(LocationName parent, Cluster cluster, String clusterId) createClusterAsync(String parent, Cluster cluster, String clusterId) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. createClusterOperationCallable() createClusterCallable()
UpdateCluster	Updates the parameters of a single Cluster.	Request object method variants only take one parameter, a request object, which must be constructed before the call. updateClusterAsync(UpdateClusterRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. updateClusterAsync(Cluster cluster, FieldMask updateMask) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. updateClusterOperationCallable() updateClusterCallable()
DeleteCluster	Deletes a single Cluster.	Request object method variants only take one parameter, a request object, which must be constructed before the call. deleteClusterAsync(DeleteClusterRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. deleteClusterAsync(ClusterName name) deleteClusterAsync(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. deleteClusterOperationCallable() deleteClusterCallable()
ListStreams	Lists Streams in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. listStreams(ListStreamsRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. listStreams(ClusterName parent) listStreams(String parent) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. listStreamsPagedCallable() listStreamsCallable()
GetStream	Gets details of a single Stream.	Request object method variants only take one parameter, a request object, which must be constructed before the call. getStream(GetStreamRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. getStream(StreamName name) getStream(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. getStreamCallable()
CreateStream	Creates a new Stream in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. createStreamAsync(CreateStreamRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. createStreamAsync(ClusterName parent, Stream stream, String streamId) createStreamAsync(String parent, Stream stream, String streamId) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. createStreamOperationCallable() createStreamCallable()
UpdateStream	Updates the parameters of a single Stream.	Request object method variants only take one parameter, a request object, which must be constructed before the call. updateStreamAsync(UpdateStreamRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. updateStreamAsync(Stream stream, FieldMask updateMask) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. updateStreamOperationCallable() updateStreamCallable()
DeleteStream	Deletes a single Stream.	Request object method variants only take one parameter, a request object, which must be constructed before the call. deleteStreamAsync(DeleteStreamRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. deleteStreamAsync(StreamName name) deleteStreamAsync(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. deleteStreamOperationCallable() deleteStreamCallable()
GetStreamThumbnail	Gets the thumbnail (image snapshot) of a single Stream.	Request object method variants only take one parameter, a request object, which must be constructed before the call. getStreamThumbnailAsync(GetStreamThumbnailRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. getStreamThumbnailAsync(String stream, String gcsObjectName) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. getStreamThumbnailOperationCallable() getStreamThumbnailCallable()
GenerateStreamHlsToken	Generate the JWT auth token required to get the stream HLS contents.	Request object method variants only take one parameter, a request object, which must be constructed before the call. generateStreamHlsToken(GenerateStreamHlsTokenRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. generateStreamHlsToken(String stream) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. generateStreamHlsTokenCallable()
ListEvents	Lists Events in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. listEvents(ListEventsRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. listEvents(ClusterName parent) listEvents(String parent) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. listEventsPagedCallable() listEventsCallable()
GetEvent	Gets details of a single Event.	Request object method variants only take one parameter, a request object, which must be constructed before the call. getEvent(GetEventRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. getEvent(EventName name) getEvent(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. getEventCallable()
CreateEvent	Creates a new Event in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. createEventAsync(CreateEventRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. createEventAsync(ClusterName parent, Event event, String eventId) createEventAsync(String parent, Event event, String eventId) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. createEventOperationCallable() createEventCallable()
UpdateEvent	Updates the parameters of a single Event.	Request object method variants only take one parameter, a request object, which must be constructed before the call. updateEventAsync(UpdateEventRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. updateEventAsync(Event event, FieldMask updateMask) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. updateEventOperationCallable() updateEventCallable()
DeleteEvent	Deletes a single Event.	Request object method variants only take one parameter, a request object, which must be constructed before the call. deleteEventAsync(DeleteEventRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. deleteEventAsync(EventName name) deleteEventAsync(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. deleteEventOperationCallable() deleteEventCallable()
ListSeries	Lists Series in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. listSeries(ListSeriesRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. listSeries(ClusterName parent) listSeries(String parent) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. listSeriesPagedCallable() listSeriesCallable()
GetSeries	Gets details of a single Series.	Request object method variants only take one parameter, a request object, which must be constructed before the call. getSeries(GetSeriesRequest request) "Flattened" method variants have converted the fields of the request object into function parameters to enable multiple ways to call the same method. getSeries(SeriesName name) getSeries(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. getSeriesCallable()
CreateSeries	Creates a new Series in a given project and location.	Request object method variants only take one parameter, a request object, which must be constructed before the call. createSeriesAsync(CreateSeriesRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. createSeriesAsync(ClusterName parent, Series series, String seriesId) createSeriesAsync(String parent, Series series, String seriesId) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. createSeriesOperationCallable() createSeriesCallable()
UpdateSeries	Updates the parameters of a single Event.	Request object method variants only take one parameter, a request object, which must be constructed before the call. updateSeriesAsync(UpdateSeriesRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. updateSeriesAsync(Series series, FieldMask updateMask) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. updateSeriesOperationCallable() updateSeriesCallable()
DeleteSeries	Deletes a single Series.	Request object method variants only take one parameter, a request object, which must be constructed before the call. deleteSeriesAsync(DeleteSeriesRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. deleteSeriesAsync(SeriesName name) deleteSeriesAsync(String name) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. deleteSeriesOperationCallable() deleteSeriesCallable()
MaterializeChannel	Materialize a channel.	Request object method variants only take one parameter, a request object, which must be constructed before the call. materializeChannelAsync(MaterializeChannelRequest request) Methods that return long-running operations have "Async" method variants that return OperationFuture, which is used to track polling of the service. materializeChannelAsync(ClusterName parent, Channel channel, String channelId) materializeChannelAsync(String parent, Channel channel, String channelId) Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service. materializeChannelOperationCallable() materializeChannelCallable()

See the individual methods for example code.

Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.

This class can be customized by passing in a custom instance of StreamsServiceSettings to create(). For example:

To customize credentials:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 StreamsServiceSettings streamsServiceSettings =
     StreamsServiceSettings.newBuilder()
         .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
         .build();
 StreamsServiceClient streamsServiceClient = StreamsServiceClient.create(streamsServiceSettings);
 

To customize the endpoint:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 StreamsServiceSettings streamsServiceSettings =
     StreamsServiceSettings.newBuilder().setEndpoint(myEndpoint).build();
 StreamsServiceClient streamsServiceClient = StreamsServiceClient.create(streamsServiceSettings);
 

To use REST (HTTP1.1/JSON) transport (instead of gRPC) for sending and receiving requests over the wire:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 StreamsServiceSettings streamsServiceSettings =
     StreamsServiceSettings.newHttpJsonBuilder().build();
 StreamsServiceClient streamsServiceClient = StreamsServiceClient.create(streamsServiceSettings);
 

Please refer to the GitHub repository's samples for more quickstart code snippets.

Inheritance

java.lang.Object > StreamsServiceClient

Static Methods

create()

public static final StreamsServiceClient create()

Constructs an instance of StreamsServiceClient with default settings.

Returns
Type	Description
StreamsServiceClient

Exceptions
Type	Description
IOException

create(StreamsServiceSettings settings)

public static final StreamsServiceClient create(StreamsServiceSettings settings)

Constructs an instance of StreamsServiceClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.

Parameter
Name	Description
settings	StreamsServiceSettings

Returns
Type	Description
StreamsServiceClient

Exceptions
Type	Description
IOException

create(StreamsServiceStub stub)

public static final StreamsServiceClient create(StreamsServiceStub stub)

Constructs an instance of StreamsServiceClient, using the given stub for making calls. This is for advanced usage - prefer using create(StreamsServiceSettings).

Parameter
Name	Description
stub	StreamsServiceStub

Returns
Type	Description
StreamsServiceClient

Constructors

StreamsServiceClient(StreamsServiceSettings settings)

protected StreamsServiceClient(StreamsServiceSettings settings)

Constructs an instance of StreamsServiceClient, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.

Parameter
Name	Description
settings	StreamsServiceSettings

StreamsServiceClient(StreamsServiceStub stub)

protected StreamsServiceClient(StreamsServiceStub stub)

Parameter
Name	Description
stub	StreamsServiceStub

Methods

awaitTermination(long duration, TimeUnit unit)

public boolean awaitTermination(long duration, TimeUnit unit)

Parameters
Name	Description
duration	long
unit	TimeUnit

Returns
Type	Description
boolean

Exceptions
Type	Description
InterruptedException

close()

public final void close()

createClusterAsync(CreateClusterRequest request)

public final OperationFuture<Cluster,OperationMetadata> createClusterAsync(CreateClusterRequest request)

Creates a new Cluster in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateClusterRequest request =
       CreateClusterRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setClusterId("clusterId561939637")
           .setCluster(Cluster.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Cluster response = streamsServiceClient.createClusterAsync(request).get();
 }
 

Parameter
Name	Description
request	CreateClusterRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Cluster,OperationMetadata>

createClusterAsync(LocationName parent, Cluster cluster, String clusterId)

public final OperationFuture<Cluster,OperationMetadata> createClusterAsync(LocationName parent, Cluster cluster, String clusterId)

Creates a new Cluster in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   Cluster cluster = Cluster.newBuilder().build();
   String clusterId = "clusterId561939637";
   Cluster response = streamsServiceClient.createClusterAsync(parent, cluster, clusterId).get();
 }
 

Parameters
Name	Description
parent	LocationName Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Cluster,OperationMetadata>

createClusterAsync(String parent, Cluster cluster, String clusterId)

public final OperationFuture<Cluster,OperationMetadata> createClusterAsync(String parent, Cluster cluster, String clusterId)

Creates a new Cluster in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   Cluster cluster = Cluster.newBuilder().build();
   String clusterId = "clusterId561939637";
   Cluster response = streamsServiceClient.createClusterAsync(parent, cluster, clusterId).get();
 }
 

Parameters
Name	Description
parent	String Required. Value for parent.
cluster	Cluster Required. The resource being created.
clusterId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Cluster,OperationMetadata>

createClusterCallable()

public final UnaryCallable<CreateClusterRequest,Operation> createClusterCallable()

Creates a new Cluster in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateClusterRequest request =
       CreateClusterRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setClusterId("clusterId561939637")
           .setCluster(Cluster.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future =
       streamsServiceClient.createClusterCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<CreateClusterRequest,Operation>

createClusterOperationCallable()

public final OperationCallable<CreateClusterRequest,Cluster,OperationMetadata> createClusterOperationCallable()

Creates a new Cluster in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateClusterRequest request =
       CreateClusterRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setClusterId("clusterId561939637")
           .setCluster(Cluster.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Cluster, OperationMetadata> future =
       streamsServiceClient.createClusterOperationCallable().futureCall(request);
   // Do something.
   Cluster response = future.get();
 }
 

Returns
Type	Description
OperationCallable<CreateClusterRequest,Cluster,OperationMetadata>

createEventAsync(ClusterName parent, Event event, String eventId)

public final OperationFuture<Event,OperationMetadata> createEventAsync(ClusterName parent, Event event, String eventId)

Creates a new Event in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   Event event = Event.newBuilder().build();
   String eventId = "eventId-1376502443";
   Event response = streamsServiceClient.createEventAsync(parent, event, eventId).get();
 }
 

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
event	Event Required. The resource being created.
eventId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Event,OperationMetadata>

createEventAsync(CreateEventRequest request)

public final OperationFuture<Event,OperationMetadata> createEventAsync(CreateEventRequest request)

Creates a new Event in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateEventRequest request =
       CreateEventRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setEventId("eventId-1376502443")
           .setEvent(Event.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Event response = streamsServiceClient.createEventAsync(request).get();
 }
 

Parameter
Name	Description
request	CreateEventRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Event,OperationMetadata>

createEventAsync(String parent, Event event, String eventId)

public final OperationFuture<Event,OperationMetadata> createEventAsync(String parent, Event event, String eventId)

Creates a new Event in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   Event event = Event.newBuilder().build();
   String eventId = "eventId-1376502443";
   Event response = streamsServiceClient.createEventAsync(parent, event, eventId).get();
 }
 

Parameters
Name	Description
parent	String Required. Value for parent.
event	Event Required. The resource being created.
eventId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Event,OperationMetadata>

createEventCallable()

public final UnaryCallable<CreateEventRequest,Operation> createEventCallable()

Creates a new Event in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateEventRequest request =
       CreateEventRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setEventId("eventId-1376502443")
           .setEvent(Event.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.createEventCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<CreateEventRequest,Operation>

createEventOperationCallable()

public final OperationCallable<CreateEventRequest,Event,OperationMetadata> createEventOperationCallable()

Creates a new Event in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateEventRequest request =
       CreateEventRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setEventId("eventId-1376502443")
           .setEvent(Event.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Event, OperationMetadata> future =
       streamsServiceClient.createEventOperationCallable().futureCall(request);
   // Do something.
   Event response = future.get();
 }
 

Returns
Type	Description
OperationCallable<CreateEventRequest,Event,OperationMetadata>

createSeriesAsync(ClusterName parent, Series series, String seriesId)

public final OperationFuture<Series,OperationMetadata> createSeriesAsync(ClusterName parent, Series series, String seriesId)

Creates a new Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   Series series = Series.newBuilder().build();
   String seriesId = "seriesId1367098866";
   Series response = streamsServiceClient.createSeriesAsync(parent, series, seriesId).get();
 }
 

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
series	Series Required. The resource being created.
seriesId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Series,OperationMetadata>

createSeriesAsync(CreateSeriesRequest request)

public final OperationFuture<Series,OperationMetadata> createSeriesAsync(CreateSeriesRequest request)

Creates a new Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateSeriesRequest request =
       CreateSeriesRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setSeriesId("seriesId1367098866")
           .setSeries(Series.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Series response = streamsServiceClient.createSeriesAsync(request).get();
 }
 

Parameter
Name	Description
request	CreateSeriesRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Series,OperationMetadata>

createSeriesAsync(String parent, Series series, String seriesId)

public final OperationFuture<Series,OperationMetadata> createSeriesAsync(String parent, Series series, String seriesId)

Creates a new Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   Series series = Series.newBuilder().build();
   String seriesId = "seriesId1367098866";
   Series response = streamsServiceClient.createSeriesAsync(parent, series, seriesId).get();
 }
 

Parameters
Name	Description
parent	String Required. Value for parent.
series	Series Required. The resource being created.
seriesId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Series,OperationMetadata>

createSeriesCallable()

public final UnaryCallable<CreateSeriesRequest,Operation> createSeriesCallable()

Creates a new Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateSeriesRequest request =
       CreateSeriesRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setSeriesId("seriesId1367098866")
           .setSeries(Series.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.createSeriesCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<CreateSeriesRequest,Operation>

createSeriesOperationCallable()

public final OperationCallable<CreateSeriesRequest,Series,OperationMetadata> createSeriesOperationCallable()

Creates a new Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateSeriesRequest request =
       CreateSeriesRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setSeriesId("seriesId1367098866")
           .setSeries(Series.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Series, OperationMetadata> future =
       streamsServiceClient.createSeriesOperationCallable().futureCall(request);
   // Do something.
   Series response = future.get();
 }
 

Returns
Type	Description
OperationCallable<CreateSeriesRequest,Series,OperationMetadata>

createStreamAsync(ClusterName parent, Stream stream, String streamId)

public final OperationFuture<Stream,OperationMetadata> createStreamAsync(ClusterName parent, Stream stream, String streamId)

Creates a new Stream in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   Stream stream = Stream.newBuilder().build();
   String streamId = "streamId1790933179";
   Stream response = streamsServiceClient.createStreamAsync(parent, stream, streamId).get();
 }
 

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Stream,OperationMetadata>

createStreamAsync(CreateStreamRequest request)

public final OperationFuture<Stream,OperationMetadata> createStreamAsync(CreateStreamRequest request)

Creates a new Stream in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateStreamRequest request =
       CreateStreamRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setStreamId("streamId1790933179")
           .setStream(Stream.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Stream response = streamsServiceClient.createStreamAsync(request).get();
 }
 

Parameter
Name	Description
request	CreateStreamRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Stream,OperationMetadata>

createStreamAsync(String parent, Stream stream, String streamId)

public final OperationFuture<Stream,OperationMetadata> createStreamAsync(String parent, Stream stream, String streamId)

Creates a new Stream in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   Stream stream = Stream.newBuilder().build();
   String streamId = "streamId1790933179";
   Stream response = streamsServiceClient.createStreamAsync(parent, stream, streamId).get();
 }
 

Parameters
Name	Description
parent	String Required. Value for parent.
stream	Stream Required. The resource being created.
streamId	String Required. Id of the requesting object.

Returns
Type	Description
OperationFuture<Stream,OperationMetadata>

createStreamCallable()

public final UnaryCallable<CreateStreamRequest,Operation> createStreamCallable()

Creates a new Stream in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateStreamRequest request =
       CreateStreamRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setStreamId("streamId1790933179")
           .setStream(Stream.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.createStreamCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<CreateStreamRequest,Operation>

createStreamOperationCallable()

public final OperationCallable<CreateStreamRequest,Stream,OperationMetadata> createStreamOperationCallable()

Creates a new Stream in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   CreateStreamRequest request =
       CreateStreamRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setStreamId("streamId1790933179")
           .setStream(Stream.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Stream, OperationMetadata> future =
       streamsServiceClient.createStreamOperationCallable().futureCall(request);
   // Do something.
   Stream response = future.get();
 }
 

Returns
Type	Description
OperationCallable<CreateStreamRequest,Stream,OperationMetadata>

deleteClusterAsync(ClusterName name)

public final OperationFuture<Empty,OperationMetadata> deleteClusterAsync(ClusterName name)

Deletes a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName name = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   streamsServiceClient.deleteClusterAsync(name).get();
 }
 

Parameter
Name	Description
name	ClusterName Required. Name of the resource

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteClusterAsync(DeleteClusterRequest request)

public final OperationFuture<Empty,OperationMetadata> deleteClusterAsync(DeleteClusterRequest request)

Deletes a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteClusterRequest request =
       DeleteClusterRequest.newBuilder()
           .setName(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setRequestId("requestId693933066")
           .build();
   streamsServiceClient.deleteClusterAsync(request).get();
 }
 

Parameter
Name	Description
request	DeleteClusterRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteClusterAsync(String name)

public final OperationFuture<Empty,OperationMetadata> deleteClusterAsync(String name)

Deletes a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   streamsServiceClient.deleteClusterAsync(name).get();
 }
 

Parameter
Name	Description
name	String Required. Name of the resource

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteClusterCallable()

public final UnaryCallable<DeleteClusterRequest,Operation> deleteClusterCallable()

Deletes a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteClusterRequest request =
       DeleteClusterRequest.newBuilder()
           .setName(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future =
       streamsServiceClient.deleteClusterCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
UnaryCallable<DeleteClusterRequest,Operation>

deleteClusterOperationCallable()

public final OperationCallable<DeleteClusterRequest,Empty,OperationMetadata> deleteClusterOperationCallable()

Deletes a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteClusterRequest request =
       DeleteClusterRequest.newBuilder()
           .setName(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Empty, OperationMetadata> future =
       streamsServiceClient.deleteClusterOperationCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
OperationCallable<DeleteClusterRequest,Empty,OperationMetadata>

deleteEventAsync(DeleteEventRequest request)

public final OperationFuture<Empty,OperationMetadata> deleteEventAsync(DeleteEventRequest request)

Deletes a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteEventRequest request =
       DeleteEventRequest.newBuilder()
           .setName(EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]").toString())
           .setRequestId("requestId693933066")
           .build();
   streamsServiceClient.deleteEventAsync(request).get();
 }
 

Parameter
Name	Description
request	DeleteEventRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteEventAsync(EventName name)

public final OperationFuture<Empty,OperationMetadata> deleteEventAsync(EventName name)

Deletes a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   EventName name = EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
   streamsServiceClient.deleteEventAsync(name).get();
 }
 

Parameter
Name	Description
name	EventName Required. Name of the resource.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteEventAsync(String name)

public final OperationFuture<Empty,OperationMetadata> deleteEventAsync(String name)

Deletes a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]").toString();
   streamsServiceClient.deleteEventAsync(name).get();
 }
 

Parameter
Name	Description
name	String Required. Name of the resource.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteEventCallable()

public final UnaryCallable<DeleteEventRequest,Operation> deleteEventCallable()

Deletes a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteEventRequest request =
       DeleteEventRequest.newBuilder()
           .setName(EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]").toString())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.deleteEventCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
UnaryCallable<DeleteEventRequest,Operation>

deleteEventOperationCallable()

public final OperationCallable<DeleteEventRequest,Empty,OperationMetadata> deleteEventOperationCallable()

Deletes a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteEventRequest request =
       DeleteEventRequest.newBuilder()
           .setName(EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]").toString())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Empty, OperationMetadata> future =
       streamsServiceClient.deleteEventOperationCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
OperationCallable<DeleteEventRequest,Empty,OperationMetadata>

deleteSeriesAsync(DeleteSeriesRequest request)

public final OperationFuture<Empty,OperationMetadata> deleteSeriesAsync(DeleteSeriesRequest request)

Deletes a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteSeriesRequest request =
       DeleteSeriesRequest.newBuilder()
           .setName(SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]").toString())
           .setRequestId("requestId693933066")
           .build();
   streamsServiceClient.deleteSeriesAsync(request).get();
 }
 

Parameter
Name	Description
request	DeleteSeriesRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteSeriesAsync(SeriesName name)

public final OperationFuture<Empty,OperationMetadata> deleteSeriesAsync(SeriesName name)

Deletes a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   SeriesName name = SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
   streamsServiceClient.deleteSeriesAsync(name).get();
 }
 

Parameter
Name	Description
name	SeriesName Required. Name of the resource.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteSeriesAsync(String name)

public final OperationFuture<Empty,OperationMetadata> deleteSeriesAsync(String name)

Deletes a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]").toString();
   streamsServiceClient.deleteSeriesAsync(name).get();
 }
 

Parameter
Name	Description
name	String Required. Name of the resource.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteSeriesCallable()

public final UnaryCallable<DeleteSeriesRequest,Operation> deleteSeriesCallable()

Deletes a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteSeriesRequest request =
       DeleteSeriesRequest.newBuilder()
           .setName(SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]").toString())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.deleteSeriesCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
UnaryCallable<DeleteSeriesRequest,Operation>

deleteSeriesOperationCallable()

public final OperationCallable<DeleteSeriesRequest,Empty,OperationMetadata> deleteSeriesOperationCallable()

Deletes a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteSeriesRequest request =
       DeleteSeriesRequest.newBuilder()
           .setName(SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]").toString())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Empty, OperationMetadata> future =
       streamsServiceClient.deleteSeriesOperationCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
OperationCallable<DeleteSeriesRequest,Empty,OperationMetadata>

deleteStreamAsync(DeleteStreamRequest request)

public final OperationFuture<Empty,OperationMetadata> deleteStreamAsync(DeleteStreamRequest request)

Deletes a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteStreamRequest request =
       DeleteStreamRequest.newBuilder()
           .setName(StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]").toString())
           .setRequestId("requestId693933066")
           .build();
   streamsServiceClient.deleteStreamAsync(request).get();
 }
 

Parameter
Name	Description
request	DeleteStreamRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteStreamAsync(StreamName name)

public final OperationFuture<Empty,OperationMetadata> deleteStreamAsync(StreamName name)

Deletes a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   StreamName name = StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
   streamsServiceClient.deleteStreamAsync(name).get();
 }
 

Parameter
Name	Description
name	StreamName Required. Name of the resource.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteStreamAsync(String name)

public final OperationFuture<Empty,OperationMetadata> deleteStreamAsync(String name)

Deletes a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]").toString();
   streamsServiceClient.deleteStreamAsync(name).get();
 }
 

Parameter
Name	Description
name	String Required. Name of the resource.

Returns
Type	Description
OperationFuture<Empty,OperationMetadata>

deleteStreamCallable()

public final UnaryCallable<DeleteStreamRequest,Operation> deleteStreamCallable()

Deletes a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteStreamRequest request =
       DeleteStreamRequest.newBuilder()
           .setName(StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]").toString())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.deleteStreamCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
UnaryCallable<DeleteStreamRequest,Operation>

deleteStreamOperationCallable()

public final OperationCallable<DeleteStreamRequest,Empty,OperationMetadata> deleteStreamOperationCallable()

Deletes a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   DeleteStreamRequest request =
       DeleteStreamRequest.newBuilder()
           .setName(StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]").toString())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Empty, OperationMetadata> future =
       streamsServiceClient.deleteStreamOperationCallable().futureCall(request);
   // Do something.
   future.get();
 }
 

Returns
Type	Description
OperationCallable<DeleteStreamRequest,Empty,OperationMetadata>

generateStreamHlsToken(GenerateStreamHlsTokenRequest request)

public final GenerateStreamHlsTokenResponse generateStreamHlsToken(GenerateStreamHlsTokenRequest request)

Generate the JWT auth token required to get the stream HLS contents.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GenerateStreamHlsTokenRequest request =
       GenerateStreamHlsTokenRequest.newBuilder().setStream("stream-891990144").build();
   GenerateStreamHlsTokenResponse response =
       streamsServiceClient.generateStreamHlsToken(request);
 }
 

Parameter
Name	Description
request	GenerateStreamHlsTokenRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
GenerateStreamHlsTokenResponse

generateStreamHlsToken(String stream)

public final GenerateStreamHlsTokenResponse generateStreamHlsToken(String stream)

Generate the JWT auth token required to get the stream HLS contents.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String stream = "stream-891990144";
   GenerateStreamHlsTokenResponse response = streamsServiceClient.generateStreamHlsToken(stream);
 }
 

Parameter
Name	Description
stream	String Required. The name of the stream.

Returns
Type	Description
GenerateStreamHlsTokenResponse

generateStreamHlsTokenCallable()

public final UnaryCallable<GenerateStreamHlsTokenRequest,GenerateStreamHlsTokenResponse> generateStreamHlsTokenCallable()

Generate the JWT auth token required to get the stream HLS contents.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GenerateStreamHlsTokenRequest request =
       GenerateStreamHlsTokenRequest.newBuilder().setStream("stream-891990144").build();
   ApiFuture<GenerateStreamHlsTokenResponse> future =
       streamsServiceClient.generateStreamHlsTokenCallable().futureCall(request);
   // Do something.
   GenerateStreamHlsTokenResponse response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<GenerateStreamHlsTokenRequest,GenerateStreamHlsTokenResponse>

getCluster(ClusterName name)

public final Cluster getCluster(ClusterName name)

Gets details of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName name = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   Cluster response = streamsServiceClient.getCluster(name);
 }
 

Parameter
Name	Description
name	ClusterName Required. Name of the resource.

Returns
Type	Description
Cluster

getCluster(GetClusterRequest request)

public final Cluster getCluster(GetClusterRequest request)

Gets details of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetClusterRequest request =
       GetClusterRequest.newBuilder()
           .setName(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .build();
   Cluster response = streamsServiceClient.getCluster(request);
 }
 

Parameter
Name	Description
request	GetClusterRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
Cluster

getCluster(String name)

public final Cluster getCluster(String name)

Gets details of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   Cluster response = streamsServiceClient.getCluster(name);
 }
 

Parameter
Name	Description
name	String Required. Name of the resource.

Returns
Type	Description
Cluster

getClusterCallable()

public final UnaryCallable<GetClusterRequest,Cluster> getClusterCallable()

Gets details of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetClusterRequest request =
       GetClusterRequest.newBuilder()
           .setName(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .build();
   ApiFuture<Cluster> future = streamsServiceClient.getClusterCallable().futureCall(request);
   // Do something.
   Cluster response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<GetClusterRequest,Cluster>

getEvent(EventName name)

public final Event getEvent(EventName name)

Gets details of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   EventName name = EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]");
   Event response = streamsServiceClient.getEvent(name);
 }
 

Parameter
Name	Description
name	EventName Required. Name of the resource.

Returns
Type	Description
Event

getEvent(GetEventRequest request)

public final Event getEvent(GetEventRequest request)

Gets details of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetEventRequest request =
       GetEventRequest.newBuilder()
           .setName(EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]").toString())
           .build();
   Event response = streamsServiceClient.getEvent(request);
 }
 

Parameter
Name	Description
request	GetEventRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
Event

getEvent(String name)

public final Event getEvent(String name)

Gets details of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]").toString();
   Event response = streamsServiceClient.getEvent(name);
 }
 

Parameter
Name	Description
name	String Required. Name of the resource.

Returns
Type	Description
Event

getEventCallable()

public final UnaryCallable<GetEventRequest,Event> getEventCallable()

Gets details of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetEventRequest request =
       GetEventRequest.newBuilder()
           .setName(EventName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[EVENT]").toString())
           .build();
   ApiFuture<Event> future = streamsServiceClient.getEventCallable().futureCall(request);
   // Do something.
   Event response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<GetEventRequest,Event>

getHttpJsonOperationsClient()

public final OperationsClient getHttpJsonOperationsClient()

Beta

This feature is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.

Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.

Returns
Type	Description
OperationsClient

getOperationsClient()

public final OperationsClient getOperationsClient()

Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.

Returns
Type	Description
OperationsClient

getSeries(GetSeriesRequest request)

public final Series getSeries(GetSeriesRequest request)

Gets details of a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetSeriesRequest request =
       GetSeriesRequest.newBuilder()
           .setName(SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]").toString())
           .build();
   Series response = streamsServiceClient.getSeries(request);
 }
 

Parameter
Name	Description
request	GetSeriesRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
Series

getSeries(SeriesName name)

public final Series getSeries(SeriesName name)

Gets details of a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   SeriesName name = SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]");
   Series response = streamsServiceClient.getSeries(name);
 }
 

Parameter
Name	Description
name	SeriesName Required. Name of the resource.

Returns
Type	Description
Series

getSeries(String name)

public final Series getSeries(String name)

Gets details of a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]").toString();
   Series response = streamsServiceClient.getSeries(name);
 }
 

Parameter
Name	Description
name	String Required. Name of the resource.

Returns
Type	Description
Series

getSeriesCallable()

public final UnaryCallable<GetSeriesRequest,Series> getSeriesCallable()

Gets details of a single Series.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetSeriesRequest request =
       GetSeriesRequest.newBuilder()
           .setName(SeriesName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[SERIES]").toString())
           .build();
   ApiFuture<Series> future = streamsServiceClient.getSeriesCallable().futureCall(request);
   // Do something.
   Series response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<GetSeriesRequest,Series>

getSettings()

public final StreamsServiceSettings getSettings()

Returns
Type	Description
StreamsServiceSettings

getStream(GetStreamRequest request)

public final Stream getStream(GetStreamRequest request)

Gets details of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetStreamRequest request =
       GetStreamRequest.newBuilder()
           .setName(StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]").toString())
           .build();
   Stream response = streamsServiceClient.getStream(request);
 }
 

Parameter
Name	Description
request	GetStreamRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
Stream

getStream(StreamName name)

public final Stream getStream(StreamName name)

Gets details of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   StreamName name = StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]");
   Stream response = streamsServiceClient.getStream(name);
 }
 

Parameter
Name	Description
name	StreamName Required. Name of the resource.

Returns
Type	Description
Stream

getStream(String name)

public final Stream getStream(String name)

Gets details of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String name = StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]").toString();
   Stream response = streamsServiceClient.getStream(name);
 }
 

Parameter
Name	Description
name	String Required. Name of the resource.

Returns
Type	Description
Stream

getStreamCallable()

public final UnaryCallable<GetStreamRequest,Stream> getStreamCallable()

Gets details of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetStreamRequest request =
       GetStreamRequest.newBuilder()
           .setName(StreamName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]", "[STREAM]").toString())
           .build();
   ApiFuture<Stream> future = streamsServiceClient.getStreamCallable().futureCall(request);
   // Do something.
   Stream response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<GetStreamRequest,Stream>

getStreamThumbnailAsync(GetStreamThumbnailRequest request)

public final OperationFuture<GetStreamThumbnailResponse,OperationMetadata> getStreamThumbnailAsync(GetStreamThumbnailRequest request)

Gets the thumbnail (image snapshot) of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetStreamThumbnailRequest request =
       GetStreamThumbnailRequest.newBuilder()
           .setStream("stream-891990144")
           .setGcsObjectName("gcsObjectName-1987275551")
           .setEvent("event96891546")
           .setRequestId("requestId693933066")
           .build();
   GetStreamThumbnailResponse response =
       streamsServiceClient.getStreamThumbnailAsync(request).get();
 }
 

Parameter
Name	Description
request	GetStreamThumbnailRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<GetStreamThumbnailResponse,OperationMetadata>

getStreamThumbnailAsync(String stream, String gcsObjectName)

public final OperationFuture<GetStreamThumbnailResponse,OperationMetadata> getStreamThumbnailAsync(String stream, String gcsObjectName)

Gets the thumbnail (image snapshot) of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String stream = "stream-891990144";
   String gcsObjectName = "gcsObjectName-1987275551";
   GetStreamThumbnailResponse response =
       streamsServiceClient.getStreamThumbnailAsync(stream, gcsObjectName).get();
 }
 

Parameters
Name	Description
stream	String Required. The name of the stream for to get the thumbnail from.
gcsObjectName	String Required. The name of the GCS object to store the thumbnail image.

Returns
Type	Description
OperationFuture<GetStreamThumbnailResponse,OperationMetadata>

getStreamThumbnailCallable()

public final UnaryCallable<GetStreamThumbnailRequest,Operation> getStreamThumbnailCallable()

Gets the thumbnail (image snapshot) of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetStreamThumbnailRequest request =
       GetStreamThumbnailRequest.newBuilder()
           .setStream("stream-891990144")
           .setGcsObjectName("gcsObjectName-1987275551")
           .setEvent("event96891546")
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future =
       streamsServiceClient.getStreamThumbnailCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<GetStreamThumbnailRequest,Operation>

getStreamThumbnailOperationCallable()

public final OperationCallable<GetStreamThumbnailRequest,GetStreamThumbnailResponse,OperationMetadata> getStreamThumbnailOperationCallable()

Gets the thumbnail (image snapshot) of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   GetStreamThumbnailRequest request =
       GetStreamThumbnailRequest.newBuilder()
           .setStream("stream-891990144")
           .setGcsObjectName("gcsObjectName-1987275551")
           .setEvent("event96891546")
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<GetStreamThumbnailResponse, OperationMetadata> future =
       streamsServiceClient.getStreamThumbnailOperationCallable().futureCall(request);
   // Do something.
   GetStreamThumbnailResponse response = future.get();
 }
 

Returns
Type	Description
OperationCallable<GetStreamThumbnailRequest,GetStreamThumbnailResponse,OperationMetadata>

getStub()

public StreamsServiceStub getStub()

Returns
Type	Description
StreamsServiceStub

isShutdown()

public boolean isShutdown()

Returns
Type	Description
boolean

isTerminated()

public boolean isTerminated()

Returns
Type	Description
boolean

listClusters(ListClustersRequest request)

public final StreamsServiceClient.ListClustersPagedResponse listClusters(ListClustersRequest request)

Lists Clusters in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListClustersRequest request =
       ListClustersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   for (Cluster element : streamsServiceClient.listClusters(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
request	ListClustersRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
StreamsServiceClient.ListClustersPagedResponse

listClusters(LocationName parent)

public final StreamsServiceClient.ListClustersPagedResponse listClusters(LocationName parent)

Lists Clusters in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (Cluster element : streamsServiceClient.listClusters(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	LocationName Required. Parent value for ListClustersRequest.

Returns
Type	Description
StreamsServiceClient.ListClustersPagedResponse

listClusters(String parent)

public final StreamsServiceClient.ListClustersPagedResponse listClusters(String parent)

Lists Clusters in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (Cluster element : streamsServiceClient.listClusters(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	String Required. Parent value for ListClustersRequest.

Returns
Type	Description
StreamsServiceClient.ListClustersPagedResponse

listClustersCallable()

public final UnaryCallable<ListClustersRequest,ListClustersResponse> listClustersCallable()

Lists Clusters in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListClustersRequest request =
       ListClustersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   while (true) {
     ListClustersResponse response = streamsServiceClient.listClustersCallable().call(request);
     for (Cluster element : response.getClustersList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
 

Returns
Type	Description
UnaryCallable<ListClustersRequest,ListClustersResponse>

listClustersPagedCallable()

public final UnaryCallable<ListClustersRequest,StreamsServiceClient.ListClustersPagedResponse> listClustersPagedCallable()

Lists Clusters in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListClustersRequest request =
       ListClustersRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   ApiFuture<Cluster> future =
       streamsServiceClient.listClustersPagedCallable().futureCall(request);
   // Do something.
   for (Cluster element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Returns
Type	Description
UnaryCallable<ListClustersRequest,ListClustersPagedResponse>

listEvents(ClusterName parent)

public final StreamsServiceClient.ListEventsPagedResponse listEvents(ClusterName parent)

Lists Events in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   for (Event element : streamsServiceClient.listEvents(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	ClusterName Required. Parent value for ListEventsRequest.

Returns
Type	Description
StreamsServiceClient.ListEventsPagedResponse

listEvents(ListEventsRequest request)

public final StreamsServiceClient.ListEventsPagedResponse listEvents(ListEventsRequest request)

Lists Events in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListEventsRequest request =
       ListEventsRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   for (Event element : streamsServiceClient.listEvents(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
request	ListEventsRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
StreamsServiceClient.ListEventsPagedResponse

listEvents(String parent)

public final StreamsServiceClient.ListEventsPagedResponse listEvents(String parent)

Lists Events in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   for (Event element : streamsServiceClient.listEvents(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	String Required. Parent value for ListEventsRequest.

Returns
Type	Description
StreamsServiceClient.ListEventsPagedResponse

listEventsCallable()

public final UnaryCallable<ListEventsRequest,ListEventsResponse> listEventsCallable()

Lists Events in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListEventsRequest request =
       ListEventsRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   while (true) {
     ListEventsResponse response = streamsServiceClient.listEventsCallable().call(request);
     for (Event element : response.getEventsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
 

Returns
Type	Description
UnaryCallable<ListEventsRequest,ListEventsResponse>

listEventsPagedCallable()

public final UnaryCallable<ListEventsRequest,StreamsServiceClient.ListEventsPagedResponse> listEventsPagedCallable()

Lists Events in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListEventsRequest request =
       ListEventsRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   ApiFuture<Event> future = streamsServiceClient.listEventsPagedCallable().futureCall(request);
   // Do something.
   for (Event element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Returns
Type	Description
UnaryCallable<ListEventsRequest,ListEventsPagedResponse>

listSeries(ClusterName parent)

public final StreamsServiceClient.ListSeriesPagedResponse listSeries(ClusterName parent)

Lists Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   for (Series element : streamsServiceClient.listSeries(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	ClusterName Required. Parent value for ListSeriesRequest.

Returns
Type	Description
StreamsServiceClient.ListSeriesPagedResponse

listSeries(ListSeriesRequest request)

public final StreamsServiceClient.ListSeriesPagedResponse listSeries(ListSeriesRequest request)

Lists Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListSeriesRequest request =
       ListSeriesRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   for (Series element : streamsServiceClient.listSeries(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
request	ListSeriesRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
StreamsServiceClient.ListSeriesPagedResponse

listSeries(String parent)

public final StreamsServiceClient.ListSeriesPagedResponse listSeries(String parent)

Lists Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   for (Series element : streamsServiceClient.listSeries(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	String Required. Parent value for ListSeriesRequest.

Returns
Type	Description
StreamsServiceClient.ListSeriesPagedResponse

listSeriesCallable()

public final UnaryCallable<ListSeriesRequest,ListSeriesResponse> listSeriesCallable()

Lists Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListSeriesRequest request =
       ListSeriesRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   while (true) {
     ListSeriesResponse response = streamsServiceClient.listSeriesCallable().call(request);
     for (Series element : response.getSeriesList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
 

Returns
Type	Description
UnaryCallable<ListSeriesRequest,ListSeriesResponse>

listSeriesPagedCallable()

public final UnaryCallable<ListSeriesRequest,StreamsServiceClient.ListSeriesPagedResponse> listSeriesPagedCallable()

Lists Series in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListSeriesRequest request =
       ListSeriesRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   ApiFuture<Series> future = streamsServiceClient.listSeriesPagedCallable().futureCall(request);
   // Do something.
   for (Series element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Returns
Type	Description
UnaryCallable<ListSeriesRequest,ListSeriesPagedResponse>

listStreams(ClusterName parent)

public final StreamsServiceClient.ListStreamsPagedResponse listStreams(ClusterName parent)

Lists Streams in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   for (Stream element : streamsServiceClient.listStreams(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	ClusterName Required. Parent value for ListStreamsRequest.

Returns
Type	Description
StreamsServiceClient.ListStreamsPagedResponse

listStreams(ListStreamsRequest request)

public final StreamsServiceClient.ListStreamsPagedResponse listStreams(ListStreamsRequest request)

Lists Streams in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListStreamsRequest request =
       ListStreamsRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   for (Stream element : streamsServiceClient.listStreams(request).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
request	ListStreamsRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
StreamsServiceClient.ListStreamsPagedResponse

listStreams(String parent)

public final StreamsServiceClient.ListStreamsPagedResponse listStreams(String parent)

Lists Streams in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   for (Stream element : streamsServiceClient.listStreams(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Parameter
Name	Description
parent	String Required. Parent value for ListStreamsRequest.

Returns
Type	Description
StreamsServiceClient.ListStreamsPagedResponse

listStreamsCallable()

public final UnaryCallable<ListStreamsRequest,ListStreamsResponse> listStreamsCallable()

Lists Streams in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListStreamsRequest request =
       ListStreamsRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   while (true) {
     ListStreamsResponse response = streamsServiceClient.listStreamsCallable().call(request);
     for (Stream element : response.getStreamsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }
 

Returns
Type	Description
UnaryCallable<ListStreamsRequest,ListStreamsResponse>

listStreamsPagedCallable()

public final UnaryCallable<ListStreamsRequest,StreamsServiceClient.ListStreamsPagedResponse> listStreamsPagedCallable()

Lists Streams in a given project and location.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ListStreamsRequest request =
       ListStreamsRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .setFilter("filter-1274492040")
           .setOrderBy("orderBy-1207110587")
           .build();
   ApiFuture<Stream> future =
       streamsServiceClient.listStreamsPagedCallable().futureCall(request);
   // Do something.
   for (Stream element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }
 

Returns
Type	Description
UnaryCallable<ListStreamsRequest,ListStreamsPagedResponse>

materializeChannelAsync(ClusterName parent, Channel channel, String channelId)

public final OperationFuture<Channel,OperationMetadata> materializeChannelAsync(ClusterName parent, Channel channel, String channelId)

Materialize a channel.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   ClusterName parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]");
   Channel channel = Channel.newBuilder().build();
   String channelId = "channelId1461735806";
   Channel response =
       streamsServiceClient.materializeChannelAsync(parent, channel, channelId).get();
 }
 

Parameters
Name	Description
parent	ClusterName Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	String Required. Id of the channel.

Returns
Type	Description
OperationFuture<Channel,OperationMetadata>

materializeChannelAsync(MaterializeChannelRequest request)

public final OperationFuture<Channel,OperationMetadata> materializeChannelAsync(MaterializeChannelRequest request)

Materialize a channel.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   MaterializeChannelRequest request =
       MaterializeChannelRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setChannelId("channelId1461735806")
           .setChannel(Channel.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Channel response = streamsServiceClient.materializeChannelAsync(request).get();
 }
 

Parameter
Name	Description
request	MaterializeChannelRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Channel,OperationMetadata>

materializeChannelAsync(String parent, Channel channel, String channelId)

public final OperationFuture<Channel,OperationMetadata> materializeChannelAsync(String parent, Channel channel, String channelId)

Materialize a channel.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   String parent = ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString();
   Channel channel = Channel.newBuilder().build();
   String channelId = "channelId1461735806";
   Channel response =
       streamsServiceClient.materializeChannelAsync(parent, channel, channelId).get();
 }
 

Parameters
Name	Description
parent	String Required. Value for parent.
channel	Channel Required. The resource being created.
channelId	String Required. Id of the channel.

Returns
Type	Description
OperationFuture<Channel,OperationMetadata>

materializeChannelCallable()

public final UnaryCallable<MaterializeChannelRequest,Operation> materializeChannelCallable()

Materialize a channel.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   MaterializeChannelRequest request =
       MaterializeChannelRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setChannelId("channelId1461735806")
           .setChannel(Channel.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future =
       streamsServiceClient.materializeChannelCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<MaterializeChannelRequest,Operation>

materializeChannelOperationCallable()

public final OperationCallable<MaterializeChannelRequest,Channel,OperationMetadata> materializeChannelOperationCallable()

Materialize a channel.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   MaterializeChannelRequest request =
       MaterializeChannelRequest.newBuilder()
           .setParent(ClusterName.of("[PROJECT]", "[LOCATION]", "[CLUSTER]").toString())
           .setChannelId("channelId1461735806")
           .setChannel(Channel.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Channel, OperationMetadata> future =
       streamsServiceClient.materializeChannelOperationCallable().futureCall(request);
   // Do something.
   Channel response = future.get();
 }
 

Returns
Type	Description
OperationCallable<MaterializeChannelRequest,Channel,OperationMetadata>

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

updateClusterAsync(Cluster cluster, FieldMask updateMask)

public final OperationFuture<Cluster,OperationMetadata> updateClusterAsync(Cluster cluster, FieldMask updateMask)

Updates the parameters of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   Cluster cluster = Cluster.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Cluster response = streamsServiceClient.updateClusterAsync(cluster, updateMask).get();
 }
 

Parameters
Name	Description
cluster	Cluster Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Cluster resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.

Returns
Type	Description
OperationFuture<Cluster,OperationMetadata>

updateClusterAsync(UpdateClusterRequest request)

public final OperationFuture<Cluster,OperationMetadata> updateClusterAsync(UpdateClusterRequest request)

Updates the parameters of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateClusterRequest request =
       UpdateClusterRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setCluster(Cluster.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Cluster response = streamsServiceClient.updateClusterAsync(request).get();
 }
 

Parameter
Name	Description
request	UpdateClusterRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Cluster,OperationMetadata>

updateClusterCallable()

public final UnaryCallable<UpdateClusterRequest,Operation> updateClusterCallable()

Updates the parameters of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateClusterRequest request =
       UpdateClusterRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setCluster(Cluster.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future =
       streamsServiceClient.updateClusterCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<UpdateClusterRequest,Operation>

updateClusterOperationCallable()

public final OperationCallable<UpdateClusterRequest,Cluster,OperationMetadata> updateClusterOperationCallable()

Updates the parameters of a single Cluster.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateClusterRequest request =
       UpdateClusterRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setCluster(Cluster.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Cluster, OperationMetadata> future =
       streamsServiceClient.updateClusterOperationCallable().futureCall(request);
   // Do something.
   Cluster response = future.get();
 }
 

Returns
Type	Description
OperationCallable<UpdateClusterRequest,Cluster,OperationMetadata>

updateEventAsync(Event event, FieldMask updateMask)

public final OperationFuture<Event,OperationMetadata> updateEventAsync(Event event, FieldMask updateMask)

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   Event event = Event.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Event response = streamsServiceClient.updateEventAsync(event, updateMask).get();
 }
 

Parameters
Name	Description
event	Event Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Event resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.

Returns
Type	Description
OperationFuture<Event,OperationMetadata>

updateEventAsync(UpdateEventRequest request)

public final OperationFuture<Event,OperationMetadata> updateEventAsync(UpdateEventRequest request)

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateEventRequest request =
       UpdateEventRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setEvent(Event.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Event response = streamsServiceClient.updateEventAsync(request).get();
 }
 

Parameter
Name	Description
request	UpdateEventRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Event,OperationMetadata>

updateEventCallable()

public final UnaryCallable<UpdateEventRequest,Operation> updateEventCallable()

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateEventRequest request =
       UpdateEventRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setEvent(Event.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.updateEventCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<UpdateEventRequest,Operation>

updateEventOperationCallable()

public final OperationCallable<UpdateEventRequest,Event,OperationMetadata> updateEventOperationCallable()

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateEventRequest request =
       UpdateEventRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setEvent(Event.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Event, OperationMetadata> future =
       streamsServiceClient.updateEventOperationCallable().futureCall(request);
   // Do something.
   Event response = future.get();
 }
 

Returns
Type	Description
OperationCallable<UpdateEventRequest,Event,OperationMetadata>

updateSeriesAsync(Series series, FieldMask updateMask)

public final OperationFuture<Series,OperationMetadata> updateSeriesAsync(Series series, FieldMask updateMask)

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   Series series = Series.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Series response = streamsServiceClient.updateSeriesAsync(series, updateMask).get();
 }
 

Parameters
Name	Description
series	Series Required. The resource being updated
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Series resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.

Returns
Type	Description
OperationFuture<Series,OperationMetadata>

updateSeriesAsync(UpdateSeriesRequest request)

public final OperationFuture<Series,OperationMetadata> updateSeriesAsync(UpdateSeriesRequest request)

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateSeriesRequest request =
       UpdateSeriesRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setSeries(Series.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Series response = streamsServiceClient.updateSeriesAsync(request).get();
 }
 

Parameter
Name	Description
request	UpdateSeriesRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Series,OperationMetadata>

updateSeriesCallable()

public final UnaryCallable<UpdateSeriesRequest,Operation> updateSeriesCallable()

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateSeriesRequest request =
       UpdateSeriesRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setSeries(Series.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.updateSeriesCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<UpdateSeriesRequest,Operation>

updateSeriesOperationCallable()

public final OperationCallable<UpdateSeriesRequest,Series,OperationMetadata> updateSeriesOperationCallable()

Updates the parameters of a single Event.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateSeriesRequest request =
       UpdateSeriesRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setSeries(Series.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Series, OperationMetadata> future =
       streamsServiceClient.updateSeriesOperationCallable().futureCall(request);
   // Do something.
   Series response = future.get();
 }
 

Returns
Type	Description
OperationCallable<UpdateSeriesRequest,Series,OperationMetadata>

updateStreamAsync(Stream stream, FieldMask updateMask)

public final OperationFuture<Stream,OperationMetadata> updateStreamAsync(Stream stream, FieldMask updateMask)

Updates the parameters of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   Stream stream = Stream.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Stream response = streamsServiceClient.updateStreamAsync(stream, updateMask).get();
 }
 

Parameters
Name	Description
stream	Stream Required. The resource being updated.
updateMask	FieldMask Required. Field mask is used to specify the fields to be overwritten in the Stream resource by the update. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask then all fields will be overwritten.

Returns
Type	Description
OperationFuture<Stream,OperationMetadata>

updateStreamAsync(UpdateStreamRequest request)

public final OperationFuture<Stream,OperationMetadata> updateStreamAsync(UpdateStreamRequest request)

Updates the parameters of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateStreamRequest request =
       UpdateStreamRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setStream(Stream.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Stream response = streamsServiceClient.updateStreamAsync(request).get();
 }
 

Parameter
Name	Description
request	UpdateStreamRequest The request object containing all of the parameters for the API call.

Returns
Type	Description
OperationFuture<Stream,OperationMetadata>

updateStreamCallable()

public final UnaryCallable<UpdateStreamRequest,Operation> updateStreamCallable()

Updates the parameters of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateStreamRequest request =
       UpdateStreamRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setStream(Stream.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Operation> future = streamsServiceClient.updateStreamCallable().futureCall(request);
   // Do something.
   Operation response = future.get();
 }
 

Returns
Type	Description
UnaryCallable<UpdateStreamRequest,Operation>

updateStreamOperationCallable()

public final OperationCallable<UpdateStreamRequest,Stream,OperationMetadata> updateStreamOperationCallable()

Updates the parameters of a single Stream.

Sample code:

 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (StreamsServiceClient streamsServiceClient = StreamsServiceClient.create()) {
   UpdateStreamRequest request =
       UpdateStreamRequest.newBuilder()
           .setUpdateMask(FieldMask.newBuilder().build())
           .setStream(Stream.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   OperationFuture<Stream, OperationMetadata> future =
       streamsServiceClient.updateStreamOperationCallable().futureCall(request);
   // Do something.
   Stream response = future.get();
 }
 

Returns
Type	Description
OperationCallable<UpdateStreamRequest,Stream,OperationMetadata>