[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/master 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(-) ----------------------------------------------------------------------