[BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.
This closes #2561 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6d3fe51c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6d3fe51c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6d3fe51c Branch: refs/heads/master Commit: 6d3fe51ce3240cea54e01cb61723f1547039904d Parents: ed52d32 be92f59 Author: Luke Cwik <[email protected]> Authored: Tue Apr 18 16:19:16 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Tue Apr 18 16:19:16 2017 -0700 ---------------------------------------------------------------------- examples/java/pom.xml | 5 + examples/java8/pom.xml | 5 + pom.xml | 6 + runners/flink/examples/pom.xml | 4 + runners/google-cloud-dataflow-java/pom.xml | 5 + sdks/java/core/pom.xml | 46 +- .../beam/sdk/options/BigQueryOptions.java | 32 - .../options/CloudResourceManagerOptions.java | 40 - .../DefaultPipelineOptionsRegistrar.java | 5 - .../org/apache/beam/sdk/options/GcpOptions.java | 227 ------ .../org/apache/beam/sdk/options/GcsOptions.java | 158 ---- .../beam/sdk/options/GoogleApiDebugOptions.java | 87 -- .../beam/sdk/options/PipelineOptions.java | 4 +- .../apache/beam/sdk/options/PubsubOptions.java | 36 - .../apache/beam/sdk/runners/PipelineRunner.java | 2 + .../beam/sdk/testing/BigqueryMatcher.java | 256 ------ .../apache/beam/sdk/testing/TestPipeline.java | 3 - .../beam/sdk/util/AppEngineEnvironment.java | 62 -- .../apache/beam/sdk/util/CredentialFactory.java | 29 - .../org/apache/beam/sdk/util/DefaultBucket.java | 105 --- .../beam/sdk/util/GcpCredentialFactory.java | 67 -- .../apache/beam/sdk/util/GcpProjectUtil.java | 106 --- .../beam/sdk/util/GcsIOChannelFactory.java | 111 --- .../sdk/util/GcsIOChannelFactoryRegistrar.java | 38 - .../apache/beam/sdk/util/GcsPathValidator.java | 95 --- .../java/org/apache/beam/sdk/util/GcsUtil.java | 798 ------------------- .../util/IntervalBoundedExponentialBackOff.java | 89 --- .../beam/sdk/util/NoopCredentialFactory.java | 68 -- .../sdk/util/NullCredentialInitializer.java | 62 -- .../org/apache/beam/sdk/util/Transport.java | 178 ----- .../org/apache/beam/SdkCoreApiSurfaceTest.java | 2 - .../java/org/apache/beam/sdk/io/TextIOTest.java | 97 +-- .../apache/beam/sdk/options/GcpOptionsTest.java | 171 ---- .../sdk/options/GoogleApiDebugOptionsTest.java | 145 ---- .../sdk/options/PipelineOptionsFactoryTest.java | 4 +- .../beam/sdk/runners/PipelineRunnerTest.java | 46 +- .../beam/sdk/testing/BigqueryMatcherTest.java | 176 ---- .../beam/sdk/testing/TestPipelineTest.java | 6 +- .../apache/beam/sdk/util/DefaultBucketTest.java | 112 --- .../beam/sdk/util/GcpProjectUtilTest.java | 76 -- .../util/GcsIOChannelFactoryRegistrarTest.java | 44 - .../beam/sdk/util/GcsIOChannelFactoryTest.java | 43 - .../beam/sdk/util/GcsPathValidatorTest.java | 87 -- .../org/apache/beam/sdk/util/GcsUtilTest.java | 798 ------------------- .../IntervalBoundedExponentialBackOffTest.java | 100 --- .../util/RetryHttpRequestInitializerTest.java | 290 ------- sdks/java/extensions/gcp-core/pom.xml | 217 +++++ .../beam/sdk/options/BigQueryOptions.java | 32 + .../options/CloudResourceManagerOptions.java | 40 + .../org/apache/beam/sdk/options/GcpOptions.java | 227 ++++++ .../options/GcpPipelineOptionsRegistrar.java | 39 + .../org/apache/beam/sdk/options/GcsOptions.java | 158 ++++ .../beam/sdk/options/GoogleApiDebugOptions.java | 87 ++ .../apache/beam/sdk/options/PubsubOptions.java | 36 + .../apache/beam/sdk/options/package-info.java | 22 + .../beam/sdk/testing/BigqueryMatcher.java | 256 ++++++ .../apache/beam/sdk/testing/package-info.java | 21 + .../beam/sdk/util/AppEngineEnvironment.java | 62 ++ .../apache/beam/sdk/util/CredentialFactory.java | 29 + .../org/apache/beam/sdk/util/DefaultBucket.java | 105 +++ .../beam/sdk/util/GcpCredentialFactory.java | 67 ++ .../apache/beam/sdk/util/GcpProjectUtil.java | 106 +++ .../beam/sdk/util/GcsIOChannelFactory.java | 111 +++ .../sdk/util/GcsIOChannelFactoryRegistrar.java | 38 + .../apache/beam/sdk/util/GcsPathValidator.java | 95 +++ .../java/org/apache/beam/sdk/util/GcsUtil.java | 798 +++++++++++++++++++ .../util/IntervalBoundedExponentialBackOff.java | 89 +++ .../beam/sdk/util/NoopCredentialFactory.java | 68 ++ .../sdk/util/NullCredentialInitializer.java | 62 ++ .../org/apache/beam/sdk/util/Transport.java | 178 +++++ .../org/apache/beam/sdk/util/package-info.java | 20 + .../org/apache/beam/GcpCoreApiSurfaceTest.java | 62 ++ .../apache/beam/sdk/options/GcpOptionsTest.java | 171 ++++ .../sdk/options/GoogleApiDebugOptionsTest.java | 145 ++++ .../beam/sdk/testing/BigqueryMatcherTest.java | 176 ++++ .../apache/beam/sdk/util/DefaultBucketTest.java | 112 +++ .../beam/sdk/util/GcpProjectUtilTest.java | 76 ++ .../util/GcsIOChannelFactoryRegistrarTest.java | 44 + .../beam/sdk/util/GcsIOChannelFactoryTest.java | 43 + .../beam/sdk/util/GcsPathValidatorTest.java | 87 ++ .../org/apache/beam/sdk/util/GcsUtilTest.java | 798 +++++++++++++++++++ .../IntervalBoundedExponentialBackOffTest.java | 100 +++ .../util/RetryHttpRequestInitializerTest.java | 290 +++++++ sdks/java/extensions/pom.xml | 1 + sdks/java/harness/pom.xml | 5 + sdks/java/io/google-cloud-platform/pom.xml | 20 +- 86 files changed, 5130 insertions(+), 4889 deletions(-) ----------------------------------------------------------------------
