You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ie...@apache.org on 2018/07/12 09:28:53 UTC

[beam] 01/01: Merge pull request #5212: [BEAM-4020] Add HBaseIO.readAll() based on SDF

This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 95f1a5aeba85cd4a6e0eb1ce6eee141e3667d86d
Merge: 48e4318 e53b0b2
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Thu Jul 12 11:28:47 2018 +0200

    Merge pull request #5212: [BEAM-4020] Add HBaseIO.readAll() based on SDF

 .../sdk/io/hbase/HBaseCoderProviderRegistrar.java  |   3 +-
 .../java/org/apache/beam/sdk/io/hbase/HBaseIO.java |  61 +++++++++--
 ...CoderProviderRegistrar.java => HBaseQuery.java} |  46 +++++---
 .../apache/beam/sdk/io/hbase/HBaseQueryCoder.java  |  57 ++++++++++
 .../beam/sdk/io/hbase/HBaseReadSplittableDoFn.java | 109 +++++++++++++++++++
 .../org/apache/beam/sdk/io/hbase/HBaseIOTest.java  | 121 ++++++++++++++-------
 6 files changed, 333 insertions(+), 64 deletions(-)