This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 77a5672f6c Update metric rules to emit database as a label (#12739)
add 01df14b4b0 pluggable partial upsert merger (#11983)
No new revisions were added by this update.
Summary of changes:
.../upsert/BaseTableUpsertMetadataManager.java | 8 +-
...oncurrentMapPartitionUpsertMetadataManager.java | 6 +-
.../segment/local/upsert/PartialUpsertHandler.java | 109 +++++++++------------
...MaxMerger.java => BasePartialUpsertMerger.java} | 21 ++--
.../upsert/merger/PartialUpsertColumnarMerger.java | 99 +++++++++++++++++++
.../local/upsert/merger/PartialUpsertMerger.java | 19 ++--
.../upsert/merger/PartialUpsertMergerFactory.java | 45 ++++-----
.../upsert/merger/{ => columnar}/AppendMerger.java | 6 +-
.../upsert/merger/{ => columnar}/IgnoreMerger.java | 6 +-
.../merger/{ => columnar}/IncrementMerger.java | 6 +-
.../upsert/merger/{ => columnar}/MaxMerger.java | 7 +-
.../upsert/merger/{ => columnar}/MinMerger.java | 7 +-
.../merger/{ => columnar}/OverwriteMerger.java | 6 +-
.../PartialUpsertColumnMerger.java} | 7 +-
.../PartialUpsertColumnMergerFactory.java} | 8 +-
.../upsert/merger/{ => columnar}/UnionMerger.java | 6 +-
.../segment/local/utils/TableConfigUtils.java | 57 ++++++-----
.../local/upsert/PartialUpsertHandlerTest.java | 107 ++++++++++++++++++--
.../merger/PartialUpsertMergerFactoryTest.java | 57 +++++++++++
.../PartialUpsertColumnMergerTest.java} | 21 ++--
.../pinot/spi/config/table/UpsertConfig.java | 15 +++
21 files changed, 434 insertions(+), 189 deletions(-)
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{MaxMerger.java
=> BasePartialUpsertMerger.java} (60%)
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/PartialUpsertColumnarMerger.java
rename
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{
=> columnar}/AppendMerger.java (91%)
rename
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{
=> columnar}/IgnoreMerger.java (88%)
rename
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{
=> columnar}/IncrementMerger.java (91%)
rename
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{
=> columnar}/MaxMerger.java (89%)
rename
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{
=> columnar}/MinMerger.java (89%)
rename
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{
=> columnar}/OverwriteMerger.java (88%)
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{PartialUpsertMerger.java
=> columnar/PartialUpsertColumnMerger.java} (85%)
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{PartialUpsertMergerFactory.java
=> columnar/PartialUpsertColumnMergerFactory.java} (88%)
rename
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/{
=> columnar}/UnionMerger.java (92%)
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/upsert/merger/PartialUpsertMergerFactoryTest.java
rename
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/upsert/merger/{PartialUpsertMergerTest.java
=> columnar/PartialUpsertColumnMergerTest.java} (65%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
