Class StreamsServiceClient (0.4.0)

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()

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>`