beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [39/50] incubator-beam git commit: [BEAM-952] Use ServiceLoader to register IOChannelFactories.
Date Wed, 23 Nov 2016 06:52:35 GMT
[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 <lcwik@google.com>
Authored: Tue Nov 22 06:19:30 2016 -0800
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message