{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
@@ -87,6 +89,8 @@
* To customize credentials:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatastreamSettings datastreamSettings =
* DatastreamSettings.newBuilder()
* .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
@@ -97,6 +101,8 @@
* To customize the endpoint:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatastreamSettings datastreamSettings =
* DatastreamSettings.newBuilder().setEndpoint(myEndpoint).build();
* DatastreamClient datastreamClient = DatastreamClient.create(datastreamSettings);
@@ -173,6 +179,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (ConnectionProfile element :
@@ -200,6 +208,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(Location
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (ConnectionProfile element :
@@ -225,6 +235,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(String p
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListConnectionProfilesRequest request =
* ListConnectionProfilesRequest.newBuilder()
@@ -256,6 +268,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListConnectionProfilesRequest request =
* ListConnectionProfilesRequest.newBuilder()
@@ -286,6 +300,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListConnectionProfilesRequest request =
* ListConnectionProfilesRequest.newBuilder()
@@ -323,6 +339,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
@@ -348,6 +366,8 @@ public final ConnectionProfile getConnectionProfile(ConnectionProfileName name)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]").toString();
@@ -371,6 +391,8 @@ public final ConnectionProfile getConnectionProfile(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetConnectionProfileRequest request =
* GetConnectionProfileRequest.newBuilder()
@@ -396,6 +418,8 @@ public final ConnectionProfile getConnectionProfile(GetConnectionProfileRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetConnectionProfileRequest request =
* GetConnectionProfileRequest.newBuilder()
@@ -422,6 +446,8 @@ public final ConnectionProfile getConnectionProfile(GetConnectionProfileRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* ConnectionProfile connectionProfile = ConnectionProfile.newBuilder().build();
@@ -456,6 +482,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* ConnectionProfile connectionProfile = ConnectionProfile.newBuilder().build();
@@ -490,6 +518,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateConnectionProfileRequest request =
* CreateConnectionProfileRequest.newBuilder()
@@ -519,6 +549,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateConnectionProfileRequest request =
* CreateConnectionProfileRequest.newBuilder()
@@ -549,6 +581,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateConnectionProfileRequest request =
* CreateConnectionProfileRequest.newBuilder()
@@ -578,6 +612,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfile connectionProfile = ConnectionProfile.newBuilder().build();
* FieldMask updateMask = FieldMask.newBuilder().build();
@@ -610,6 +646,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateConnectionProfileRequest request =
* UpdateConnectionProfileRequest.newBuilder()
@@ -638,6 +676,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateConnectionProfileRequest request =
* UpdateConnectionProfileRequest.newBuilder()
@@ -667,6 +707,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateConnectionProfileRequest request =
* UpdateConnectionProfileRequest.newBuilder()
@@ -695,6 +737,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
@@ -721,6 +765,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]").toString();
@@ -744,6 +790,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteConnectionProfileRequest request =
* DeleteConnectionProfileRequest.newBuilder()
@@ -771,6 +819,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteConnectionProfileRequest request =
* DeleteConnectionProfileRequest.newBuilder()
@@ -798,6 +848,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteConnectionProfileRequest request =
* DeleteConnectionProfileRequest.newBuilder()
@@ -827,6 +879,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DiscoverConnectionProfileRequest request =
* DiscoverConnectionProfileRequest.newBuilder()
@@ -854,6 +908,8 @@ public final DiscoverConnectionProfileResponse discoverConnectionProfile(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DiscoverConnectionProfileRequest request =
* DiscoverConnectionProfileRequest.newBuilder()
@@ -878,6 +934,8 @@ public final DiscoverConnectionProfileResponse discoverConnectionProfile(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (Stream element : datastreamClient.listStreams(parent).iterateAll()) {
@@ -904,6 +962,8 @@ public final ListStreamsPagedResponse listStreams(LocationName parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (Stream element : datastreamClient.listStreams(parent).iterateAll()) {
@@ -927,6 +987,8 @@ public final ListStreamsPagedResponse listStreams(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamsRequest request =
* ListStreamsRequest.newBuilder()
@@ -956,6 +1018,8 @@ public final ListStreamsPagedResponse listStreams(ListStreamsRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamsRequest request =
* ListStreamsRequest.newBuilder()
@@ -985,6 +1049,8 @@ public final ListStreamsPagedResponse listStreams(ListStreamsRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamsRequest request =
* ListStreamsRequest.newBuilder()
@@ -1020,6 +1086,8 @@ public final UnaryCallable listStreamsC
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamName name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]");
* Stream response = datastreamClient.getStream(name);
@@ -1042,6 +1110,8 @@ public final Stream getStream(StreamName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]").toString();
* Stream response = datastreamClient.getStream(name);
@@ -1063,6 +1133,8 @@ public final Stream getStream(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetStreamRequest request =
* GetStreamRequest.newBuilder()
@@ -1086,6 +1158,8 @@ public final Stream getStream(GetStreamRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetStreamRequest request =
* GetStreamRequest.newBuilder()
@@ -1108,6 +1182,8 @@ public final UnaryCallable getStreamCallable() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* Stream stream = Stream.newBuilder().build();
@@ -1139,6 +1215,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* Stream stream = Stream.newBuilder().build();
@@ -1170,6 +1248,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateStreamRequest request =
* CreateStreamRequest.newBuilder()
@@ -1199,6 +1279,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateStreamRequest request =
* CreateStreamRequest.newBuilder()
@@ -1228,6 +1310,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateStreamRequest request =
* CreateStreamRequest.newBuilder()
@@ -1255,6 +1339,8 @@ public final UnaryCallable createStreamCallable(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* Stream stream = Stream.newBuilder().build();
* FieldMask updateMask = FieldMask.newBuilder().build();
@@ -1283,6 +1369,8 @@ public final OperationFuture updateStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateStreamRequest request =
* UpdateStreamRequest.newBuilder()
@@ -1311,6 +1399,8 @@ public final OperationFuture updateStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateStreamRequest request =
* UpdateStreamRequest.newBuilder()
@@ -1339,6 +1429,8 @@ public final OperationFuture updateStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateStreamRequest request =
* UpdateStreamRequest.newBuilder()
@@ -1365,6 +1457,8 @@ public final UnaryCallable updateStreamCallable(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamName name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]");
* datastreamClient.deleteStreamAsync(name).get();
@@ -1387,6 +1481,8 @@ public final OperationFuture deleteStreamAsync(StreamN
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]").toString();
* datastreamClient.deleteStreamAsync(name).get();
@@ -1408,6 +1504,8 @@ public final OperationFuture deleteStreamAsync(String
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteStreamRequest request =
* DeleteStreamRequest.newBuilder()
@@ -1433,6 +1531,8 @@ public final OperationFuture deleteStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteStreamRequest request =
* DeleteStreamRequest.newBuilder()
@@ -1458,6 +1558,8 @@ public final OperationFuture deleteStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteStreamRequest request =
* DeleteStreamRequest.newBuilder()
@@ -1481,6 +1583,8 @@ public final UnaryCallable deleteStreamCallable(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamObjectName name =
* StreamObjectName.of("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
@@ -1504,6 +1608,8 @@ public final StreamObject getStreamObject(StreamObjectName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* StreamObjectName.of("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]").toString();
@@ -1526,6 +1632,8 @@ public final StreamObject getStreamObject(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetStreamObjectRequest request =
* GetStreamObjectRequest.newBuilder()
@@ -1550,6 +1658,8 @@ public final StreamObject getStreamObject(GetStreamObjectRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetStreamObjectRequest request =
* GetStreamObjectRequest.newBuilder()
@@ -1574,6 +1684,8 @@ public final UnaryCallable getStreamObject
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LookupStreamObjectRequest request =
* LookupStreamObjectRequest.newBuilder()
@@ -1598,6 +1710,8 @@ public final StreamObject lookupStreamObject(LookupStreamObjectRequest request)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LookupStreamObjectRequest request =
* LookupStreamObjectRequest.newBuilder()
@@ -1622,6 +1736,8 @@ public final UnaryCallable lookupStream
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamName parent = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]");
* for (StreamObject element : datastreamClient.listStreamObjects(parent).iterateAll()) {
@@ -1648,6 +1764,8 @@ public final ListStreamObjectsPagedResponse listStreamObjects(StreamName parent)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]").toString();
* for (StreamObject element : datastreamClient.listStreamObjects(parent).iterateAll()) {
@@ -1672,6 +1790,8 @@ public final ListStreamObjectsPagedResponse listStreamObjects(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamObjectsRequest request =
* ListStreamObjectsRequest.newBuilder()
@@ -1699,6 +1819,8 @@ public final ListStreamObjectsPagedResponse listStreamObjects(ListStreamObjectsR
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamObjectsRequest request =
* ListStreamObjectsRequest.newBuilder()
@@ -1727,6 +1849,8 @@ public final ListStreamObjectsPagedResponse listStreamObjects(ListStreamObjectsR
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamObjectsRequest request =
* ListStreamObjectsRequest.newBuilder()
@@ -1762,6 +1886,8 @@ public final ListStreamObjectsPagedResponse listStreamObjects(ListStreamObjectsR
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamObjectName object =
* StreamObjectName.of("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
@@ -1787,6 +1913,8 @@ public final StartBackfillJobResponse startBackfillJob(StreamObjectName object)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String object =
* StreamObjectName.of("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]").toString();
@@ -1810,6 +1938,8 @@ public final StartBackfillJobResponse startBackfillJob(String object) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StartBackfillJobRequest request =
* StartBackfillJobRequest.newBuilder()
@@ -1834,6 +1964,8 @@ public final StartBackfillJobResponse startBackfillJob(StartBackfillJobRequest r
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StartBackfillJobRequest request =
* StartBackfillJobRequest.newBuilder()
@@ -1859,6 +1991,8 @@ public final StartBackfillJobResponse startBackfillJob(StartBackfillJobRequest r
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamObjectName object =
* StreamObjectName.of("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]");
@@ -1884,6 +2018,8 @@ public final StopBackfillJobResponse stopBackfillJob(StreamObjectName object) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String object =
* StreamObjectName.of("[PROJECT]", "[LOCATION]", "[STREAM]", "[OBJECT]").toString();
@@ -1906,6 +2042,8 @@ public final StopBackfillJobResponse stopBackfillJob(String object) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StopBackfillJobRequest request =
* StopBackfillJobRequest.newBuilder()
@@ -1930,6 +2068,8 @@ public final StopBackfillJobResponse stopBackfillJob(StopBackfillJobRequest requ
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StopBackfillJobRequest request =
* StopBackfillJobRequest.newBuilder()
@@ -1955,6 +2095,8 @@ public final StopBackfillJobResponse stopBackfillJob(StopBackfillJobRequest requ
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName name = LocationName.of("[PROJECT]", "[LOCATION]");
* for (String element : datastreamClient.fetchStaticIps(name).iterateAll()) {
@@ -1980,6 +2122,8 @@ public final FetchStaticIpsPagedResponse fetchStaticIps(LocationName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (String element : datastreamClient.fetchStaticIps(name).iterateAll()) {
@@ -2004,6 +2148,8 @@ public final FetchStaticIpsPagedResponse fetchStaticIps(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* FetchStaticIpsRequest request =
* FetchStaticIpsRequest.newBuilder()
@@ -2031,6 +2177,8 @@ public final FetchStaticIpsPagedResponse fetchStaticIps(FetchStaticIpsRequest re
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* FetchStaticIpsRequest request =
* FetchStaticIpsRequest.newBuilder()
@@ -2058,6 +2206,8 @@ public final FetchStaticIpsPagedResponse fetchStaticIps(FetchStaticIpsRequest re
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* FetchStaticIpsRequest request =
* FetchStaticIpsRequest.newBuilder()
@@ -2092,6 +2242,8 @@ public final FetchStaticIpsPagedResponse fetchStaticIps(FetchStaticIpsRequest re
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* PrivateConnection privateConnection = PrivateConnection.newBuilder().build();
@@ -2126,6 +2278,8 @@ public final OperationFuture createPrivate
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* PrivateConnection privateConnection = PrivateConnection.newBuilder().build();
@@ -2160,6 +2314,8 @@ public final OperationFuture createPrivate
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreatePrivateConnectionRequest request =
* CreatePrivateConnectionRequest.newBuilder()
@@ -2187,6 +2343,8 @@ public final OperationFuture createPrivate
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreatePrivateConnectionRequest request =
* CreatePrivateConnectionRequest.newBuilder()
@@ -2215,6 +2373,8 @@ public final OperationFuture createPrivate
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreatePrivateConnectionRequest request =
* CreatePrivateConnectionRequest.newBuilder()
@@ -2242,6 +2402,8 @@ public final OperationFuture createPrivate
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* PrivateConnectionName name =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
@@ -2267,6 +2429,8 @@ public final PrivateConnection getPrivateConnection(PrivateConnectionName name)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]").toString();
@@ -2290,6 +2454,8 @@ public final PrivateConnection getPrivateConnection(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetPrivateConnectionRequest request =
* GetPrivateConnectionRequest.newBuilder()
@@ -2315,6 +2481,8 @@ public final PrivateConnection getPrivateConnection(GetPrivateConnectionRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetPrivateConnectionRequest request =
* GetPrivateConnectionRequest.newBuilder()
@@ -2341,6 +2509,8 @@ public final PrivateConnection getPrivateConnection(GetPrivateConnectionRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (PrivateConnection element :
@@ -2369,6 +2539,8 @@ public final ListPrivateConnectionsPagedResponse listPrivateConnections(Location
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (PrivateConnection element :
@@ -2395,6 +2567,8 @@ public final ListPrivateConnectionsPagedResponse listPrivateConnections(String p
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListPrivateConnectionsRequest request =
* ListPrivateConnectionsRequest.newBuilder()
@@ -2426,6 +2600,8 @@ public final ListPrivateConnectionsPagedResponse listPrivateConnections(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListPrivateConnectionsRequest request =
* ListPrivateConnectionsRequest.newBuilder()
@@ -2456,6 +2632,8 @@ public final ListPrivateConnectionsPagedResponse listPrivateConnections(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListPrivateConnectionsRequest request =
* ListPrivateConnectionsRequest.newBuilder()
@@ -2493,6 +2671,8 @@ public final ListPrivateConnectionsPagedResponse listPrivateConnections(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* PrivateConnectionName name =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
@@ -2519,6 +2699,8 @@ public final OperationFuture deletePrivateConnectionAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]").toString();
@@ -2542,6 +2724,8 @@ public final OperationFuture deletePrivateConnectionAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeletePrivateConnectionRequest request =
* DeletePrivateConnectionRequest.newBuilder()
@@ -2570,6 +2754,8 @@ public final OperationFuture deletePrivateConnectionAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeletePrivateConnectionRequest request =
* DeletePrivateConnectionRequest.newBuilder()
@@ -2598,6 +2784,8 @@ public final OperationFuture deletePrivateConnectionAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeletePrivateConnectionRequest request =
* DeletePrivateConnectionRequest.newBuilder()
@@ -2627,6 +2815,8 @@ public final OperationFuture deletePrivateConnectionAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* PrivateConnectionName parent =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
@@ -2660,6 +2850,8 @@ public final OperationFuture createRouteAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]").toString();
@@ -2693,6 +2885,8 @@ public final OperationFuture createRouteAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateRouteRequest request =
* CreateRouteRequest.newBuilder()
@@ -2723,6 +2917,8 @@ public final OperationFuture createRouteAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateRouteRequest request =
* CreateRouteRequest.newBuilder()
@@ -2753,6 +2949,8 @@ public final OperationFuture createRouteAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateRouteRequest request =
* CreateRouteRequest.newBuilder()
@@ -2780,6 +2978,8 @@ public final UnaryCallable createRouteCallable()
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
* Route response = datastreamClient.getRoute(name);
@@ -2802,6 +3002,8 @@ public final Route getRoute(RouteName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]").toString();
@@ -2824,6 +3026,8 @@ public final Route getRoute(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetRouteRequest request =
* GetRouteRequest.newBuilder()
@@ -2849,6 +3053,8 @@ public final Route getRoute(GetRouteRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetRouteRequest request =
* GetRouteRequest.newBuilder()
@@ -2874,6 +3080,8 @@ public final UnaryCallable getRouteCallable() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* PrivateConnectionName parent =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]");
@@ -2900,6 +3108,8 @@ public final ListRoutesPagedResponse listRoutes(PrivateConnectionName parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent =
* PrivateConnectionName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]").toString();
@@ -2925,6 +3135,8 @@ public final ListRoutesPagedResponse listRoutes(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListRoutesRequest request =
* ListRoutesRequest.newBuilder()
@@ -2957,6 +3169,8 @@ public final ListRoutesPagedResponse listRoutes(ListRoutesRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListRoutesRequest request =
* ListRoutesRequest.newBuilder()
@@ -2988,6 +3202,8 @@ public final UnaryCallable listRoute
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListRoutesRequest request =
* ListRoutesRequest.newBuilder()
@@ -3025,6 +3241,8 @@ public final UnaryCallable listRoutesCall
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* RouteName name = RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]");
* datastreamClient.deleteRouteAsync(name).get();
@@ -3047,6 +3265,8 @@ public final OperationFuture deleteRouteAsync(RouteNam
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* RouteName.of("[PROJECT]", "[LOCATION]", "[PRIVATE_CONNECTION]", "[ROUTE]").toString();
@@ -3069,6 +3289,8 @@ public final OperationFuture deleteRouteAsync(String n
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteRouteRequest request =
* DeleteRouteRequest.newBuilder()
@@ -3096,6 +3318,8 @@ public final OperationFuture deleteRouteAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteRouteRequest request =
* DeleteRouteRequest.newBuilder()
@@ -3123,6 +3347,8 @@ public final OperationFuture deleteRouteAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteRouteRequest request =
* DeleteRouteRequest.newBuilder()
@@ -3148,6 +3374,8 @@ public final UnaryCallable deleteRouteCallable()
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListLocationsRequest request =
* ListLocationsRequest.newBuilder()
@@ -3176,6 +3404,8 @@ public final ListLocationsPagedResponse listLocations(ListLocationsRequest reque
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListLocationsRequest request =
* ListLocationsRequest.newBuilder()
@@ -3205,6 +3435,8 @@ public final ListLocationsPagedResponse listLocations(ListLocationsRequest reque
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListLocationsRequest request =
* ListLocationsRequest.newBuilder()
@@ -3239,6 +3471,8 @@ public final UnaryCallable listLoca
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
* Location response = datastreamClient.getLocation(request);
@@ -3259,6 +3493,8 @@ public final Location getLocation(GetLocationRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetLocationRequest request = GetLocationRequest.newBuilder().setName("name3373707").build();
* ApiFuture future = datastreamClient.getLocationCallable().futureCall(request);
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/DatastreamSettings.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/DatastreamSettings.java
index 67c71b7a..88c71dab 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/DatastreamSettings.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/DatastreamSettings.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -65,6 +65,8 @@
* For example, to set the total timeout of getConnectionProfile to 30 seconds:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatastreamSettings.Builder datastreamSettingsBuilder = DatastreamSettings.newBuilder();
* datastreamSettingsBuilder
* .getConnectionProfileSettings()
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/package-info.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/package-info.java
index 4c97aacd..1b40c70d 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/package-info.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -26,6 +26,8 @@
* Sample for DatastreamClient:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStub.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStub.java
index d2daac8c..8104da66 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStub.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStub.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStubSettings.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStubSettings.java
index 13093e1f..ca567ea6 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStubSettings.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStubSettings.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -123,6 +123,8 @@
* For example, to set the total timeout of getConnectionProfile to 30 seconds:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatastreamStubSettings.Builder datastreamSettingsBuilder = DatastreamStubSettings.newBuilder();
* datastreamSettingsBuilder
* .getConnectionProfileSettings()
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamCallableFactory.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamCallableFactory.java
index 0c0e3670..92d16a24 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamCallableFactory.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamCallableFactory.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamStub.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamStub.java
index 222fa5c3..35aae842 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamStub.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/GrpcDatastreamStub.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java
index e5f09a0f..d8566180 100644
--- a/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java
+++ b/google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1alpha1/DatastreamClient.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2021 Google LLC
+ * Copyright 2022 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -47,6 +47,8 @@
* calls that map to API methods. Sample code to get started:
*
* {@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
@@ -83,6 +85,8 @@
* To customize credentials:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatastreamSettings datastreamSettings =
* DatastreamSettings.newBuilder()
* .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
@@ -93,6 +97,8 @@
* To customize the endpoint:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* DatastreamSettings datastreamSettings =
* DatastreamSettings.newBuilder().setEndpoint(myEndpoint).build();
* DatastreamClient datastreamClient = DatastreamClient.create(datastreamSettings);
@@ -170,6 +176,8 @@ public final OperationsClient getOperationsClient() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (ConnectionProfile element :
@@ -197,6 +205,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(Location
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (ConnectionProfile element :
@@ -222,6 +232,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(String p
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListConnectionProfilesRequest request =
* ListConnectionProfilesRequest.newBuilder()
@@ -253,6 +265,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListConnectionProfilesRequest request =
* ListConnectionProfilesRequest.newBuilder()
@@ -283,6 +297,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListConnectionProfilesRequest request =
* ListConnectionProfilesRequest.newBuilder()
@@ -320,6 +336,8 @@ public final ListConnectionProfilesPagedResponse listConnectionProfiles(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
@@ -345,6 +363,8 @@ public final ConnectionProfile getConnectionProfile(ConnectionProfileName name)
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]").toString();
@@ -368,6 +388,8 @@ public final ConnectionProfile getConnectionProfile(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetConnectionProfileRequest request =
* GetConnectionProfileRequest.newBuilder()
@@ -393,6 +415,8 @@ public final ConnectionProfile getConnectionProfile(GetConnectionProfileRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetConnectionProfileRequest request =
* GetConnectionProfileRequest.newBuilder()
@@ -419,6 +443,8 @@ public final ConnectionProfile getConnectionProfile(GetConnectionProfileRequest
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* ConnectionProfile connectionProfile = ConnectionProfile.newBuilder().build();
@@ -453,6 +479,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* ConnectionProfile connectionProfile = ConnectionProfile.newBuilder().build();
@@ -487,6 +515,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateConnectionProfileRequest request =
* CreateConnectionProfileRequest.newBuilder()
@@ -514,6 +544,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateConnectionProfileRequest request =
* CreateConnectionProfileRequest.newBuilder()
@@ -542,6 +574,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateConnectionProfileRequest request =
* CreateConnectionProfileRequest.newBuilder()
@@ -569,6 +603,8 @@ public final OperationFuture createConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfile connectionProfile = ConnectionProfile.newBuilder().build();
* FieldMask updateMask = FieldMask.newBuilder().build();
@@ -601,6 +637,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateConnectionProfileRequest request =
* UpdateConnectionProfileRequest.newBuilder()
@@ -627,6 +665,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateConnectionProfileRequest request =
* UpdateConnectionProfileRequest.newBuilder()
@@ -654,6 +694,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateConnectionProfileRequest request =
* UpdateConnectionProfileRequest.newBuilder()
@@ -680,6 +722,8 @@ public final OperationFuture updateConnect
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ConnectionProfileName name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");
@@ -706,6 +750,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name =
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]").toString();
@@ -729,6 +775,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteConnectionProfileRequest request =
* DeleteConnectionProfileRequest.newBuilder()
@@ -756,6 +804,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteConnectionProfileRequest request =
* DeleteConnectionProfileRequest.newBuilder()
@@ -783,6 +833,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DeleteConnectionProfileRequest request =
* DeleteConnectionProfileRequest.newBuilder()
@@ -812,6 +864,8 @@ public final OperationFuture deleteConnectionProfileAs
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DiscoverConnectionProfileRequest request =
* DiscoverConnectionProfileRequest.newBuilder()
@@ -839,6 +893,8 @@ public final DiscoverConnectionProfileResponse discoverConnectionProfile(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* DiscoverConnectionProfileRequest request =
* DiscoverConnectionProfileRequest.newBuilder()
@@ -863,6 +919,8 @@ public final DiscoverConnectionProfileResponse discoverConnectionProfile(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* for (Stream element : datastreamClient.listStreams(parent).iterateAll()) {
@@ -889,6 +947,8 @@ public final ListStreamsPagedResponse listStreams(LocationName parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* for (Stream element : datastreamClient.listStreams(parent).iterateAll()) {
@@ -912,6 +972,8 @@ public final ListStreamsPagedResponse listStreams(String parent) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamsRequest request =
* ListStreamsRequest.newBuilder()
@@ -941,6 +1003,8 @@ public final ListStreamsPagedResponse listStreams(ListStreamsRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamsRequest request =
* ListStreamsRequest.newBuilder()
@@ -970,6 +1034,8 @@ public final ListStreamsPagedResponse listStreams(ListStreamsRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* ListStreamsRequest request =
* ListStreamsRequest.newBuilder()
@@ -1005,6 +1071,8 @@ public final UnaryCallable listStreamsC
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamName name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]");
* Stream response = datastreamClient.getStream(name);
@@ -1027,6 +1095,8 @@ public final Stream getStream(StreamName name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]").toString();
* Stream response = datastreamClient.getStream(name);
@@ -1048,6 +1118,8 @@ public final Stream getStream(String name) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetStreamRequest request =
* GetStreamRequest.newBuilder()
@@ -1071,6 +1143,8 @@ public final Stream getStream(GetStreamRequest request) {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* GetStreamRequest request =
* GetStreamRequest.newBuilder()
@@ -1093,6 +1167,8 @@ public final UnaryCallable getStreamCallable() {
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
* Stream stream = Stream.newBuilder().build();
@@ -1124,6 +1200,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
* Stream stream = Stream.newBuilder().build();
@@ -1155,6 +1233,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateStreamRequest request =
* CreateStreamRequest.newBuilder()
@@ -1184,6 +1264,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateStreamRequest request =
* CreateStreamRequest.newBuilder()
@@ -1213,6 +1295,8 @@ public final OperationFuture createStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* CreateStreamRequest request =
* CreateStreamRequest.newBuilder()
@@ -1240,6 +1324,8 @@ public final UnaryCallable createStreamCallable(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* Stream stream = Stream.newBuilder().build();
* FieldMask updateMask = FieldMask.newBuilder().build();
@@ -1268,6 +1354,8 @@ public final OperationFuture updateStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateStreamRequest request =
* UpdateStreamRequest.newBuilder()
@@ -1296,6 +1384,8 @@ public final OperationFuture updateStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateStreamRequest request =
* UpdateStreamRequest.newBuilder()
@@ -1324,6 +1414,8 @@ public final OperationFuture updateStreamAsync(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* UpdateStreamRequest request =
* UpdateStreamRequest.newBuilder()
@@ -1350,6 +1442,8 @@ public final UnaryCallable updateStreamCallable(
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* StreamName name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]");
* datastreamClient.deleteStreamAsync(name).get();
@@ -1372,6 +1466,8 @@ public final OperationFuture deleteStreamAsync(StreamN
* Sample code:
*
*
{@code
+ * // This snippet has been automatically generated for illustrative purposes only.
+ * // It may require modifications to work in your environment.
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
* String name = StreamName.of("[PROJECT]", "[LOCATION]", "[STREAM]").toString();
* datastreamClient.deleteStreamAsync(name).get();
@@ -1393,6 +1489,8 @@ public final OperationFuture deleteStreamAsync(String
*