This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9ee3724 Merge pull request #11170: [BEAM-9553] Use latest Flink job
server image as default
add 4fa8420 [BEAM-9279] Refactor HBase to disminish relying on
Serializable wrappers
add 8b653b4 [BEAM-9279] Make HBase.ReadAll based on Reads instead of
HBaseQuery
new 52419e9 Merge pull request #10815: [BEAM-9279] Make HBase.ReadAll
based on Reads instead of HBaseQuery
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGES.md | 43 ++-
.../sdk/io/hbase/HBaseCoderProviderRegistrar.java | 3 +-
.../java/org/apache/beam/sdk/io/hbase/HBaseIO.java | 309 ++++++++++++++-------
.../org/apache/beam/sdk/io/hbase/HBaseQuery.java | 52 ----
.../apache/beam/sdk/io/hbase/HBaseQueryCoder.java | 57 ----
.../beam/sdk/io/hbase/HBaseReadSplittableDoFn.java | 60 ++--
.../org/apache/beam/sdk/io/hbase/HBaseUtils.java | 7 +
.../apache/beam/sdk/io/hbase/SerializableScan.java | 52 ----
.../org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 7 +-
.../beam/sdk/io/hbase/SerializableScanTest.java | 55 ----
10 files changed, 270 insertions(+), 375 deletions(-)
delete mode 100644
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseQuery.java
delete mode 100644
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseQueryCoder.java
delete mode 100644
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/SerializableScan.java
delete mode 100644
sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/SerializableScanTest.java
