This is an automated email from the ASF dual-hosted git repository.
Jackie-Jiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from db54af84a7f Add scalar functions: PostgreSQL-compliance math, string,
trig, and IP utilities (#18420)
add 9853d35ab2f Refactor Avro/Parquet RecordExtractor; finalize
logical-type contract (#18400)
No new revisions were added by this update.
Summary of changes:
.../common/function/scalar/StringFunctions.java | 13 +-
.../apache/pinot/common/utils/PinotDataType.java | 254 +++++++-
.../pinot/common/utils/PinotDataTypeTest.java | 122 +++-
.../tests/TimeSeriesIntegrationTest.java | 4 +-
.../pinot/integration/tests/udf/AvroSink.java | 21 +-
.../arrow/ArrowToGenericRowConverter.java | 3 +-
.../inputformat/avro/AvroRecordExtractor.java | 239 ++++++--
.../avro/AvroRecordExtractorConfig.java | 26 +-
.../plugin/inputformat/avro/AvroRecordReader.java | 2 +-
.../inputformat/avro/AvroRecordReaderConfig.java | 15 +-
.../plugin/inputformat/avro/AvroSchemaUtil.java | 166 +-----
.../pinot/plugin/inputformat/avro/AvroUtils.java | 32 +-
.../inputformat/avro/AvroRecordExtractorTest.java | 655 +++++++++++++++++----
.../avro/AvroRecordToPinotRowGeneratorTest.java | 156 -----
.../inputformat/avro/AvroSchemaUtilTest.java | 362 ------------
.../plugin/inputformat/orc/ORCRecordExtractor.java | 12 +-
.../parquet/ParquetAvroRecordExtractor.java | 44 +-
.../parquet/ParquetAvroRecordReader.java | 8 +-
.../parquet/ParquetNativeRecordExtractor.java | 208 ++++---
.../ParquetNativeRecordExtractorConfig.java} | 23 +-
.../parquet/ParquetNativeRecordReader.java | 7 +-
.../parquet/ParquetRecordReaderConfig.java | 39 +-
.../plugin/inputformat/parquet/ParquetUtils.java | 41 +-
.../parquet/ParquetAvroRecordExtractorTest.java | 68 ++-
.../ParquetCollectionAndEquivalenceTest.java | 548 ++++++++++-------
.../parquet/ParquetNativeRecordExtractorTest.java | 160 ++++-
.../protobuf/ProtoBufRecordExtractor.java | 17 +-
.../inputformat/thrift/ThriftRecordExtractor.java | 4 +-
pinot-spi/pom.xml | 4 +
.../spi/data/readers/BaseRecordExtractor.java | 150 +++--
.../pinot/spi/data/readers/RecordExtractor.java | 64 +-
.../java/org/apache/pinot/spi/utils/JsonUtils.java | 57 +-
.../java/org/apache/pinot/spi/utils/MapUtils.java | 27 +-
.../org/apache/pinot/spi/utils/TimestampUtils.java | 36 +-
.../java/org/apache/pinot/spi/utils/UuidUtils.java | 49 ++
.../spi/data/readers/BaseRecordExtractorTest.java | 196 +++---
.../org/apache/pinot/spi/utils/JsonUtilsTest.java | 44 ++
.../org/apache/pinot/spi/utils/MapUtilsTest.java | 39 ++
.../apache/pinot/spi/utils/TimestampUtilsTest.java | 42 ++
39 files changed, 2317 insertions(+), 1640 deletions(-)
delete mode 100644
pinot-plugins/pinot-input-format/pinot-avro-base/src/test/java/org/apache/pinot/plugin/inputformat/avro/AvroRecordToPinotRowGeneratorTest.java
delete mode 100644
pinot-plugins/pinot-input-format/pinot-avro-base/src/test/java/org/apache/pinot/plugin/inputformat/avro/AvroSchemaUtilTest.java
copy
pinot-plugins/pinot-input-format/{pinot-avro-base/src/main/java/org/apache/pinot/plugin/inputformat/avro/AvroRecordExtractorConfig.java
=>
pinot-parquet/src/main/java/org/apache/pinot/plugin/inputformat/parquet/ParquetNativeRecordExtractorConfig.java}
(59%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/utils/UuidUtils.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
