You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/04/25 22:20:06 UTC
[3/3] beam git commit: [BEAM-1871] Move Bigquery/Pubsub options to
sdks/java/io/google-cloud-platform
[BEAM-1871] Move Bigquery/Pubsub options to sdks/java/io/google-cloud-platform
This closes #2678
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e3c17a3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2e3c17a3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2e3c17a3
Branch: refs/heads/master
Commit: 2e3c17a3560ac32da8fc5c944c836107b2b76312
Parents: 652a919 6f9f7bc
Author: Luke Cwik <lc...@google.com>
Authored: Tue Apr 25 15:19:56 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Tue Apr 25 15:19:56 2017 -0700
----------------------------------------------------------------------
examples/java/pom.xml | 22 ++
.../beam/examples/common/ExampleUtils.java | 60 ++++-
.../examples/cookbook/BigQueryTornadoesIT.java | 4 +-
pom.xml | 7 +
.../options/DataflowPipelineOptions.java | 4 +-
sdks/java/extensions/gcp-core/pom.xml | 29 +--
.../beam/sdk/options/BigQueryOptions.java | 32 ---
.../options/GcpPipelineOptionsRegistrar.java | 2 -
.../apache/beam/sdk/options/PubsubOptions.java | 36 ---
.../beam/sdk/testing/BigqueryMatcher.java | 256 ------------------
.../apache/beam/sdk/testing/package-info.java | 21 --
.../org/apache/beam/sdk/util/Transport.java | 36 ---
.../org/apache/beam/GcpCoreApiSurfaceTest.java | 2 -
.../sdk/options/GoogleApiDebugOptionsTest.java | 7 +-
.../beam/sdk/testing/BigqueryMatcherTest.java | 176 -------------
sdks/java/extensions/protobuf/pom.xml | 19 +-
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 1 -
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 1 -
.../sdk/io/gcp/bigquery/BigQueryOptions.java | 39 +++
.../io/gcp/bigquery/BigQueryQuerySource.java | 1 -
.../sdk/io/gcp/bigquery/BigQueryServices.java | 1 -
.../io/gcp/bigquery/BigQueryServicesImpl.java | 41 ++-
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 1 -
.../io/gcp/bigquery/BigQueryTableSource.java | 1 -
.../beam/sdk/io/gcp/bigquery/CreateTables.java | 1 -
.../beam/sdk/io/gcp/bigquery/PrepareWrite.java | 1 -
.../sdk/io/gcp/bigquery/StreamingWriteFn.java | 1 -
.../beam/sdk/io/gcp/bigquery/WriteRename.java | 1 -
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 1 -
.../common/GcpIoPipelineOptionsRegistrar.java | 39 +++
.../beam/sdk/io/gcp/common/package-info.java | 20 ++
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 1 -
.../sdk/io/gcp/pubsub/PubsubGrpcClient.java | 1 -
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 1 -
.../sdk/io/gcp/pubsub/PubsubJsonClient.java | 1 -
.../beam/sdk/io/gcp/pubsub/PubsubOptions.java | 44 ++++
.../sdk/io/gcp/pubsub/PubsubTestClient.java | 1 -
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 1 -
.../io/gcp/pubsub/PubsubUnboundedSource.java | 1 -
.../beam/sdk/io/gcp/testing/package-info.java | 21 ++
.../beam/sdk/io/gcp/GcpApiSurfaceTest.java | 2 +
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 1 -
.../io/gcp/bigquery/FakeBigQueryServices.java | 1 -
.../sdk/io/gcp/testing/BigqueryMatcher.java | 257 +++++++++++++++++++
.../sdk/io/gcp/testing/BigqueryMatcherTest.java | 177 +++++++++++++
45 files changed, 737 insertions(+), 636 deletions(-)
----------------------------------------------------------------------