[BEAM-1871] Move several options/auth classes around in gcp-core This closes #1871
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/730b14e1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/730b14e1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/730b14e1 Branch: refs/heads/master Commit: 730b14e11e4479559fb068b3a661b2c90f4185e3 Parents: 0c740f4 0aed801 Author: Luke Cwik <[email protected]> Authored: Thu Apr 27 10:51:19 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Thu Apr 27 10:51:19 2017 -0700 ---------------------------------------------------------------------- .../common/ExampleBigQueryTableOptions.java | 2 +- ...xamplePubsubTopicAndSubscriptionOptions.java | 2 +- .../common/ExamplePubsubTopicOptions.java | 2 +- .../beam/examples/common/ExampleUtils.java | 2 +- .../apache/beam/examples/complete/TfIdf.java | 2 +- .../complete/game/utils/WriteToBigQuery.java | 2 +- .../examples/MinimalWordCountJava8Test.java | 2 +- pom.xml | 7 + runners/google-cloud-dataflow-java/pom.xml | 7 + .../options/DataflowPipelineOptions.java | 4 +- .../dataflow/util/DataflowTransport.java | 2 +- .../BatchStatefulParDoOverridesTest.java | 2 +- .../runners/dataflow/DataflowMetricsTest.java | 2 +- .../dataflow/DataflowPipelineJobTest.java | 2 +- .../DataflowPipelineTranslatorTest.java | 2 +- .../runners/dataflow/DataflowRunnerTest.java | 4 +- .../testing/TestDataflowRunnerTest.java | 2 +- .../dataflow/util/MonitoringUtilTest.java | 2 +- .../runners/dataflow/util/PackageUtilTest.java | 2 +- .../extensions/gcp/auth/CredentialFactory.java | 29 +++ .../gcp/auth/GcpCredentialFactory.java | 67 ++++++ .../gcp/auth/NoopCredentialFactory.java | 68 ++++++ .../gcp/auth/NullCredentialInitializer.java | 62 +++++ .../sdk/extensions/gcp/auth/package-info.java | 22 ++ .../options/CloudResourceManagerOptions.java | 46 ++++ .../sdk/extensions/gcp/options/GcpOptions.java | 231 +++++++++++++++++++ .../options/GcpPipelineOptionsRegistrar.java | 39 ++++ .../sdk/extensions/gcp/options/GcsOptions.java | 160 +++++++++++++ .../gcp/options/GoogleApiDebugOptions.java | 89 +++++++ .../extensions/gcp/options/package-info.java | 22 ++ .../options/CloudResourceManagerOptions.java | 40 ---- .../org/apache/beam/sdk/options/GcpOptions.java | 227 ------------------ .../options/GcpPipelineOptionsRegistrar.java | 37 --- .../org/apache/beam/sdk/options/GcsOptions.java | 56 +---- .../beam/sdk/options/GoogleApiDebugOptions.java | 87 ------- .../apache/beam/sdk/util/CredentialFactory.java | 29 --- .../org/apache/beam/sdk/util/DefaultBucket.java | 4 +- .../beam/sdk/util/GcpCredentialFactory.java | 67 ------ .../apache/beam/sdk/util/GcpProjectUtil.java | 2 +- .../beam/sdk/util/GcsIOChannelFactory.java | 2 +- .../apache/beam/sdk/util/GcsPathValidator.java | 2 +- .../java/org/apache/beam/sdk/util/GcsUtil.java | 3 +- .../beam/sdk/util/NoopCredentialFactory.java | 68 ------ .../sdk/util/NullCredentialInitializer.java | 62 ----- .../apache/beam/sdk/util/TestCredential.java | 59 ----- .../org/apache/beam/sdk/util/Transport.java | 5 +- .../org/apache/beam/GcpCoreApiSurfaceTest.java | 60 ----- .../extensions/gcp/GcpCoreApiSurfaceTest.java | 60 +++++ .../sdk/extensions/gcp/auth/TestCredential.java | 59 +++++ .../extensions/gcp/options/GcpOptionsTest.java | 172 ++++++++++++++ .../gcp/options/GoogleApiDebugOptionsTest.java | 147 ++++++++++++ .../apache/beam/sdk/options/GcpOptionsTest.java | 171 -------------- .../sdk/options/GoogleApiDebugOptionsTest.java | 146 ------------ .../apache/beam/sdk/util/DefaultBucketTest.java | 6 +- .../beam/sdk/util/GcpProjectUtilTest.java | 3 +- .../beam/sdk/util/GcsIOChannelFactoryTest.java | 2 +- .../beam/sdk/util/GcsPathValidatorTest.java | 3 +- .../org/apache/beam/sdk/util/GcsUtilTest.java | 3 +- .../org/apache/beam/fn/harness/FnHarness.java | 2 +- .../fn/harness/logging/BeamFnLoggingClient.java | 2 +- .../harness/stream/StreamObserverFactory.java | 2 +- .../apache/beam/fn/harness/FnHarnessTest.java | 2 +- sdks/java/io/google-cloud-platform/pom.xml | 7 + .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryOptions.java | 2 +- .../io/gcp/bigquery/BigQueryServicesImpl.java | 4 +- .../beam/sdk/io/gcp/bigtable/BigtableIO.java | 2 +- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 2 +- .../sdk/io/gcp/pubsub/PubsubGrpcClient.java | 2 +- .../beam/sdk/io/gcp/pubsub/PubsubOptions.java | 2 +- .../beam/sdk/io/gcp/storage/GcsFileSystem.java | 2 +- .../io/gcp/storage/GcsFileSystemRegistrar.java | 2 +- .../sdk/io/gcp/bigtable/BigtableIOTest.java | 4 +- .../sdk/io/gcp/bigtable/BigtableWriteIT.java | 2 +- .../beam/sdk/io/gcp/datastore/V1ReadIT.java | 2 +- .../beam/sdk/io/gcp/datastore/V1TestUtil.java | 2 +- .../beam/sdk/io/gcp/datastore/V1WriteIT.java | 2 +- .../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 2 +- .../sdk/io/gcp/storage/GcsFileSystemTest.java | 2 +- 79 files changed, 1360 insertions(+), 1160 deletions(-) ----------------------------------------------------------------------
