This is an automated email from the ASF dual-hosted git repository.
vjasani pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
from 9d93facd8f PHOENIX-6950 PhoenixDriver APIs should unlock closeLock
only if thread is able to take lock (#1609)
add 4c7752355d PHOENIX-5521 Phoenix level HBase Replication Sink Endpoint
(#1561)
No new revisions were added by this update.
Summary of changes:
.../apache/phoenix/end2end/WALAnnotationIT.java | 6 +-
.../index/ReplicationWithWALAnnotationIT.java | 557 +++++++++++++++++++++
...processor.java => ReplicationSinkEndpoint.java} | 16 +-
.../UngroupedAggregateRegionScanner.java | 16 +
.../org/apache/phoenix/execute/MutationState.java | 35 +-
.../java/org/apache/phoenix/util/ScanUtil.java | 15 +
.../org/apache/phoenix/util/WALAnnotationUtil.java | 15 +
...ble.java => ReplicationSinkCompatEndpoint.java} | 24 +-
.../hbase/ReplicationSinkCompatEndpoint.java | 24 +-
phoenix-hbase-compat-2.4.1/pom.xml | 2 +-
.../hbase/ReplicationSinkCompatEndpoint.java | 63 +++
phoenix-hbase-compat-2.5.0/pom.xml | 2 +-
.../hbase/ReplicationSinkCompatEndpoint.java | 63 +++
13 files changed, 790 insertions(+), 48 deletions(-)
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/index/ReplicationWithWALAnnotationIT.java
copy
phoenix-core/src/main/java/org/apache/phoenix/coprocessor/{PhoenixCoprocessor.java
=> ReplicationSinkEndpoint.java} (69%)
copy
phoenix-hbase-compat-2.3.0/src/main/java/org/apache/phoenix/compat/hbase/{CompatDelegateHTable.java
=> ReplicationSinkCompatEndpoint.java} (67%)
copy
phoenix-hbase-compat-2.3.0/src/main/java/org/apache/phoenix/compat/hbase/CompatDelegateHTable.java
=>
phoenix-hbase-compat-2.4.0/src/main/java/org/apache/phoenix/compat/hbase/ReplicationSinkCompatEndpoint.java
(67%)
create mode 100644
phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/ReplicationSinkCompatEndpoint.java
create mode 100644
phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/ReplicationSinkCompatEndpoint.java
