This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/com.h2database-h2-2.2.224
in repository https://gitbox.apache.org/repos/asf/pinot.git
omit 75d13eca36 Bump com.h2database:h2 from 2.2.220 to 2.2.224
add 6b0cfebffe share the same table config object (#12463)
add d7feaaf4f8 cleanup: fix apache rat violation (#12476)
add 1004d3b0d2 bugfix: reduce enum array allocation in QueryLogger (#12478)
add fe7530969d bugfix: fixing jdbc client sql feature not supported
exception (#12480)
add 4621aaf85b Remove mercateo test-clock dependency (#12473)
add 3d7bc6f09f cleanup: maven no transfer progress (#12444)
add 7f09cc8d56 [Adaptive Server Selector] Add metrics for Stats Manager
Queue Size (#12340)
add efd7786797 require noDictionaryColumns with aggregationConfigs (#12464)
add 59551e4522 Emit Metrics for Broker Adaptive Server Selector type
(#12482)
add 2086f93782 Bump org.apache.maven.plugins:maven-checkstyle-plugin
(#12489)
add 62352d53e0 Upgrade github action plugin versions (#12490)
add 0ff9fe2b3f bump netty 4.1.100 to 4.1.107 (#12485)
add 55cecc1824 Enabling avroParquet to read Int96 as bytes (#12484)
add c8060c143c [Feature] Add Support for SQL Formatting in Query Editor
(#11725)
add fb1b79da88 Fix the race condition for H3InclusionIndexFilterOperator
(#12487)
add cd41d70e30 add Netty unit test (#12486)
add 6903eca09e enable Netty leak detection (#12483)
add e2444422db add Netty arm64 dependencies (#12493)
add 7f8bfab1b4 bump maven-surefire-plugin to 3.2.5 (#12491)
add 5b834e1f9a bump testng to 7.9.0 (#12492)
add dcbaca1f1a bump maven-dependency-plugin to 3.6.1 (#12495)
add a1ed8bdb62 close JDBC connections (#12494)
add 8977c85e4f Remove all table metrics when a table is deleted (#12403)
add 3267a749f8 int96 parity with native parquet reader (#12496)
add 07daa7bbaa Record enricher (#12243)
add b42010a1ec auto renew jvm default sslconext when it's loaded from
files (#12462)
add d9ac0efa7d Add config option for timezone (#12386)
add 5dc807bb0a Adds per-column, query-time index skip option (#12414)
add 74989c0191 Lint failure (#12294)
add 19e1ab7932 fix GuavaRateLimiter acquire method (#12500)
add bc07b8dd2c Metric for upsert tables count (#12505)
add 28e480e8d3 Fix ColumnMinMaxValueGenerator (#12502)
add 7e6117f046 Add controller API to get allLiveInstances (#12498)
add 53b3bfa41c refactor TlsUtils class (#12515)
add eb61827435 Update license & notice for release 1.1.0 (#12511)
add 689d7d712b Propagate Disable User Agent Config to Http Client (#12479)
add ac13a191b9 Added pinot-error-code header in query response (#12338)
add 704f73d4f9 update ControllerJobType from enum to string (#12518)
add 35c89c87a5 [Multi-stage] Reduce the stats transfered (#12517)
add bddd3612bc Pass explicit TypeRef when evaluating MV jsonPath (#12524)
add 2249be357b Rest Endpoint to Create ZNode (#12497)
add f0fcbd8701 Adding record reader config/context param to record
transformer (#12520)
add 8972bc6066 Revert " Adding record reader config/context param to
record transformer (#12520)" (#12526)
add 1bfc6ac4dd maven: no transfer progress (#12528)
add f51c34fcbd Egalpin/skip indexes minor changes (#12514)
add 954f5d7e51 use Temurin instead of AdoptOpenJdk (#12533)
add 7b71babb73 reformat ClusterTest.java (#12531)
add 60d23ca97b Prepare for next development iteration (#12530)
add 9a8fa79199 Allow passing custom record reader to be inited/closed in
SegmentProcessorFramework (#12529)
add 01b0f8c272 [null-aggr] Add null handling support in `mode` aggregation
(#12227)
add 06495fdd7e remove duplicate scala.version (#12543)
add dbf55b3435 Metrics for Realtime Rows Fetched and Stream Consumer
Create Exceptions (#12522)
add 8b05ccab9c bump mockito to 5.11.0 (#12536)
add 7ba328fa3d Addressed comments and fixed tests from pull request 12389.
/uptime and /start-time endpoints working all components (#12512)
add 81b2eef49b use maven 3.9.6 in docker (#12549)
add c275823728 build-helper-maven-plugin 3.5.0 (#12548)
add 3397986ada maven-compiler-plugin 3.12.1 (#12540)
add fc2fb69f05 Bump org.apache.maven.scm:maven-scm-provider-gitexe from
1.9.4 to 2.0.1 (#12472)
add edfd78d181 Bump org.apache.maven.plugins:maven-eclipse-plugin from 2.9
to 2.10 (#12471)
add 0175f33763 GitHub Actions checkout v4 (#12550)
add e051ac984b Bump com.h2database:h2 from 2.2.220 to 2.2.224
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (75d13eca36)
\
N -- N -- N
refs/heads/dependabot/maven/com.h2database-h2-2.2.224 (e051ac984b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../build-multi-arch-pinot-docker-image.yml | 10 +-
.../workflows/build-pinot-base-docker-image.yml | 4 +-
.github/workflows/build-pinot-docker-image.yml | 4 +-
.github/workflows/build-presto-docker-image.yml | 4 +-
.github/workflows/build-superset-docker-image.yml | 4 +-
.github/workflows/pinot_compatibility_tests.yml | 8 +-
.github/workflows/pinot_tests.yml | 43 +-
.github/workflows/pinot_vuln_check.yml | 4 +-
.../scripts/pr-tests/.pinot_tests_build.sh | 6 +-
LICENSE-binary | 354 +-
NOTICE-binary | 125 +-
contrib/pinot-fmpp-maven-plugin/pom.xml | 2 +-
.../pinot-base-build/amazoncorretto.dockerfile | 2 +-
.../pinot-base-build/ms-openjdk.dockerfile | 2 +-
.../pinot-base/pinot-base-build/openjdk.dockerfile | 2 +-
docker/images/pinot-presto/Dockerfile | 2 +-
.../jmx_prometheus_javaagent/configs/server.yml | 2 +-
licenses-binary/LICENSE-go.txt | 27 +
pinot-broker/pom.xml | 7 +-
.../api/resources/PinotBrokerHealthCheck.java | 31 +
.../broker/api/resources/PinotClientRequest.java | 36 +-
.../broker/broker/BrokerAdminApiApplication.java | 6 +-
.../broker/broker/helix/BaseBrokerStarter.java | 7 +-
.../apache/pinot/broker/querylog/QueryLogger.java | 3 +-
.../MultiStageBrokerRequestHandler.java | 20 +-
.../api/resources/PinotClientRequestTest.java | 54 +
.../AdaptiveServerSelectorTest.java | 44 +-
.../instanceselector/InstanceSelectorTest.java | 4 +-
pinot-clients/pinot-java-client/pom.xml | 2 +-
.../apache/pinot/client/utils/ConnectionUtils.java | 2 +-
pinot-clients/pinot-jdbc-client/pom.xml | 2 +-
.../java/org/apache/pinot/client/PinotDriver.java | 2 +-
.../pinot/client/base/AbstractBaseConnection.java | 210 +-
.../org/apache/pinot/client/utils/Constants.java | 2 +-
.../org/apache/pinot/client/utils/DriverUtils.java | 2 +-
pinot-clients/pom.xml | 2 +-
pinot-common/pom.xml | 15 +-
.../org/apache/pinot/common/config/GrpcConfig.java | 2 +-
.../pinot/common/datablock/DataBlockUtils.java | 2 -
.../pinot/common/metadata/ZKMetadataProvider.java | 5 +-
.../metadata/controllerjob/ControllerJobType.java | 15 +-
.../pinot/common/metrics/AbstractMetrics.java | 15 +
.../apache/pinot/common/metrics/BrokerGauge.java | 13 +-
.../pinot/common/metrics/ControllerGauge.java | 1 +
.../apache/pinot/common/metrics/ServerMeter.java | 2 +
.../pinot/common/utils/ServiceStartableUtils.java | 13 +
.../common/utils/config/QueryOptionsUtils.java | 33 +
.../pinot/common/utils/grpc/GrpcQueryClient.java | 4 +-
.../apache/pinot/common/utils/http/HttpClient.java | 5 +-
.../common/utils/tls/JvmDefaultSslContext.java | 108 +
.../pinot/common/utils/tls/RenewableTlsUtils.java | 268 +
.../pinot/common/utils/{ => tls}/TlsUtils.java | 242 +-
.../InstanceAssignmentConfigUtilsTest.java | 238 +
.../org/apache/pinot/common/utils/TestClock.java} | 39 +-
.../common/utils/config/QueryOptionsUtilsTest.java | 22 +
.../pinot/common/utils/{ => tls}/TlsUtilsTest.java | 28 +-
pinot-compatibility-verifier/pom.xml | 2 +-
pinot-connectors/pinot-flink-connector/pom.xml | 2 +-
.../connector/flink/sink/FlinkSegmentWriter.java | 4 +
pinot-connectors/pinot-spark-2-connector/pom.xml | 2 +-
pinot-connectors/pinot-spark-3-connector/pom.xml | 2 +-
pinot-connectors/pinot-spark-common/pom.xml | 2 +-
.../common/reader/PinotServerDataFetcher.scala | 2 +-
pinot-connectors/pom.xml | 2 +-
pinot-controller/package-lock.json | 6 +
pinot-controller/pom.xml | 2 +-
.../pinot/controller/BaseControllerStarter.java | 5 +-
.../api/ControllerAdminApiApplication.java | 2 +
.../api/resources/PinotControllerHealthCheck.java | 32 +
.../resources/PinotInstanceRestletResource.java | 13 +
.../api/resources/PinotTableRestletResource.java | 15 +-
.../api/resources/ZookeeperResource.java | 62 +
.../controller/helix/SegmentStatusChecker.java | 73 +-
.../helix/core/PinotHelixResourceManager.java | 35 +-
.../rebalance/ZkBasedTableRebalanceObserver.java | 2 +-
.../tenant/ZkBasedTenantRebalanceObserver.java | 2 +-
pinot-controller/src/main/resources/Readme.md | 21 +
.../src/main/resources/app/pages/Query.tsx | 38 +-
.../src/main/resources/package-lock.json | 14047 ++++++++++++++++++-
pinot-controller/src/main/resources/package.json | 3 +-
.../pinot/controller/helix/ControllerTest.java | 5 +-
.../controller/helix/SegmentStatusCheckerTest.java | 24 +-
.../PinotHelixResourceManagerStatelessTest.java | 4 +
pinot-core/pom.xml | 24 +-
.../evaluators/DefaultJsonPathEvaluator.java | 89 +-
.../manager/realtime/IngestionDelayTracker.java | 2 +
.../realtime/RealtimeSegmentDataManager.java | 52 +-
.../manager/realtime/RealtimeTableDataManager.java | 13 +-
.../core/operator/filter/FilterOperatorUtils.java | 22 +-
.../filter/H3InclusionIndexFilterOperator.java | 34 +-
.../org/apache/pinot/core/plan/FilterPlanNode.java | 10 +-
.../core/plan/maker/InstancePlanMakerImplV2.java | 2 +
.../function/AggregationFunctionFactory.java | 4 +-
.../BaseSingleInputAggregationFunction.java | 21 +
.../function/ModeAggregationFunction.java | 147 +-
.../NullableSingleInputAggregationFunction.java | 141 +
.../core/query/request/context/QueryContext.java | 19 +
.../framework/SegmentProcessorFramework.java | 2 +
.../segment/processing/mapper/SegmentMapper.java | 4 +
.../core/transport/ChannelHandlerFactory.java | 2 +-
.../pinot/core/transport/grpc/GrpcQueryServer.java | 4 +-
.../routing/stats/ServerRoutingStatsManager.java | 13 +-
.../apache/pinot/core/util/ListenerConfigUtil.java | 5 +-
.../test/java/org/apache/pinot/core/NettyTest.java | 59 +
.../evaluators/DefaultJsonPathEvaluatorTest.java | 146 +
.../function/ModeAggregationFunctionTest.java | 273 +
.../framework/SegmentProcessorFrameworkTest.java | 17 +-
.../pinot/core/transport/QueryRoutingTest.java | 2 +-
.../stats/ServerRoutingStatsManagerTest.java | 39 +-
.../apache/pinot/queries/AllNullQueriesTest.java | 729 +-
.../pinot/queries/NullEnabledQueriesTest.java | 6 +-
.../apache/pinot/queries/TransformQueriesTest.java | 2 +-
pinot-distribution/pom.xml | 2 +-
pinot-integration-test-base/pom.xml | 2 +-
.../pinot/integration/tests/ClusterTest.java | 20 +-
.../pinot/integration/tests/NettyLeakListener.java | 58 +
.../integration/tests/NettyTestNGListener.java | 49 +
pinot-integration-tests/pom.xml | 2 +-
.../ControllerPeriodicTasksIntegrationTest.java | 39 +-
.../tests/OfflineClusterIntegrationTest.java | 101 +-
.../integration/tests/TlsIntegrationTest.java | 2 +-
.../tests/UpsertTableIntegrationTest.java | 8 +-
pinot-minion/pom.xml | 2 +-
.../org/apache/pinot/minion/BaseMinionStarter.java | 2 +-
.../pinot/minion/MinionAdminApiApplication.java | 5 +
.../minion/api/resources/HealthCheckResource.java | 34 +
pinot-perf/pom.xml | 2 +-
.../perf/AbstractAggregationFunctionBenchmark.java | 217 +
.../pinot/perf/BenchmarkModeAggregation.java | 175 +
.../apache/pinot/perf/SyntheticBlockValSets.java | 256 +
.../pinot/perf/SyntheticNullBitmapFactories.java | 89 +
.../pinot-batch-ingestion-common/pom.xml | 2 +-
.../pinot-batch-ingestion-hadoop/pom.xml | 2 +-
.../pinot-batch-ingestion-spark-2.4/pom.xml | 2 +-
.../pinot-batch-ingestion-spark-3/pom.xml | 2 +-
.../pinot-batch-ingestion-standalone/pom.xml | 2 +-
pinot-plugins/pinot-batch-ingestion/pom.xml | 2 +-
.../pinot-environment/pinot-azure/pom.xml | 2 +-
pinot-plugins/pinot-environment/pom.xml | 2 +-
pinot-plugins/pinot-file-system/pinot-adls/pom.xml | 2 +-
pinot-plugins/pinot-file-system/pinot-gcs/pom.xml | 2 +-
pinot-plugins/pinot-file-system/pinot-hdfs/pom.xml | 2 +-
pinot-plugins/pinot-file-system/pinot-s3/pom.xml | 2 +-
pinot-plugins/pinot-file-system/pom.xml | 2 +-
.../pinot-input-format/pinot-avro-base/pom.xml | 2 +-
.../inputformat/avro/AvroRecordExtractor.java | 10 +-
.../pinot-input-format/pinot-avro/pom.xml | 2 +-
.../pinot-input-format/pinot-clp-log/pom.xml | 2 +-
.../pinot-confluent-avro/pom.xml | 2 +-
pinot-plugins/pinot-input-format/pinot-csv/pom.xml | 2 +-
.../pinot-input-format/pinot-json/pom.xml | 2 +-
pinot-plugins/pinot-input-format/pinot-orc/pom.xml | 2 +-
.../pinot-input-format/pinot-parquet/pom.xml | 2 +-
.../parquet/ParquetAvroRecordExtractor.java | 62 +
.../parquet/ParquetAvroRecordReader.java | 6 +-
.../parquet/ParquetNativeRecordExtractor.java | 10 +-
.../plugin/inputformat/parquet/ParquetUtils.java | 3 +
.../parquet/ParquetRecordReaderTest.java | 1 +
.../src/test/resources/int96AvroParquet.parquet | Bin 0 -> 19853 bytes
.../pinot-input-format/pinot-protobuf/pom.xml | 2 +-
.../pinot-input-format/pinot-thrift/pom.xml | 2 +-
pinot-plugins/pinot-input-format/pom.xml | 2 +-
.../pinot-metrics/pinot-dropwizard/pom.xml | 2 +-
pinot-plugins/pinot-metrics/pinot-yammer/pom.xml | 2 +-
pinot-plugins/pinot-metrics/pom.xml | 2 +-
.../pinot-minion-builtin-tasks/pom.xml | 2 +-
pinot-plugins/pinot-minion-tasks/pom.xml | 2 +-
.../pinot-segment-uploader-default/pom.xml | 2 +-
pinot-plugins/pinot-segment-uploader/pom.xml | 2 +-
.../pinot-segment-writer-file-based/pom.xml | 2 +-
pinot-plugins/pinot-segment-writer/pom.xml | 2 +-
.../pinot-stream-ingestion/pinot-kafka-2.0/pom.xml | 2 +-
.../pinot-kafka-base/pom.xml | 2 +-
.../pinot-stream-ingestion/pinot-kinesis/pom.xml | 2 +-
.../pinot-stream-ingestion/pinot-pulsar/pom.xml | 2 +-
pinot-plugins/pinot-stream-ingestion/pom.xml | 2 +-
pinot-plugins/pom.xml | 2 +-
pinot-query-planner/pom.xml | 2 +-
pinot-query-runtime/pom.xml | 2 +-
.../runtime/blocks/TransferableBlockUtils.java | 3 +-
.../runtime/operator/exchange/BlockExchange.java | 39 +-
.../query/service/dispatch/QueryDispatcher.java | 25 +-
pinot-segment-local/pom.xml | 5 +-
.../record/enricher/clp/CLPEncodingEnricher.java | 100 +
.../enricher/clp/CLPEncodingEnricherFactory.java | 51 +
.../record/enricher/clp/ClpEnricherConfig.java | 23 +-
.../enricher/function/CustomFunctionEnricher.java | 66 +
.../function/CustomFunctionEnricherConfig.java | 23 +-
.../function/CustomFunctionEnricherFactory.java | 61 +
.../converter/RealtimeSegmentConverter.java | 4 +-
.../RecordReaderSegmentCreationDataSource.java | 9 +
.../creator/impl/SegmentColumnarIndexCreator.java | 76 +-
.../impl/SegmentIndexCreationDriverImpl.java | 12 +-
.../ColumnMinMaxValueGenerator.java | 373 +-
.../apache/pinot/segment/local/utils/H3Utils.java | 91 +-
.../pinot/segment/local/utils/IngestionUtils.java | 8 +-
.../segment/local/utils/TableConfigUtils.java | 26 +
.../impl/SegmentColumnarIndexCreatorTest.java | 82 -
.../segment/local/utils/TableConfigUtilsTest.java | 40 +-
pinot-segment-spi/pom.xml | 2 +-
.../pinot/segment/spi/datasource/DataSource.java | 7 +
pinot-server/pom.xml | 2 +-
.../pinot/server/api/AdminApiApplication.java | 5 +
.../server/api/resources/HealthCheckResource.java | 34 +
.../pinot/server/starter/ServerInstance.java | 2 +-
.../server/starter/helix/BaseServerStarter.java | 8 +-
.../helix/SegmentMessageHandlerFactory.java | 20 +
pinot-spi/pom.xml | 2 +-
.../spi/annotations/RecordEnricherFactory.java | 13 +-
.../config/table/ingestion/EnrichmentConfig.java | 49 +
.../config/table/ingestion/IngestionConfig.java | 14 +
.../spi/data/readers/RecordReaderFileConfig.java | 25 +-
.../pinot/spi/recordenricher/RecordEnricher.java | 23 +-
.../spi/recordenricher/RecordEnricherConfig.java | 6 +-
.../spi/recordenricher/RecordEnricherFactory.java | 12 +-
.../spi/recordenricher/RecordEnricherPipeline.java | 75 +
.../spi/recordenricher/RecordEnricherRegistry.java | 62 +
.../RecordEnricherValidationConfig.java | 18 +-
.../apache/pinot/spi/utils/CommonConstants.java | 3 +
.../utils/builder/ControllerRequestURLBuilder.java | 8 +
pinot-tools/pom.xml | 2 +-
.../org/apache/pinot/tools/BootstrapTableTool.java | 2 +-
.../pinot/tools/admin/PinotAdministrator.java | 2 +
.../command/LaunchDataIngestionJobCommand.java | 2 +-
.../pinot/tools/streams/PinotRealtimeSource.java | 2 +-
pom.xml | 38 +-
226 files changed, 19325 insertions(+), 1872 deletions(-)
create mode 100644 licenses-binary/LICENSE-go.txt
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/api/resources/PinotClientRequestTest.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/utils/tls/JvmDefaultSslContext.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/utils/tls/RenewableTlsUtils.java
rename pinot-common/src/main/java/org/apache/pinot/common/utils/{ =>
tls}/TlsUtils.java (52%)
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/assignment/InstanceAssignmentConfigUtilsTest.java
copy
pinot-common/src/{main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=> test/java/org/apache/pinot/common/utils/TestClock.java} (52%)
rename pinot-common/src/test/java/org/apache/pinot/common/utils/{ =>
tls}/TlsUtilsTest.java (90%)
create mode 100644 pinot-controller/package-lock.json
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/NullableSingleInputAggregationFunction.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/NettyTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/common/evaluators/DefaultJsonPathEvaluatorTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/ModeAggregationFunctionTest.java
create mode 100644
pinot-integration-test-base/src/test/java/org/apache/pinot/integration/tests/NettyLeakListener.java
create mode 100644
pinot-integration-test-base/src/test/java/org/apache/pinot/integration/tests/NettyTestNGListener.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/AbstractAggregationFunctionBenchmark.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/BenchmarkModeAggregation.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/SyntheticBlockValSets.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/SyntheticNullBitmapFactories.java
create mode 100644
pinot-plugins/pinot-input-format/pinot-parquet/src/main/java/org/apache/pinot/plugin/inputformat/parquet/ParquetAvroRecordExtractor.java
create mode 100644
pinot-plugins/pinot-input-format/pinot-parquet/src/test/resources/int96AvroParquet.parquet
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/plugin/record/enricher/clp/CLPEncodingEnricher.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/plugin/record/enricher/clp/CLPEncodingEnricherFactory.java
copy
pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=>
pinot-segment-local/src/main/java/org/apache/pinot/plugin/record/enricher/clp/ClpEnricherConfig.java
(62%)
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/plugin/record/enricher/function/CustomFunctionEnricher.java
copy
pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=>
pinot-segment-local/src/main/java/org/apache/pinot/plugin/record/enricher/function/CustomFunctionEnricherConfig.java
(54%)
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/plugin/record/enricher/function/CustomFunctionEnricherFactory.java
copy
pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/annotations/RecordEnricherFactory.java
(72%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/config/table/ingestion/EnrichmentConfig.java
copy
pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricher.java
(56%)
copy
pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricherConfig.java
(84%)
copy
pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricherFactory.java
(68%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricherPipeline.java
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricherRegistry.java
copy
pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/recordenricher/RecordEnricherValidationConfig.java
(66%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
