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 a506df38a5 Safeguard AbstractBuilder copy constructor from empty
TextIndexConfig (#14616)
add 694546b3b2 Make RecordEnricher extend RecordTransformer (#14601)
No new revisions were added by this update.
Summary of changes:
.../connector/flink/sink/FlinkSegmentWriter.java | 7 +-
.../realtime/RealtimeSegmentDataManager.java | 15 +--
.../framework/SegmentProcessorFramework.java | 10 +-
.../segment/processing/mapper/SegmentMapper.java | 7 +-
.../mergerollup/DimensionValueTransformer.java | 2 +-
.../tasks/mergerollup/MergeRollupTaskExecutor.java | 2 +-
.../mergerollup/DimensionValueTransformerTest.java | 2 +-
.../filebased/FileBasedSegmentWriter.java | 3 +-
.../converter/RealtimeSegmentConverter.java | 4 +-
.../recordtransformer/ComplexTypeTransformer.java | 10 +-
.../recordtransformer/CompositeTransformer.java | 70 ++++++++---
.../recordtransformer/DataTypeTransformer.java | 7 ++
.../recordtransformer/ExpressionTransformer.java | 16 +++
.../local/recordtransformer/FilterTransformer.java | 7 ++
.../recordtransformer/NullValueTransformer.java | 1 +
.../recordtransformer/SanitizationTransformer.java | 1 +
.../SchemaConformingTransformer.java | 1 +
.../SchemaConformingTransformerV2.java | 1 +
.../recordtransformer/SpecialValueTransformer.java | 1 +
.../TimeValidationTransformer.java | 1 +
.../enricher/clp/CLPEncodingEnricher.java | 8 +-
.../enricher/clp/CLPEncodingEnricherConfig.java} | 6 +-
.../enricher/clp/CLPEncodingEnricherFactory.java | 12 +-
.../enricher/function/CustomFunctionEnricher.java | 10 +-
.../function/CustomFunctionEnricherConfig.java | 7 +-
.../function/CustomFunctionEnricherFactory.java | 10 +-
.../RecordReaderSegmentCreationDataSource.java | 9 --
.../local/segment/creator/TransformPipeline.java | 14 ++-
.../impl/SegmentIndexCreationDriverImpl.java | 27 +----
.../pinot/segment/local/utils/IngestionUtils.java | 133 ++++++---------------
.../segment/local/utils/TableConfigUtils.java | 4 +-
.../recordtransformer/RecordTransformerTest.java | 1 +
.../SchemaConformingTransformerTest.java | 1 +
.../segment/local/utils/IngestionUtilsTest.java | 63 +++++-----
.../spi/annotations/RecordEnricherFactory.java | 30 -----
.../spi/recordenricher/RecordEnricherConfig.java | 23 ----
.../spi/recordenricher/RecordEnricherPipeline.java | 75 ------------
.../spi}/recordtransformer/RecordTransformer.java | 12 +-
.../enricher}/RecordEnricher.java | 21 ++--
.../enricher}/RecordEnricherFactory.java | 20 +++-
.../enricher}/RecordEnricherRegistry.java | 40 +++----
.../enricher}/RecordEnricherValidationConfig.java | 2 +-
42 files changed, 302 insertions(+), 394 deletions(-)
rename pinot-segment-local/src/main/java/org/apache/pinot/{plugin/record =>
segment/local/recordtransformer}/enricher/clp/CLPEncodingEnricher.java (92%)
rename
pinot-segment-local/src/main/java/org/apache/pinot/{plugin/record/enricher/clp/ClpEnricherConfig.java
=>
segment/local/recordtransformer/enricher/clp/CLPEncodingEnricherConfig.java}
(85%)
rename pinot-segment-local/src/main/java/org/apache/pinot/{plugin/record =>
segment/local/recordtransformer}/enricher/clp/CLPEncodingEnricherFactory.java
(80%)
rename pinot-segment-local/src/main/java/org/apache/pinot/{plugin/record =>
segment/local/recordtransformer}/enricher/function/CustomFunctionEnricher.java
(86%)
rename pinot-segment-local/src/main/java/org/apache/pinot/{plugin/record =>
segment/local/recordtransformer}/enricher/function/CustomFunctionEnricherConfig.java
(89%)
rename pinot-segment-local/src/main/java/org/apache/pinot/{plugin/record =>
segment/local/recordtransformer}/enricher/function/CustomFunctionEnricherFactory.java
(87%)
delete mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/annotations/RecordEnricherFactory.java
delete mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricherConfig.java
delete mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricherPipeline.java
rename {pinot-segment-local/src/main/java/org/apache/pinot/segment/local =>
pinot-spi/src/main/java/org/apache/pinot/spi}/recordtransformer/RecordTransformer.java
(82%)
rename pinot-spi/src/main/java/org/apache/pinot/spi/{recordenricher =>
recordtransformer/enricher}/RecordEnricher.java (65%)
rename pinot-spi/src/main/java/org/apache/pinot/spi/{recordenricher =>
recordtransformer/enricher}/RecordEnricherFactory.java (75%)
rename pinot-spi/src/main/java/org/apache/pinot/spi/{recordenricher =>
recordtransformer/enricher}/RecordEnricherRegistry.java (69%)
rename pinot-spi/src/main/java/org/apache/pinot/spi/{recordenricher =>
recordtransformer/enricher}/RecordEnricherValidationConfig.java (95%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
