This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch mutable_off_heap
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
discard 08744b6 Optimize MutableOffHeapByteArrayStore by directly calling the
PinotDataBuffer API
add 3eef6ea Update quick_start.rst (#4319)
add 9497a75 [TE] Fix doc - add import sql url, disable pinot build (#4357)
add 81f433f Raise the threshold of using MMAP for inverted index creation
from 100M to 2G (#4358)
add 859c68c [TE] Tuning of Composite alert - Store metric refs in
component spec (#4359)
add b75a4c0 Adding support for udfs in Selection (#4346)
add ab6dd9f [TE] Trigger expression based grouping of anomalies - AND, OR
and combinations (#4354)
add 4ce688e [TE] update detection health (#4364)
add 866e29a Adding util methods for controller that will be used in
offline push (#4360)
add 39811df [TE] frontend - harleyjj/alert-overview - dont use anomalies
from bounds endpoint in Alert Overview (#4366)
add 49902ae [TE] set detection window based on detection granularity
(#4352)
add 583548c [TE] Bug Fix - Inject the correct metric ref in component
spec (#4369)
add db7cd63 [TE] Update name for entity anomalies (#4370)
add 6250aee Optimize MutableOffHeapByteArrayStore by directly calling the
PinotDataBuffer API
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 (08744b6)
\
N -- N -- N refs/heads/mutable_off_heap (6250aee)
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:
.../common}/function/AggregationFunctionType.java | 5 +-
.../FunctionDefinitionRegistry.java} | 21 +-
.../common/utils/FileUploadDownloadClient.java | 41 +++
.../pinot/common/utils/request/RequestUtils.java | 3 +-
.../parsers/PinotQuery2BrokerRequestConverter.java | 19 +-
.../pinot/pql/parsers/pql2/ast/OrderByAstNode.java | 5 +-
.../pql/parsers/pql2/ast/OutputColumnAstNode.java | 20 +-
.../core/data/aggregator/AvgValueAggregator.java | 2 +-
.../core/data/aggregator/CountValueAggregator.java | 2 +-
.../DistinctCountHLLValueAggregator.java | 2 +-
.../core/data/aggregator/MaxValueAggregator.java | 2 +-
.../aggregator/MinMaxRangeValueAggregator.java | 2 +-
.../core/data/aggregator/MinValueAggregator.java | 2 +-
.../aggregator/PercentileEstValueAggregator.java | 2 +-
.../PercentileTDigestValueAggregator.java | 2 +-
.../core/data/aggregator/SumValueAggregator.java | 2 +-
.../core/data/aggregator/ValueAggregator.java | 2 +-
.../data/aggregator/ValueAggregatorFactory.java | 2 +-
.../query/DictionaryBasedAggregationOperator.java | 2 +-
.../query/MetadataBasedAggregationOperator.java | 2 +-
.../core/operator/query/SelectionOnlyOperator.java | 109 -------
.../core/operator/query/SelectionOperator.java | 282 +++++++++++++++++
.../operator/query/SelectionOrderByOperator.java | 116 -------
.../transform/TransformBlockDataFetcher.java | 340 +++++++++++++++++++++
.../core/operator/transform/TransformOperator.java | 13 +-
.../plan/MetadataBasedAggregationPlanNode.java | 2 +-
.../apache/pinot/core/plan/SelectionPlanNode.java | 38 +--
.../apache/pinot/core/plan/TransformPlanNode.java | 50 ++-
.../core/plan/maker/InstancePlanMakerImplV2.java | 2 +-
.../aggregation/DefaultAggregationExecutor.java | 2 +-
.../aggregation/function/AggregationFunction.java | 1 +
.../function/AggregationFunctionFactory.java | 1 +
.../function/AggregationFunctionUtils.java | 1 +
.../function/AvgAggregationFunction.java | 1 +
.../function/AvgMVAggregationFunction.java | 1 +
.../function/CountAggregationFunction.java | 1 +
.../function/CountMVAggregationFunction.java | 1 +
.../function/DistinctCountAggregationFunction.java | 1 +
.../DistinctCountHLLAggregationFunction.java | 1 +
.../DistinctCountHLLMVAggregationFunction.java | 1 +
.../DistinctCountMVAggregationFunction.java | 1 +
.../DistinctCountRawHLLAggregationFunction.java | 1 +
.../DistinctCountRawHLLMVAggregationFunction.java | 1 +
.../function/FastHLLAggregationFunction.java | 1 +
.../function/MaxAggregationFunction.java | 1 +
.../function/MaxMVAggregationFunction.java | 1 +
.../function/MinAggregationFunction.java | 1 +
.../function/MinMVAggregationFunction.java | 1 +
.../function/MinMaxRangeAggregationFunction.java | 1 +
.../function/MinMaxRangeMVAggregationFunction.java | 1 +
.../function/PercentileAggregationFunction.java | 1 +
.../function/PercentileEstAggregationFunction.java | 1 +
.../PercentileEstMVAggregationFunction.java | 1 +
.../function/PercentileMVAggregationFunction.java | 1 +
.../PercentileTDigestAggregationFunction.java | 1 +
.../PercentileTDigestMVAggregationFunction.java | 1 +
.../function/SumAggregationFunction.java | 1 +
.../function/SumMVAggregationFunction.java | 1 +
.../groupby/DefaultGroupByExecutor.java | 2 +-
.../core/query/request/ServerQueryRequest.java | 18 +-
.../query/selection/SelectionOperatorUtils.java | 4 +-
.../inv/OffHeapBitmapInvertedIndexCreator.java | 4 +-
.../executor/StarTreeAggregationExecutor.java | 2 +-
.../startree/executor/StarTreeGroupByExecutor.java | 2 +-
.../startree/plan/StarTreeTransformPlanNode.java | 3 +-
.../startree/v2/AggregationFunctionColumnPair.java | 2 +-
.../startree/v2/builder/BaseSingleTreeBuilder.java | 2 +-
.../startree/v2/store/StarTreeLoaderUtils.java | 2 +-
.../function/AggregationFunctionFactoryTest.java | 1 +
.../function/AggregationFunctionTypeTest.java | 1 +
.../v2/AggregationFunctionColumnPairTest.java | 2 +-
.../pinot/core/startree/v2/BaseStarTreeV2Test.java | 2 +-
...InnerSegmentSelectionMultiValueQueriesTest.java | 123 +++++---
...nnerSegmentSelectionSingleValueQueriesTest.java | 146 +++++----
.../DefaultAggregationExecutorTest.java | 2 +-
.../apache/pinot/hadoop/job/ControllerRestApi.java | 4 +
.../pinot/hadoop/job/DefaultControllerRestApi.java | 50 +++
.../DeleteAPIHybridClusterIntegrationTest.java | 23 ++
.../tests/OfflineClusterIntegrationTest.java | 86 +++++-
.../tests/StarTreeV2ClusterIntegrationTest.java | 2 +-
.../pinot/perf/BenchmarkPinotDataBuffer.java | 137 +++++++++
thirdeye/docs/import_sql_metric.rst | 7 +-
thirdeye/docs/production.rst | 4 +-
thirdeye/docs/quick_start.rst | 10 +-
thirdeye/install.sh | 10 +-
.../app/pods/components/alert-details/component.js | 7 +-
thirdeye/thirdeye-frontend/app/utils/anomaly.js | 11 +-
.../thirdeye-frontend/app/utils/api/anomaly.js | 6 +-
.../config/data-sources/data-sources-config.yml | 2 +-
.../thirdeye/detection/DetectionPipeline.java | 2 +-
.../pinot/thirdeye/detection/DetectionUtils.java | 57 ++++
.../components/TriggerConditionGrouper.java | 202 ++++++++++++
.../thirdeye/detection/health/DetectionHealth.java | 6 +-
.../detection/health/DetectionTaskStatus.java | 31 +-
...rSpec.java => TriggerConditionGrouperSpec.java} | 40 ++-
.../thirdeye/detection/wrapper/GrouperWrapper.java | 13 +-
.../detection/yaml/DetectionConfigTuner.java | 41 +--
.../yaml/translator/DetectionConfigTranslator.java | 99 +++---
.../components/TriggerConditionGrouperTest.java | 230 ++++++++++++++
.../detection/health/DetectionHealthTest.java | 3 +
.../yaml/translator/pipeline-config-5.yaml | 4 +-
101 files changed, 1979 insertions(+), 548 deletions(-)
rename {pinot-core/src/main/java/org/apache/pinot/core/query/aggregation =>
pinot-common/src/main/java/org/apache/pinot/common}/function/AggregationFunctionType.java
(93%)
copy
pinot-common/src/main/java/org/apache/pinot/common/{data/DateTimeFieldSpecChildKeyHandler.java
=> function/FunctionDefinitionRegistry.java} (70%)
delete mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/query/SelectionOnlyOperator.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/query/SelectionOperator.java
delete mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/query/SelectionOrderByOperator.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/transform/TransformBlockDataFetcher.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/BenchmarkPinotDataBuffer.java
create mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/components/TriggerConditionGrouper.java
copy
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/spec/{MockGrouperSpec.java
=> TriggerConditionGrouperSpec.java} (50%)
create mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/components/TriggerConditionGrouperTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
