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 1f6b882841 Add withTableProperties to Get Tenant Table API (#16202)
add 116050bea2 Refine record transform handling (#16254)
No new revisions were added by this update.
Summary of changes:
.../connector/flink/sink/FlinkSegmentWriter.java | 20 +-
.../realtime/RealtimeSegmentDataManager.java | 93 ++--
.../framework/SegmentProcessorFramework.java | 2 +-
.../segment/processing/mapper/SegmentMapper.java | 39 +-
.../mergerollup/DimensionValueTransformer.java | 36 +-
.../mergerollup/DimensionValueTransformerTest.java | 4 +-
.../filebased/FileBasedSegmentWriter.java | 18 +-
.../converter/RealtimeSegmentConverter.java | 2 +-
.../writer/StatelessRealtimeSegmentWriter.java | 11 +-
.../recordtransformer/ComplexTypeTransformer.java | 226 +++++-----
.../recordtransformer/CompositeTransformer.java | 202 ---------
.../recordtransformer/DataTypeTransformer.java | 18 +-
.../recordtransformer/ExpressionTransformer.java | 17 +-
.../local/recordtransformer/FilterTransformer.java | 43 +-
.../recordtransformer/NullValueTransformer.java | 3 +-
.../recordtransformer/RecordTransformerUtils.java | 122 ++++++
.../recordtransformer/SanitizationTransformer.java | 40 +-
.../SchemaConformingTransformer.java | 179 ++++----
.../recordtransformer/SpecialValueTransformer.java | 3 +-
.../TimeValidationTransformer.java | 44 +-
.../RecordReaderSegmentCreationDataSource.java | 10 +-
.../local/segment/creator/TransformPipeline.java | 204 ++++-----
.../impl/SegmentIndexCreationDriverImpl.java | 18 +-
.../pinot/segment/local/utils/IngestionUtils.java | 8 -
.../mutable/MutableSegmentDedupTest.java | 10 +-
.../MutableSegmentImplNullValueVectorTest.java | 55 +--
.../MutableSegmentImplUpsertComparisonColTest.java | 72 +--
.../mutable/MutableSegmentImplUpsertTest.java | 65 +--
.../ComplexTypeTransformerTest.java | 272 ++++++------
.../CompositeTransformerTest.java | 82 ----
.../ExpressionTransformerTest.java | 20 +-
.../recordtransformer/RecordTransformerTest.java | 486 ++++++++-------------
.../SchemaConformingTransformerTest.java | 30 +-
.../segment/creator/TransformPipelineTest.java | 172 +++-----
.../readers/RecordReaderSampleDataTest.java | 63 ++-
.../apache/pinot/spi/data/readers/GenericRow.java | 76 ++--
.../spi/recordtransformer/RecordTransformer.java | 37 +-
.../recordtransformer/enricher/RecordEnricher.java | 10 +-
.../admin/command/DataImportDryRunCommand.java | 6 +-
39 files changed, 1236 insertions(+), 1582 deletions(-)
delete mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/CompositeTransformer.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/RecordTransformerUtils.java
delete mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/recordtransformer/CompositeTransformerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
