You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/11/23 06:52:35 UTC
[39/50] incubator-beam git commit: [BEAM-952] Use ServiceLoader to
register IOChannelFactories.
[BEAM-952] Use ServiceLoader to register IOChannelFactories.
This closes #1255
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e53d6d45
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e53d6d45
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e53d6d45
Branch: refs/heads/gearpump-runner
Commit: e53d6d45895aee6c61fd8060b20751875352a4ee
Parents: 249dbc0 fa417f9
Author: Luke Cwik <lc...@google.com>
Authored: Tue Nov 22 06:19:30 2016 -0800
Committer: Luke Cwik <lc...@google.com>
Committed: Tue Nov 22 06:19:30 2016 -0800
----------------------------------------------------------------------
.../beam/runners/dataflow/DataflowRunner.java | 2 +-
.../options/DataflowPipelineOptionsTest.java | 6 +-
.../runners/dataflow/util/PackageUtilTest.java | 2 +-
.../sdk/options/PipelineOptionsFactory.java | 32 +----
.../apache/beam/sdk/runners/PipelineRunner.java | 2 +-
.../apache/beam/sdk/testing/TestPipeline.java | 2 +-
.../beam/sdk/util/FileIOChannelFactory.java | 11 ++
.../sdk/util/FileIOChannelFactoryRegistrar.java | 38 ++++++
.../beam/sdk/util/GcsIOChannelFactory.java | 10 +-
.../sdk/util/GcsIOChannelFactoryRegistrar.java | 38 ++++++
.../sdk/util/IOChannelFactoryRegistrar.java | 48 +++++++
.../apache/beam/sdk/util/IOChannelUtils.java | 134 ++++++++++++++++++-
.../beam/sdk/util/common/ReflectHelpers.java | 29 ++++
.../java/org/apache/beam/sdk/io/AvroIOTest.java | 2 +-
.../apache/beam/sdk/io/FileBasedSourceTest.java | 2 +-
.../java/org/apache/beam/sdk/io/TextIOTest.java | 2 +-
.../sdk/options/PipelineOptionsFactoryTest.java | 34 -----
.../util/FileIOChannelFactoryRegistrarTest.java | 44 ++++++
.../beam/sdk/util/FileIOChannelFactoryTest.java | 2 +-
.../util/GcsIOChannelFactoryRegistrarTest.java | 44 ++++++
.../beam/sdk/util/GcsIOChannelFactoryTest.java | 2 +-
.../beam/sdk/util/IOChannelUtilsTest.java | 39 ++++++
.../sdk/util/common/ReflectHelpersTest.java | 33 +++++
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 6 +-
24 files changed, 478 insertions(+), 86 deletions(-)
----------------------------------------------------------------------