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/18 23:19:33 UTC

[7/7] beam git commit: [BEAM-1871] Create new GCP core module package and move several GCP related classes from beam-sdks-java-core over.

[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 <lc...@google.com>
Authored: Tue Apr 18 16:19:16 2017 -0700
Committer: Luke Cwik <lc...@google.com>
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(-)
----------------------------------------------------------------------