You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by yu...@apache.org on 2021/05/12 22:16:41 UTC
[incubator-pinot] branch master updated (dce7479 -> 046b255)
This is an automated email from the ASF dual-hosted git repository.
yupeng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from dce7479 Move maxBurstQps broker metric in createRateLimiter method (#6898)
add 046b255 Add the complex data type transformer for complex type handling (#6845)
No new revisions were added by this update.
Summary of changes:
.../common/utils/config/TableConfigSerDeTest.java | 5 +-
.../pinot/controller/util/FileIngestionHelper.java | 2 +-
.../realtime/LLRealtimeSegmentDataManager.java | 30 ++-
.../apache/pinot/core/util/SchemaUtilsTest.java | 4 +-
.../pinot/core/util/TableConfigUtilsTest.java | 48 ++--
.../IngestionConfigHybridIntegrationTest.java | 2 +-
.../tests/JsonPathClusterIntegrationTest.java | 2 +-
.../tests/MapTypeClusterIntegrationTest.java | 2 +-
.../tests/OfflineClusterIntegrationTest.java | 2 +-
.../SegmentWriterUploaderIntegrationTest.java | 2 +-
.../RealtimeToOfflineSegmentsTaskExecutorTest.java | 4 +-
.../filebased/FileBasedSegmentWriterTest.java | 20 +-
.../recordtransformer/ComplexTypeTransformer.java | 259 +++++++++++++++++++++
.../ComplexTypeTransformerTest.java | 224 ++++++++++++++++++
.../ExpressionTransformerTest.java | 10 +-
.../recordtransformer/RecordTransformerTest.java | 10 +-
.../SegmentGenerationWithFilterRecordsTest.java | 2 +-
.../index/loader/SegmentPreProcessorTest.java | 2 +-
.../segment/local/utils/IngestionUtilsTest.java | 14 +-
.../{FilterConfig.java => ComplexTypeConfig.java} | 17 +-
.../config/table/ingestion/IngestionConfig.java | 12 +-
.../apache/pinot/spi/data/readers/GenericRow.java | 49 ++++
.../pinot/spi/utils/IngestionConfigUtilsTest.java | 8 +-
... => RealtimeComplexTypeHandlingQuickStart.java} | 14 +-
...Handling_meetupRsvp_realtime_table_config.json} | 27 +--
... => complexTypeHandling_meetupRsvp_schema.json} | 27 +--
26 files changed, 665 insertions(+), 133 deletions(-)
create mode 100644 pinot-segment-local/src/main/java/org/apache/pinot/segment/local/recordtransformer/ComplexTypeTransformer.java
create mode 100644 pinot-segment-local/src/test/java/org/apache/pinot/segment/local/recordtransformer/ComplexTypeTransformerTest.java
copy pinot-spi/src/main/java/org/apache/pinot/spi/config/table/ingestion/{FilterConfig.java => ComplexTypeConfig.java} (71%)
copy pinot-tools/src/main/java/org/apache/pinot/tools/{RealtimeJsonIndexQuickStart.java => RealtimeComplexTypeHandlingQuickStart.java} (91%)
copy pinot-tools/src/main/resources/examples/stream/meetupRsvp/{json_meetupRsvp_realtime_table_config.json => complexTypeHandling_meetupRsvp_realtime_table_config.json} (72%)
copy pinot-tools/src/main/resources/examples/stream/meetupRsvp/{json_meetupRsvp_schema.json => complexTypeHandling_meetupRsvp_schema.json} (55%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org