[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 <[email protected]> Authored: Tue Apr 25 15:19:56 2017 -0700 Committer: Luke Cwik <[email protected]> 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(-) ----------------------------------------------------------------------
