diff --git a/CHANGELOG.md b/CHANGELOG.md
index 6dfaa7e4..9d617a25 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,12 @@
# Changelog
+## [0.6.1](https://github.com/googleapis/java-dataflow/compare/v0.6.0...v0.6.1) (2022-06-23)
+
+
+### Dependencies
+
+* update dependency com.google.cloud:google-cloud-shared-dependencies to v2.13.0 ([#181](https://github.com/googleapis/java-dataflow/issues/181)) ([bc949a7](https://github.com/googleapis/java-dataflow/commit/bc949a7c7d7232506466fc41c5acafd5592ff223))
+
## [0.6.0](https://github.com/googleapis/java-dataflow/compare/v0.5.1...v0.6.0) (2022-05-19)
diff --git a/README.md b/README.md
index 4fa4ffcf..4b63515f 100644
--- a/README.md
+++ b/README.md
@@ -22,7 +22,7 @@ If you are using Maven, add this to your pom.xml file:
com.google.cloud
google-cloud-dataflow
- 0.5.1
+ 0.6.0
```
@@ -30,13 +30,13 @@ If you are using Maven, add this to your pom.xml file:
If you are using Gradle without BOM, add this to your dependencies
```Groovy
-implementation 'com.google.cloud:google-cloud-dataflow:0.5.1'
+implementation 'com.google.cloud:google-cloud-dataflow:0.6.0'
```
If you are using SBT, add this to your dependencies
```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-dataflow" % "0.5.1"
+libraryDependencies += "com.google.cloud" % "google-cloud-dataflow" % "0.6.0"
```
## Authentication
diff --git a/google-cloud-dataflow-bom/pom.xml b/google-cloud-dataflow-bom/pom.xml
index e8998c2d..53868b42 100644
--- a/google-cloud-dataflow-bom/pom.xml
+++ b/google-cloud-dataflow-bom/pom.xml
@@ -3,12 +3,12 @@
4.0.0
com.google.cloud
google-cloud-dataflow-bom
- 0.6.0
+ 0.6.1
pom
com.google.cloud
google-cloud-shared-config
- 1.4.0
+ 1.5.0
Google Dataflow BOM
@@ -56,17 +56,17 @@
com.google.cloud
google-cloud-dataflow
- 0.6.0
+ 0.6.1
com.google.api.grpc
grpc-google-cloud-dataflow-v1beta3
- 0.6.0
+ 0.6.1
com.google.api.grpc
proto-google-cloud-dataflow-v1beta3
- 0.6.0
+ 0.6.1
diff --git a/google-cloud-dataflow/pom.xml b/google-cloud-dataflow/pom.xml
index e8f9c744..5da6d473 100644
--- a/google-cloud-dataflow/pom.xml
+++ b/google-cloud-dataflow/pom.xml
@@ -3,7 +3,7 @@
4.0.0
com.google.cloud
google-cloud-dataflow
- 0.6.0
+ 0.6.1
jar
Google Dataflow
https://github.com/googleapis/java-dataflow
@@ -11,7 +11,7 @@
com.google.cloud
google-cloud-dataflow-parent
- 0.6.0
+ 0.6.1
google-cloud-dataflow
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/FlexTemplatesServiceClient.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/FlexTemplatesServiceClient.java
index 31310a66..1ca69b86 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/FlexTemplatesServiceClient.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/FlexTemplatesServiceClient.java
@@ -125,7 +125,6 @@ public static final FlexTemplatesServiceClient create(FlexTemplatesServiceSettin
* Constructs an instance of FlexTemplatesServiceClient, using the given stub for making calls.
* This is for advanced usage - prefer using create(FlexTemplatesServiceSettings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final FlexTemplatesServiceClient create(FlexTemplatesServiceStub stub) {
return new FlexTemplatesServiceClient(stub);
}
@@ -140,7 +139,6 @@ protected FlexTemplatesServiceClient(FlexTemplatesServiceSettings settings) thro
this.stub = ((FlexTemplatesServiceStubSettings) settings.getStubSettings()).createStub();
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected FlexTemplatesServiceClient(FlexTemplatesServiceStub stub) {
this.settings = null;
this.stub = stub;
@@ -150,7 +148,6 @@ public final FlexTemplatesServiceSettings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public FlexTemplatesServiceStub getStub() {
return stub;
}
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/JobsV1Beta3Client.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/JobsV1Beta3Client.java
index 1f881b49..adfafef0 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/JobsV1Beta3Client.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/JobsV1Beta3Client.java
@@ -130,7 +130,6 @@ public static final JobsV1Beta3Client create(JobsV1Beta3Settings settings) throw
* Constructs an instance of JobsV1Beta3Client, using the given stub for making calls. This is for
* advanced usage - prefer using create(JobsV1Beta3Settings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final JobsV1Beta3Client create(JobsV1Beta3Stub stub) {
return new JobsV1Beta3Client(stub);
}
@@ -145,7 +144,6 @@ protected JobsV1Beta3Client(JobsV1Beta3Settings settings) throws IOException {
this.stub = ((JobsV1Beta3StubSettings) settings.getStubSettings()).createStub();
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected JobsV1Beta3Client(JobsV1Beta3Stub stub) {
this.settings = null;
this.stub = stub;
@@ -155,7 +153,6 @@ public final JobsV1Beta3Settings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public JobsV1Beta3Stub getStub() {
return stub;
}
@@ -456,7 +453,7 @@ public final UnaryCallable listJobsPaged
* .build();
* while (true) {
* ListJobsResponse response = jobsV1Beta3Client.listJobsCallable().call(request);
- * for (Job element : response.getResponsesList()) {
+ * for (Job element : response.getJobsList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
@@ -556,7 +553,7 @@ public final AggregatedListJobsPagedResponse aggregatedListJobs(ListJobsRequest
* .build();
* while (true) {
* ListJobsResponse response = jobsV1Beta3Client.aggregatedListJobsCallable().call(request);
- * for (Job element : response.getResponsesList()) {
+ * for (Job element : response.getJobsList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MessagesV1Beta3Client.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MessagesV1Beta3Client.java
index 71f35f66..4ef9d1de 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MessagesV1Beta3Client.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MessagesV1Beta3Client.java
@@ -139,7 +139,6 @@ public static final MessagesV1Beta3Client create(MessagesV1Beta3Settings setting
* Constructs an instance of MessagesV1Beta3Client, using the given stub for making calls. This is
* for advanced usage - prefer using create(MessagesV1Beta3Settings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final MessagesV1Beta3Client create(MessagesV1Beta3Stub stub) {
return new MessagesV1Beta3Client(stub);
}
@@ -154,7 +153,6 @@ protected MessagesV1Beta3Client(MessagesV1Beta3Settings settings) throws IOExcep
this.stub = ((MessagesV1Beta3StubSettings) settings.getStubSettings()).createStub();
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected MessagesV1Beta3Client(MessagesV1Beta3Stub stub) {
this.settings = null;
this.stub = stub;
@@ -164,7 +162,6 @@ public final MessagesV1Beta3Settings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public MessagesV1Beta3Stub getStub() {
return stub;
}
@@ -280,7 +277,7 @@ public final ListJobMessagesPagedResponse listJobMessages(ListJobMessagesRequest
* while (true) {
* ListJobMessagesResponse response =
* messagesV1Beta3Client.listJobMessagesCallable().call(request);
- * for (JobMessage element : response.getResponsesList()) {
+ * for (JobMessage element : response.getJobMessagesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MetricsV1Beta3Client.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MetricsV1Beta3Client.java
index af98a8c5..6fa09498 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MetricsV1Beta3Client.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/MetricsV1Beta3Client.java
@@ -129,7 +129,6 @@ public static final MetricsV1Beta3Client create(MetricsV1Beta3Settings settings)
* Constructs an instance of MetricsV1Beta3Client, using the given stub for making calls. This is
* for advanced usage - prefer using create(MetricsV1Beta3Settings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final MetricsV1Beta3Client create(MetricsV1Beta3Stub stub) {
return new MetricsV1Beta3Client(stub);
}
@@ -144,7 +143,6 @@ protected MetricsV1Beta3Client(MetricsV1Beta3Settings settings) throws IOExcepti
this.stub = ((MetricsV1Beta3StubSettings) settings.getStubSettings()).createStub();
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected MetricsV1Beta3Client(MetricsV1Beta3Stub stub) {
this.settings = null;
this.stub = stub;
@@ -154,7 +152,6 @@ public final MetricsV1Beta3Settings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public MetricsV1Beta3Stub getStub() {
return stub;
}
@@ -317,7 +314,7 @@ public final GetJobExecutionDetailsPagedResponse getJobExecutionDetails(
* while (true) {
* JobExecutionDetails response =
* metricsV1Beta3Client.getJobExecutionDetailsCallable().call(request);
- * for (StageSummary element : response.getResponsesList()) {
+ * for (StageSummary element : response.getStagesList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
@@ -436,7 +433,7 @@ public final GetStageExecutionDetailsPagedResponse getStageExecutionDetails(
* while (true) {
* StageExecutionDetails response =
* metricsV1Beta3Client.getStageExecutionDetailsCallable().call(request);
- * for (WorkerDetails element : response.getResponsesList()) {
+ * for (WorkerDetails element : response.getWorkersList()) {
* // doThingsWith(element);
* }
* String nextPageToken = response.getNextPageToken();
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/SnapshotsV1Beta3Client.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/SnapshotsV1Beta3Client.java
index 889288d8..e9ce4586 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/SnapshotsV1Beta3Client.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/SnapshotsV1Beta3Client.java
@@ -123,7 +123,6 @@ public static final SnapshotsV1Beta3Client create(SnapshotsV1Beta3Settings setti
* Constructs an instance of SnapshotsV1Beta3Client, using the given stub for making calls. This
* is for advanced usage - prefer using create(SnapshotsV1Beta3Settings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final SnapshotsV1Beta3Client create(SnapshotsV1Beta3Stub stub) {
return new SnapshotsV1Beta3Client(stub);
}
@@ -138,7 +137,6 @@ protected SnapshotsV1Beta3Client(SnapshotsV1Beta3Settings settings) throws IOExc
this.stub = ((SnapshotsV1Beta3StubSettings) settings.getStubSettings()).createStub();
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected SnapshotsV1Beta3Client(SnapshotsV1Beta3Stub stub) {
this.settings = null;
this.stub = stub;
@@ -148,7 +146,6 @@ public final SnapshotsV1Beta3Settings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public SnapshotsV1Beta3Stub getStub() {
return stub;
}
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/TemplatesServiceClient.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/TemplatesServiceClient.java
index 3c761a26..6e0efab8 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/TemplatesServiceClient.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/TemplatesServiceClient.java
@@ -125,7 +125,6 @@ public static final TemplatesServiceClient create(TemplatesServiceSettings setti
* Constructs an instance of TemplatesServiceClient, using the given stub for making calls. This
* is for advanced usage - prefer using create(TemplatesServiceSettings).
*/
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final TemplatesServiceClient create(TemplatesServiceStub stub) {
return new TemplatesServiceClient(stub);
}
@@ -140,7 +139,6 @@ protected TemplatesServiceClient(TemplatesServiceSettings settings) throws IOExc
this.stub = ((TemplatesServiceStubSettings) settings.getStubSettings()).createStub();
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected TemplatesServiceClient(TemplatesServiceStub stub) {
this.settings = null;
this.stub = stub;
@@ -150,7 +148,6 @@ public final TemplatesServiceSettings getSettings() {
return settings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public TemplatesServiceStub getStub() {
return stub;
}
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/FlexTemplatesServiceStubSettings.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/FlexTemplatesServiceStubSettings.java
index 0b2e8fa0..3981151c 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/FlexTemplatesServiceStubSettings.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/FlexTemplatesServiceStubSettings.java
@@ -98,7 +98,6 @@ public class FlexTemplatesServiceStubSettings
return launchFlexTemplateSettings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public FlexTemplatesServiceStub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/JobsV1Beta3StubSettings.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/JobsV1Beta3StubSettings.java
index f0eb3251..5f7502b6 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/JobsV1Beta3StubSettings.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/JobsV1Beta3StubSettings.java
@@ -262,7 +262,6 @@ public UnaryCallSettings snapshotJobSettings() {
return snapshotJobSettings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public JobsV1Beta3Stub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MessagesV1Beta3StubSettings.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MessagesV1Beta3StubSettings.java
index 014d9b0f..e90aeedc 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MessagesV1Beta3StubSettings.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MessagesV1Beta3StubSettings.java
@@ -165,7 +165,6 @@ public ApiFuture getFuturePagedResponse(
return listJobMessagesSettings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public MessagesV1Beta3Stub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MetricsV1Beta3StubSettings.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MetricsV1Beta3StubSettings.java
index 6330bc68..14318c8c 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MetricsV1Beta3StubSettings.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/MetricsV1Beta3StubSettings.java
@@ -265,7 +265,6 @@ public UnaryCallSettings getJobMetricsSettings
return getStageExecutionDetailsSettings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public MetricsV1Beta3Stub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/SnapshotsV1Beta3StubSettings.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/SnapshotsV1Beta3StubSettings.java
index d359f566..94cf39fb 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/SnapshotsV1Beta3StubSettings.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/SnapshotsV1Beta3StubSettings.java
@@ -113,7 +113,6 @@ public UnaryCallSettings listSnapsh
return listSnapshotsSettings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public SnapshotsV1Beta3Stub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
diff --git a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/TemplatesServiceStubSettings.java b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/TemplatesServiceStubSettings.java
index 5beac426..85bfc341 100644
--- a/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/TemplatesServiceStubSettings.java
+++ b/google-cloud-dataflow/src/main/java/com/google/dataflow/v1beta3/stub/TemplatesServiceStubSettings.java
@@ -112,7 +112,6 @@ public UnaryCallSettings getTemplateSet
return getTemplateSettings;
}
- @BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public TemplatesServiceStub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
diff --git a/grpc-google-cloud-dataflow-v1beta3/pom.xml b/grpc-google-cloud-dataflow-v1beta3/pom.xml
index a68f3881..36c0f8d0 100644
--- a/grpc-google-cloud-dataflow-v1beta3/pom.xml
+++ b/grpc-google-cloud-dataflow-v1beta3/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
grpc-google-cloud-dataflow-v1beta3
- 0.6.0
+ 0.6.1
grpc-google-cloud-dataflow-v1beta3
GRPC library for google-cloud-dataflow
com.google.cloud
google-cloud-dataflow-parent
- 0.6.0
+ 0.6.1
diff --git a/pom.xml b/pom.xml
index 2dd2378b..086d4a32 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
com.google.cloud
google-cloud-dataflow-parent
pom
- 0.6.0
+ 0.6.1
Google Dataflow Parent
https://github.com/googleapis/java-dataflow
@@ -14,7 +14,7 @@
com.google.cloud
google-cloud-shared-config
- 1.4.0
+ 1.5.0
@@ -69,23 +69,23 @@
com.google.cloud
google-cloud-dataflow
- 0.6.0
+ 0.6.1
com.google.api.grpc
grpc-google-cloud-dataflow-v1beta3
- 0.6.0
+ 0.6.1
com.google.api.grpc
proto-google-cloud-dataflow-v1beta3
- 0.6.0
+ 0.6.1
com.google.cloud
google-cloud-shared-dependencies
- 2.12.0
+ 2.13.0
pom
import
diff --git a/proto-google-cloud-dataflow-v1beta3/pom.xml b/proto-google-cloud-dataflow-v1beta3/pom.xml
index 04e8f903..482dc431 100644
--- a/proto-google-cloud-dataflow-v1beta3/pom.xml
+++ b/proto-google-cloud-dataflow-v1beta3/pom.xml
@@ -4,13 +4,13 @@
4.0.0
com.google.api.grpc
proto-google-cloud-dataflow-v1beta3
- 0.6.0
+ 0.6.1
proto-google-cloud-dataflow-v1beta3
Proto library for google-cloud-dataflow
com.google.cloud
google-cloud-dataflow-parent
- 0.6.0
+ 0.6.1
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index aab4854f..2e90613a 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -29,7 +29,7 @@
com.google.cloud
google-cloud-dataflow
- 0.5.1
+ 0.6.0
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index 63cde645..2acabb05 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -28,7 +28,7 @@
com.google.cloud
google-cloud-dataflow
- 0.5.1
+ 0.6.0
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index 0651aa19..cf1713a2 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -28,7 +28,7 @@
com.google.cloud
google-cloud-dataflow
- 0.5.1
+ 0.6.0
diff --git a/versions.txt b/versions.txt
index a6d3f64f..9b9fd1e9 100644
--- a/versions.txt
+++ b/versions.txt
@@ -1,6 +1,6 @@
# Format:
# module:released-version:current-version
-google-cloud-dataflow:0.6.0:0.6.0
-grpc-google-cloud-dataflow-v1beta3:0.6.0:0.6.0
-proto-google-cloud-dataflow-v1beta3:0.6.0:0.6.0
+google-cloud-dataflow:0.6.1:0.6.1
+grpc-google-cloud-dataflow-v1beta3:0.6.1:0.6.1
+proto-google-cloud-dataflow-v1beta3:0.6.1:0.6.1