This is an automated email from the ASF dual-hosted git repository.
snlee pushed a change to branch add-variance-function
in repository https://gitbox.apache.org/repos/asf/pinot.git
discard a0587bfba4 Add Variance and Standard Deviation Aggregation Functions
add 99fc894585 add json config to not wrap automatically (#9827)
add f2b56d9788 [Multistage][Testing] Integration test for general
aggregate functions. (#9811)
add 6cfa6dca8b Download offline segments from peers (#9710)
add 69ad81b616 Thread Level Usage Accounting and Query Killing on Server
(#9727)
add 32314bb433 Fix Spark connector empty datatable handling in GRPC reader
(#9837)
add d62a867d46 Add max merger and min mergers for partial upsert (#9665)
add 214095425e Do not create dictionary for high-cardinality columns
(#9527)
add caa5dbc4ef #9518 added pinot helm 0.2.6 with secure version pinot
0.11.0 (#9519)
add 0d3e4a3cff Fix a typo in JsonExtractKeyTransformFunction (#9856)
add 555e5a0443 Combine the read access for replication config (#9849)
add 0c673299b0 ADLS file system upgrade (#9855)
add 4303ad9d82 add v1 ingress in helm chart (#9862)
add aa839c97b5 Adding new ADLSPinotFS auth type: DEFAULT (#9860)
add 27d4c3ee27 [multistage] [testing] Mailbox receive operator test (#9778)
add 837aff94a6 [hotfix] fix type hoisting (#9829)
add 6ef4dfc500 [multistage] m0ar tests! (binary, boolean, char, time)
(#9818)
add 375b7d0269 [multistage][test] add table expression tests (#9817)
add 86f923de45 Support Avro's Fixed data type (#9642)
add 03ce7d3bd9 Optimize AdaptiveServerSelection for replicaGroup based
routing (#9803)
add 443b8c542c Clean up transform functions (#9858)
add d458668690 Do not sort the instances in InstancePartitions (#9866)
add 26a83ba4f3 [bugfix] fix mergeRollupTask metrics (#9864)
add e41bdd0c6f [multistage] Add Multi Stage Strict Replica Group Routing
Strategy (#9808)
add 74e13b1aa0 Merge new columns in existing record with default merge
strategy (#9851)
add ca4c16cc61 [multistage][testing] Add some having test case (#9833)
add d50f9ee8b0 Fix a typo in
ScalarTransformFunctionWrapperTest.testStringSplitPartTransformFunction()
(#9871)
add a22250270d [multistage] test coverage for CASE and fix bug with CHAR
literals (#9846)
add 4198af7016 remove json file requirement (#9879)
add 28f337a6af Bug fix: Get correct primary key count (#9876)
add 99d2eb84c9 Bump spotless-maven-plugin from 2.9.0 to 2.28.0 (#9877)
add 9bd420fc4a [multistage][hotfix] shuffle rewrite (#9870)
add 6210f43ca0 Disable Dictionary (#9868)
add 041865a80f [multistage] support sort push-down (#9832)
add 0a6d84391d support BOOL_AND and BOOL_OR aggregate functions (#9848)
add 2dae95127d #9834 Added Delete Schema/Table pinot admin commands (#9857)
add f6f59ebedf Fix issues for realtime table reload (#9885)
add b4faa4e43a initial commit to add timeoutMs from broker and from query
options (#9571)
add 9690b2dcdc Use Pulsar AdminClient to delete unused subscriptions
(#9859)
add 716797fca1 UI: fix segment status color remains same in different
table page (#9891)
add 568d858f16 Fix bloom filter creation on BYTES (#9898)
add 42354206b7 Add memory optimized dimension table (#9802)
add 9b8809fea5 add table sort function for table size (#9844)
add 85e413ebe8 In Kafka consumer, seek offset only when needed (#9896)
add 4ae6d35ff1 [hotfix] broker selection not using table name (#9902)
add ecf41be2ec [multistage][test] add with statement test (#9826)
add d5211a1439 [multistage][testing] Basic math func test and some more
between test (#9850)
add e883ed55e5 [multistage] add tests for string functions (#9901)
add 31333da7b9 Add Variance and Standard Deviation Aggregation Functions
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 (a0587bfba4)
\
N -- N -- N refs/heads/add-variance-function (31333da7b9)
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:
config/codestyle-intellij.xml | 4 +
kubernetes/helm/index.yaml | 28 +
kubernetes/helm/pinot-0.2.6.tgz | Bin 0 -> 60818 bytes
kubernetes/helm/pinot/Chart.yaml | 4 +-
.../helm/pinot/templates/broker/ingress.yaml | 34 +
.../helm/pinot/templates/controller/ingress.yaml | 34 +
kubernetes/helm/pinot/values.yaml | 12 +-
.../broker/api/resources/PinotBrokerDebug.java | 15 +-
.../requesthandler/BaseBrokerRequestHandler.java | 4 +-
.../MultiStageBrokerRequestHandler.java | 12 +-
.../pinot/broker/routing/BrokerRoutingManager.java | 13 +-
.../AdaptiveServerSelector.java | 10 +
.../adaptiveserverselector/HybridSelector.java | 28 +
.../adaptiveserverselector/LatencySelector.java | 28 +
.../NumInFlightReqSelector.java | 26 +
.../instanceselector/BaseInstanceSelector.java | 10 +-
.../routing/instanceselector/InstanceSelector.java | 7 +-
.../instanceselector/InstanceSelectorFactory.java | 11 +-
.../MultiStageReplicaGroupSelector.java | 150 +++++
.../ReplicaGroupInstanceSelector.java | 23 +-
.../broker/broker/HelixBrokerStarterTest.java | 7 +-
.../BaseBrokerRequestHandlerTest.java | 2 +-
.../AdaptiveServerSelectorTest.java | 84 +++
.../instanceselector/InstanceSelectorTest.java | 277 ++++++---
.../java/org/apache/pinot/client/Connection.java | 37 +-
.../apache/pinot/client/PreparedStatementTest.java | 30 +
pinot-common/pom.xml | 2 +-
.../assignment/InstanceAssignmentConfigUtils.java | 2 +-
.../pinot/common/datablock/BaseDataBlock.java | 4 +-
.../pinot/common/datablock/DataBlockUtils.java | 1 +
.../pinot/common/datatable/DataTableImplV3.java | 8 +-
.../pinot/common/datatable/DataTableImplV4.java | 6 +-
.../common/function/scalar/StringFunctions.java | 39 +-
.../apache/pinot/common/metrics/ServerGauge.java | 3 +-
.../apache/pinot/common/metrics/ServerMeter.java | 3 +
.../apache/pinot/common/metrics/ServerMetrics.java | 19 +
.../pinot/common/request/context/ThreadTimer.java | 56 --
.../org/apache/pinot/common/utils/DataSchema.java | 17 +
.../common/utils/FileUploadDownloadClient.java | 33 +-
.../common/utils/config/TableConfigUtils.java | 13 +-
.../utils/fetcher/SegmentFetcherFactory.java | 27 +
.../apache/pinot/common/utils/DataSchemaTest.java | 28 +
.../pinot/common/utils/config/TableConfigTest.java | 68 +-
.../connector/PinotGrpcServerDataFetcher.scala | 16 +-
.../spark/ExampleSparkPinotConnectorTest.scala | 16 +
.../pinot-common-jdk8/pom.xml | 2 +-
.../api/resources/PinotTableRestletResource.java | 5 +-
.../controller/helix/SegmentStatusChecker.java | 7 +-
.../helix/core/PinotHelixResourceManager.java | 13 +-
.../helix/core/PinotTableIdealStateBuilder.java | 16 +-
.../InstanceReplicaGroupPartitionSelector.java | 2 -
.../assignment/segment/BaseSegmentAssignment.java | 7 +-
.../segment/OfflineSegmentAssignment.java | 6 -
.../segment/RealtimeSegmentAssignment.java | 6 -
.../BalancedNumSegmentAssignmentStrategy.java | 7 +-
.../ReplicaGroupSegmentAssignmentStrategy.java | 6 +-
.../realtime/PinotLLCRealtimeSegmentManager.java | 2 +-
.../app/components/SegmentStatusRenderer.tsx | 2 +-
.../src/main/resources/app/components/Table.tsx | 21 +-
.../src/main/resources/app/interfaces/types.d.ts | 2 +
.../src/main/resources/app/utils/SortFunctions.tsx | 49 ++
.../api/PinotTableRestletResourceTest.java | 5 +-
.../api/TableConfigsRestletResourceTest.java | 4 +-
.../controller/helix/PinotResourceManagerTest.java | 7 +-
.../instance/InstanceAssignmentTest.java | 241 +++----
...altimeNonReplicaGroupSegmentAssignmentTest.java | 7 +-
...NonReplicaGroupTieredSegmentAssignmentTest.java | 5 +-
.../RealtimeReplicaGroupSegmentAssignmentTest.java | 5 +-
.../SegmentAssignmentStrategyFactoryTest.java | 12 +-
.../TableRebalancerClusterStatelessTest.java | 15 +-
.../helix/core/retention/RetentionManagerTest.java | 8 +-
pinot-core/pom.xml | 2 +-
.../CPUMemThreadLevelAccountingObjects.java | 123 ++++
.../HeapUsagePublishingAccountantFactory.java | 72 +++
.../PerQueryCPUMemAccountantFactory.java | 691 +++++++++++++++++++++
.../utils/RunnerWorkerThreadOffsetProvider.java} | 51 +-
.../core/common/datablock/DataBlockBuilder.java | 6 +-
.../core/data/manager/BaseTableDataManager.java | 42 +-
.../core/data/manager/offline/DimensionTable.java | 36 +-
.../manager/offline/DimensionTableDataManager.java | 85 ++-
...ionTable.java => FastLookupDimensionTable.java} | 30 +-
.../manager/offline/LookupRecordLocation.java} | 41 +-
.../offline/MemoryOptimizedDimensionTable.java | 93 +++
.../manager/realtime/RealtimeTableDataManager.java | 10 +-
.../apache/pinot/core/operator/BaseOperator.java | 6 +-
.../pinot/core/operator/DocIdSetOperator.java | 4 +
.../core/operator/InstanceResponseOperator.java | 8 +-
.../core/operator/combine/BaseCombineOperator.java | 21 +-
.../operator/combine/GroupByCombineOperator.java | 13 +-
.../function/AdditionTransformFunction.java | 30 +-
.../function/ArrayAverageTransformFunction.java | 17 +-
.../function/ArrayLengthTransformFunction.java | 19 +-
.../function/ArrayMaxTransformFunction.java | 25 +-
.../function/ArrayMinTransformFunction.java | 29 +-
.../function/ArraySumTransformFunction.java | 11 +-
.../transform/function/BaseTransformFunction.java | 3 +
.../function/BinaryOperatorTransformFunction.java | 84 +--
.../transform/function/CaseTransformFunction.java | 75 +--
.../function/CoalesceTransformFunction.java | 64 +-
.../DateTimeConversionTransformFunction.java | 74 +--
.../function/DateTimeTransformFunction.java | 15 +-
.../function/DateTruncTransformFunction.java | 14 +-
.../function/DistinctFromTransformFunction.java | 18 +-
.../function/DivisionTransformFunction.java | 37 +-
.../function/ExtractTransformFunction.java | 8 +-
.../function/GreatestTransformFunction.java | 12 +-
.../function/GroovyTransformFunction.java | 192 +++---
.../function/InIdSetTransformFunction.java | 21 +-
.../function/IsNotNullTransformFunction.java | 15 +-
.../function/IsNullTransformFunction.java | 15 +-
.../function/JsonExtractKeyTransformFunction.java | 4 +-
.../JsonExtractScalarTransformFunction.java | 83 +--
.../transform/function/LeastTransformFunction.java | 12 +-
.../function/MapValueTransformFunction.java | 4 +-
.../function/ModuloTransformFunction.java | 20 +-
.../function/MultiplicationTransformFunction.java | 35 +-
.../function/NotOperatorTransformFunction.java | 9 +-
.../transform/function/PowerTransformFunction.java | 4 +-
.../function/RegexpExtractTransformFunction.java | 18 +-
.../function/RoundDecimalTransformFunction.java | 5 +-
.../function/SingleParamMathTransformFunction.java | 32 +-
.../function/SubtractionTransformFunction.java | 37 +-
.../function/TimeConversionTransformFunction.java | 11 +-
.../function/TransformFunctionFactory.java | 2 +
.../function/TruncateDecimalTransformFunction.java | 5 +-
.../function/ValueInTransformFunction.java | 53 +-
.../apache/pinot/core/plan/DocIdSetPlanNode.java | 2 +-
.../query/aggregation/AggregationResultHolder.java | 13 +
.../aggregation/DoubleAggregationResultHolder.java | 15 +
...ltHolder.java => IntAggregateResultHolder.java} | 44 +-
.../aggregation/ObjectAggregationResultHolder.java | 16 +
.../function/AggregationFunctionFactory.java | 4 +
.../function/BaseBooleanAggregationFunction.java | 252 ++++++++
.../BooleanAndAggregationFunction.java} | 42 +-
.../BooleanOrAggregationFunction.java} | 42 +-
.../groupby/DoubleGroupByResultHolder.java | 10 +
.../aggregation/groupby/GroupByResultHolder.java | 19 +
...sultHolder.java => IntGroupByResultHolder.java} | 33 +-
.../groupby/ObjectGroupByResultHolder.java | 12 +
.../pinot/core/query/distinct/DistinctTable.java | 6 +
.../query/executor/ServerQueryExecutorV1Impl.java | 51 +-
.../core/query/reduce/GroupByDataTableReducer.java | 88 ++-
.../pinot/core/query/scheduler/QueryScheduler.java | 255 ++++----
.../query/scheduler/resources/ResourceManager.java | 12 +-
.../query/selection/SelectionOperatorService.java | 20 +-
.../query/selection/SelectionOperatorUtils.java | 24 +
.../apache/pinot/core/routing/RoutingManager.java | 2 +-
.../core/transport/InstanceRequestHandler.java | 2 +-
.../pinot/core/util/PeerServerSegmentFinder.java | 4 +
.../accounting/ResourceManagerAccountingTest.java | 370 +++++++++++
.../pinot/core/accounting/TestThreadMXBean.java | 211 +++++++
.../core/common/datatable/DataTableSerDeTest.java | 28 +-
.../data/manager/BaseTableDataManagerTest.java | 96 ++-
.../offline/DimensionTableDataManagerTest.java | 57 ++
.../JsonExtractScalarTransformFunctionTest.java | 25 +-
.../ScalarTransformFunctionWrapperTest.java | 4 +-
.../function/AggregationFunctionFactoryTest.java | 14 +
.../pinot/queries/BooleanAggQueriesTest.java | 257 ++++++++
.../ForwardIndexHandlerReloadQueriesTest.java | 275 +++++---
...nnerSegmentSelectionSingleValueQueriesTest.java | 8 +-
.../queries/JsonIngestionFromAvroQueriesTest.java | 54 +-
.../tests/LLCRealtimeClusterIntegrationTest.java | 7 +-
.../tests/OfflineClusterQueryKillingTest.java | 279 +++++++++
.../perf/BenchmarkThreadInterruptionCheck.java | 128 +++-
...a => BenchmarkThreadResourceUsageProvider.java} | 45 +-
pinot-plugins/pinot-file-system/pinot-adls/pom.xml | 2 +-
.../pinot/plugin/filesystem/ADLSGen2PinotFS.java | 62 +-
.../filesystem/test/ADLSGen2PinotFSTest.java | 51 +-
.../inputformat/avro/AvroRecordExtractor.java | 4 +
.../inputformat/avro/AvroRecordExtractorTest.java | 226 +++++++
.../mergerollup/MergeRollupTaskGenerator.java | 43 +-
.../kafka20/KafkaPartitionLevelConsumer.java | 29 +-
.../pulsar/PulsarStreamMetadataProvider.java | 76 +--
.../rel/rules/ImmutableSortExchangeCopyRule.java | 414 ++++++++++++
.../PinotAggregateExchangeNodeInsertRule.java | 2 +-
.../calcite/rel/rules/PinotQueryRuleSets.java | 9 +-
.../rel/rules/PinotSortExchangeCopyRule.java | 114 ++++
.../rel/rules/PinotSortExchangeNodeInsertRule.java | 18 +-
.../sql/fun/PinotBoolAndAggregateFunction.java | 39 +-
.../sql/fun/PinotBoolOrAggregateFunction.java | 39 +-
.../apache/calcite/sql/fun/PinotOperatorTable.java | 7 +
.../org/apache/pinot/query/QueryEnvironment.java | 20 +-
.../apache/pinot/query/catalog/PinotCatalog.java | 9 +-
.../query/planner/logical/RelToStageConverter.java | 5 +-
.../query/planner/logical/RexExpressionUtils.java | 10 +
.../planner/logical/ShuffleRewriteVisitor.java | 60 +-
.../pinot/query/planner/logical/StagePlanner.java | 12 +-
.../apache/pinot/query/planner/stage/SortNode.java | 4 +-
.../apache/pinot/query/routing/WorkerManager.java | 16 +-
.../org/apache/pinot/query/type/TypeFactory.java | 3 +-
.../org/apache/pinot/query/type/TypeSystem.java | 15 +-
.../rel/rules/PinotSortExchangeCopyRuleTest.java | 249 ++++++++
.../apache/pinot/query/QueryCompilationTest.java | 38 +-
.../query/testutils/MockRoutingManagerFactory.java | 2 +-
.../apache/pinot/query/runtime/QueryRunner.java | 53 +-
.../runtime/executor/OpChainSchedulerService.java | 4 +-
.../query/runtime/operator/AggregateOperator.java | 14 +
.../runtime/operator/MailboxReceiveOperator.java | 113 ++--
.../pinot/query/runtime/operator/OpChain.java | 8 +-
.../pinot/query/runtime/operator/SortOperator.java | 2 +-
.../runtime/operator/operands/FilterOperand.java | 42 +-
.../query/runtime/plan/PhysicalPlanVisitor.java | 6 +-
.../query/runtime/plan/PlanRequestContext.java | 9 +-
.../runtime/plan/ServerRequestPlanVisitor.java | 14 +-
.../plan/server/ServerPlanRequestContext.java | 6 +-
.../apache/pinot/query/service/QueryConfig.java | 29 +-
.../pinot/query/service/QueryDispatcher.java | 33 +-
.../apache/pinot/query/service/QueryServer.java | 3 +-
.../java/org/apache/pinot/query/QueryTestSet.java | 1 +
.../pinot/query/runtime/QueryRunnerTest.java | 16 +-
.../pinot/query/runtime/QueryRunnerTestBase.java | 45 +-
.../operator/MailboxReceiveOperatorTest.java | 506 +++++++++++++++
.../runtime/queries/ResourceBasedQueriesTest.java | 36 +-
.../pinot/query/service/QueryDispatcherTest.java | 2 +-
.../pinot/query/service/QueryServerTest.java | 26 +-
.../src/test/resources/queries/Aggregates.json | 215 +++++++
.../src/test/resources/queries/BinaryTypes.json | 42 ++
.../src/test/resources/queries/BooleanLogic.json | 130 ++++
.../src/test/resources/queries/Case.json | 77 +++
.../src/test/resources/queries/CharacterTypes.json | 43 ++
.../src/test/resources/queries/Comparisons.json | 42 +-
.../src/test/resources/queries/MathFuncs.json | 439 +++++++++++++
.../src/test/resources/queries/OrderBy.json | 232 +++++++
.../test/resources/queries/SelectExpressions.json | 3 +-
.../src/test/resources/queries/SelectHaving.json | 69 ++
.../test/resources/queries/StringFunctions.json | 153 +++++
.../test/resources/queries/TableExpressions.json | 110 ++++
.../src/test/resources/queries/TimeTypes.json | 72 +++
.../src/test/resources/queries/WithStatements.json | 119 ++++
.../local/data/manager/TableDataManagerConfig.java | 20 +
.../recordtransformer/DataTypeTransformer.java | 1 +
.../creator/impl/SegmentColumnarIndexCreator.java | 81 ++-
.../segment/index/loader/ForwardIndexHandler.java | 584 ++++++++++++-----
.../segment/index/loader/IndexLoadingConfig.java | 8 +-
...oncurrentMapPartitionUpsertMetadataManager.java | 2 +-
.../segment/local/upsert/PartialUpsertHandler.java | 36 +-
.../segment/local/upsert/merger/MaxMerger.java | 19 +-
.../segment/local/upsert/merger/MinMerger.java | 19 +-
.../upsert/merger/PartialUpsertMergerFactory.java | 6 +
.../segment/local/utils/TableConfigUtils.java | 14 +-
.../data/manager/TableDataManagerConfigTest.java | 54 ++
.../segment/creator/DictionaryOptimiserTest.java | 35 +-
.../index/loader/ForwardIndexHandlerTest.java | 280 +++++++--
.../index/loader/SegmentPreProcessorTest.java | 138 +++-
.../local/upsert/PartialUpsertHandlerTest.java | 5 +-
.../upsert/merger/PartialUpsertMergerTest.java | 10 +
.../pinot/segment/spi/AggregationFunctionType.java | 6 +-
.../spi/creator/SegmentGeneratorConfig.java | 11 +
.../org/apache/pinot/server/conf/ServerConf.java | 2 +-
.../pinot/server/starter/ServerInstance.java | 1 +
.../server/starter/helix/BaseServerStarter.java | 8 +-
.../helix/HelixInstanceDataManagerConfig.java | 6 +
.../spi/accounting/ThreadAccountantFactory.java | 12 +-
.../spi/accounting/ThreadExecutionContext.java | 23 +-
.../accounting/ThreadResourceUsageAccountant.java | 70 +++
.../accounting/ThreadResourceUsageProvider.java | 166 +++++
.../config/instance/InstanceDataManagerConfig.java | 2 +
.../spi/config/table/DimensionTableConfig.java | 23 +-
.../pinot/spi/config/table/IndexingConfig.java | 19 +-
.../pinot/spi/config/table/RoutingConfig.java | 1 +
.../SegmentsValidationAndRetentionConfig.java | 12 +
.../apache/pinot/spi/config/table/TableConfig.java | 43 ++
.../pinot/spi/config/table/UpsertConfig.java | 2 +-
.../java/org/apache/pinot/spi/trace/Tracing.java | 179 +++++-
.../apache/pinot/spi/utils/CommonConstants.java | 53 ++
.../java/org/apache/pinot/spi/utils/LoopUtils.java | 27 +-
.../spi/utils/builder/TableConfigBuilder.java | 11 +-
.../apache/pinot/tools/PinotNumReplicaChanger.java | 2 +-
.../pinot/tools/admin/PinotAdministrator.java | 4 +
.../tools/admin/command/DeleteSchemaCommand.java | 160 +++++
.../tools/admin/command/DeleteTableCommand.java | 183 ++++++
.../command/RealtimeProvisioningHelperCommand.java | 2 +-
pom.xml | 2 +-
273 files changed, 11234 insertions(+), 2385 deletions(-)
create mode 100644 kubernetes/helm/pinot-0.2.6.tgz
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/instanceselector/MultiStageReplicaGroupSelector.java
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/request/context/ThreadTimer.java
create mode 100644
pinot-controller/src/main/resources/app/utils/SortFunctions.tsx
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/accounting/CPUMemThreadLevelAccountingObjects.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/accounting/HeapUsagePublishingAccountantFactory.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/accounting/PerQueryCPUMemAccountantFactory.java
copy
pinot-core/src/main/java/org/apache/pinot/core/{query/aggregation/ObjectAggregationResultHolder.java
=> accounting/utils/RunnerWorkerThreadOffsetProvider.java} (50%)
copy
pinot-core/src/main/java/org/apache/pinot/core/data/manager/offline/{DimensionTable.java
=> FastLookupDimensionTable.java} (72%)
copy
pinot-core/src/main/java/org/apache/pinot/core/{operator/BaseOperator.java =>
data/manager/offline/LookupRecordLocation.java} (51%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/data/manager/offline/MemoryOptimizedDimensionTable.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/{DoubleAggregationResultHolder.java
=> IntAggregateResultHolder.java} (66%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/BaseBooleanAggregationFunction.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/{AggregationResultHolder.java
=> function/BooleanAndAggregationFunction.java} (55%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/{AggregationResultHolder.java
=> function/BooleanOrAggregationFunction.java} (55%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/groupby/{DoubleGroupByResultHolder.java
=> IntGroupByResultHolder.java} (80%)
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/accounting/ResourceManagerAccountingTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/accounting/TestThreadMXBean.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/queries/BooleanAggQueriesTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/OfflineClusterQueryKillingTest.java
rename
pinot-perf/src/main/java/org/apache/pinot/perf/{BenchmarkThreadMXBeanThreadCPUTime.java
=> BenchmarkThreadResourceUsageProvider.java} (55%)
create mode 100644
pinot-query-planner/src/main/java/org/apache/calcite/rel/rules/ImmutableSortExchangeCopyRule.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/calcite/rel/rules/PinotSortExchangeCopyRule.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/AggregationResultHolder.java
=>
pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotBoolAndAggregateFunction.java
(56%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/AggregationResultHolder.java
=>
pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotBoolOrAggregateFunction.java
(56%)
create mode 100644
pinot-query-planner/src/test/java/org/apache/calcite/rel/rules/PinotSortExchangeCopyRuleTest.java
create mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/MailboxReceiveOperatorTest.java
create mode 100644
pinot-query-runtime/src/test/resources/queries/Aggregates.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/BinaryTypes.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/BooleanLogic.json
create mode 100644 pinot-query-runtime/src/test/resources/queries/Case.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/CharacterTypes.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/MathFuncs.json
create mode 100644 pinot-query-runtime/src/test/resources/queries/OrderBy.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/SelectHaving.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/StringFunctions.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/TableExpressions.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/TimeTypes.json
create mode 100644
pinot-query-runtime/src/test/resources/queries/WithStatements.json
copy
pinot-query-planner/src/main/java/org/apache/pinot/query/type/TypeSystem.java
=>
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/MaxMerger.java
(67%)
copy
pinot-query-planner/src/main/java/org/apache/pinot/query/type/TypeSystem.java
=>
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/merger/MinMerger.java
(67%)
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/data/manager/TableDataManagerConfigTest.java
copy
pinot-query-planner/src/main/java/org/apache/pinot/query/type/TypeSystem.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/accounting/ThreadAccountantFactory.java
(74%)
copy
pinot-query-planner/src/main/java/org/apache/pinot/query/type/TypeSystem.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/accounting/ThreadExecutionContext.java
(69%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/accounting/ThreadResourceUsageAccountant.java
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/accounting/ThreadResourceUsageProvider.java
copy
pinot-query-planner/src/main/java/org/apache/pinot/query/type/TypeSystem.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/config/table/DimensionTableConfig.java
(59%)
copy pinot-core/src/main/java/org/apache/pinot/core/operator/BaseOperator.java
=> pinot-spi/src/main/java/org/apache/pinot/spi/utils/LoopUtils.java (61%)
create mode 100644
pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/DeleteSchemaCommand.java
create mode 100644
pinot-tools/src/main/java/org/apache/pinot/tools/admin/command/DeleteTableCommand.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
