This is an automated email from the ASF dual-hosted git repository.
xhsun pushed a change to branch update_merge_logic
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from 4896956 [TE] Update anomaly merge logic 1. Don't output existing
anomalies that not get merged. 2. Merge new anomaly's properties into existing
anomaly. 3. Do not split existing anomalies.
add 29b918f Randomly choose segments that need to be moved (#4191)
add d499ba1 [TE] pass predicted time series thought out the detection
pipeline (#4190)
add 578f42e In DataTypeTransformer, support filling in default null value
for empty array input (#4196)
add 18d628b Track "freshness" timestamp across consuming segments (#3979)
add b69fd30 [TE] Update anomaly merge logic 1. Don't output existing
anomalies that not get merged. 2. Merge new anomaly's properties into existing
anomaly. 3. Do not split existing anomalies.
add c3d7116 Merge branch 'update_merge_logic' of
github.com:apache/incubator-pinot into update_merge_logic
add 92ffca8 [TE] Fix unit tests
No new revisions were added by this update.
Summary of changes:
.../org/apache/pinot/common/data/FieldSpec.java | 26 ++++-----
.../apache/pinot/common/metadata/RowMetadata.java | 16 ++++--
.../response/broker/BrokerResponseNative.java | 27 ++++++++-
.../org/apache/pinot/common/utils/DataTable.java | 2 +
.../ReplicaGroupRebalanceSegmentStrategy.java | 5 ++
.../realtime/HLRealtimeSegmentDataManager.java | 7 +--
.../realtime/LLRealtimeSegmentDataManager.java | 7 +--
.../recordtransformer/DataTypeTransformer.java | 7 +--
.../core/indexsegment/mutable/MutableSegment.java | 7 ++-
.../indexsegment/mutable/MutableSegmentImpl.java | 23 ++++----
.../query/executor/ServerQueryExecutorV1Impl.java | 37 +++++++++++-
.../core/query/reduce/BrokerReduceService.java | 19 +++++++
.../impl/kafka/KafkaStreamLevelConsumer.java | 7 +--
.../pinot/core/realtime/stream/MessageBatch.java | 7 +--
.../core/realtime/stream/StreamLevelConsumer.java | 11 +---
.../core/realtime/stream/StreamMessageDecoder.java | 36 ------------
.../realtime/stream/StreamMessageMetadata.java | 25 +++------
.../recordtransformer/RecordTransformerTest.java | 18 ++++++
.../MutableSegmentImplAggregateMetricsTest.java | 2 +-
.../mutable/MutableSegmentImplTest.java | 15 ++++-
.../tests/LLCRealtimeClusterIntegrationTest.java | 4 ++
.../realtime/provisioning/MemoryEstimator.java | 5 +-
.../detection/DetectionPipelineResult.java | 34 ++++++-----
.../thirdeye/detection/DetectionResource.java | 2 +-
.../pinot/thirdeye/detection/PredictionResult.java | 65 ++++++++++++++++++++++
.../detection/algorithm/DimensionWrapper.java | 5 +-
.../thirdeye/detection/algorithm/MergeWrapper.java | 6 +-
.../thirdeye/detection/spi/model/TimeSeries.java | 9 ++-
.../detection/wrapper/AnomalyDetectorWrapper.java | 32 ++++++++++-
.../detection/wrapper/AnomalyFilterWrapper.java | 6 +-
.../thirdeye/detection/DetectionTestUtils.java | 7 +--
.../detection/algorithm/MergeWrapperTest.java | 24 ++++----
.../wrapper/AnomalyDetectorWrapperTest.java | 34 +++++++++++
33 files changed, 375 insertions(+), 162 deletions(-)
copy
pinot-controller/src/main/java/org/apache/pinot/controller/api/access/AccessControlFactory.java
=>
pinot-common/src/main/java/org/apache/pinot/common/metadata/RowMetadata.java
(72%)
create mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/PredictionResult.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
