You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by jf...@apache.org on 2018/11/16 19:32:51 UTC
[incubator-pinot] branch add-config-merge-tool updated (5cbe3b8 ->
ddccedb)
This is an automated email from the ASF dual-hosted git repository.
jfim pushed a change to branch add-config-merge-tool
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
discard 5cbe3b8 Add configuration merging tool
add 0d92355 Get quickstart-realtime working again (#3374)
add 8f2dba8 Add abstract class PeriodicTask to unify duplicate code (#3264)
add 1eccd34 Backward compatibility for StreamConfig (#3380)
add a3c499c Disable LLC validation when LLC is not enabled (#3381)
add bd80360 Reduce the ZK access for segment metadata fetching (#3356)
add 57014c8 [TE] dashboard - support expected anomaly classification (#3382)
add ee5fa0d [TE] detection - pipeline/preview UI bug fix (#3383)
add 526ba5d Adding way to construct old segment upload endpoint (#3343)
add 86f65e0 Add a flag numGroupsLimitReached to mark responses that hit the number of groups limit (#3378)
add 7d347e9 Cleaning up crypter initialization (#3369)
add 83d61c9 Fix int overflow in FixedByteValueReaderWriter (#3385)
add cd6e32e [TE] rootcause - request scheduler (#3366)
add fcab1ba Supporting delete api for different storage options (#3370)
add b7ea9ee Support .tar.gz upload for pluggable storage (#3377)
add 9c6a0c6 [TE] Iris Alerts - Phase 2 : Refactoring | Cleanup DetectionEmailAlerter (#3375)
add 5071a74 TE rca anomaly label text shorten (#3384)
add f26b818 Update the TimeboundaryInfo in Pinot Broker when offline segments are refreshed. (#3354)
add 0a4712f Reduce FixedByteValueReaderWriter.writeUnpaddedString() to one write to data buffer (#3392)
add 9138751 i`[TE] frontend - aaronucsd/Added new share custom template header (#3391)
add 673af86 [TE] metric onboarding - support custom fabric groups (#3394)
add b763b65 Remove the columnName argument in FunctionExpressionEvaluator constructor (#3397)
add 0c31ba5 Instance level semaphore for realtime parallel segment builds (#3393)
add 390b4f9 [TE] build - cut down CI build time (#3401)
add 309953f [TE] Introduce configurations for alert schemes (#3395)
add 0045436 [TE] Change default alert cron for bulk onboard (#3390)
add b59b03b [TE] detection - moving monitoring window aligned to data set granularity (#3396)
add 07aa3ea Editing Reading of CSVReaderConfig in Segment Creation Job (#3372)
add 4de0b3f [TE] Read alerter configurations as a Map for easy extensibility (#3389)
add 4f34f83 Introduce OffsetCriteria class to handle different offset types and operations (#3402)
add a9550e3 [TE] Move emailWhitelist under alerterConfiguration (#3403)
add cfb97d5 [TE] rootcause - support query params for external setup of investigation (#3388)
add dab4494 [TE] Group together to, cc and bcc under recipients
add 75aa028 Adding overwrite parameter to move in PinotFS (#3386)
add 870c5d7 fix schedulerName (#3421)
add 2d404ac Use maven enforcer plugin to clean up dependencies (#2998)
add e111b8c [TE] frontend - aaronucsd/update Travis to use Chrome (#3400)
add 27ae042 Remove references to kafka from generic classes (#3423)
add f70c9c3 Add stream agnostic metrics for realtime (#3426)
add 4ce685c [TE] frontend - Alert Filter Component (#3419)
add 75e718d Move group id to StreamConfig level (#3425)
add 0a690ad [TE] frontend - aarouncsd/remove rca2 poc route for now (#3428)
add 4f2696d [TE] database - update alias field size (#3429)
add 2023bd1 [TE] frontend - random linter fixes Vol 1 (#3422)
add 18640fe Add segment merge command (#3427)
add f73a365 [TE] yaml - detection annotation (#3399)
add eccdd7d [TE] frontend - aarouncsd/update RCA title (#3430)
add 668aaf4 [TE] alerts - fix null array exception (#3431)
add 5ee6df6 [TE] Fix for zero anomalies email bug and added some additional checks (#3432)
add 5c296de Add RecordTransformer to perform transformation to incoming record (GenericRow) (#3424)
add 0c3f416 PINOT-7296: Reduce lock contention by not sharing DecimalFormat instances (#3433)
add 2e8e20e [TE] user dashboard - hide anomalies if alert is disabled (#3435)
add 0acea8f [TE] Introduce ability to suppress alerts (#3437)
add bbb300c Adding RetentionManager Support for Pluggable Storage (#3371)
add 65ad8a4 Replace ENABLE_SEGMENT_LEVEL_VALIDATION config with SEGMENT_LEVEL_VALIDATION_INTERVAL_IN_SECONDS (#3441)
add e692b89 Add the support for dynamic routing table (#3434)
add ba9f2dd Add stream related javadoc (#3436)
add b3c2e08 [TE] frontend - Anomaly resolution change label fix (#3444)
add 16559dc Limit the ByteArray wrapper logic inside segment creator (#3439)
add a5291e1 Allow generating new star-tree using Hadoop job (#3442)
add e41cd17 [TE] rootcause - inconsistent data warning (#3449)
add 283c70a Add max length limit to string values (#3445)
add b7a8cc1 [TE] anomalies - backend label translation fix (#3452)
add ac2ab14 Fix the bug for transferring more than 2G bytes (#3453)
add b70f2d5 Fixed the naming bug for merge segment admin command (#3446)
add d4104d4 [TE] frontend - aaronucsd/Added basic YAML editor (#3447)
add 6b790e1 [TE] onboarding - support bulk onboarding by dataset (#3455)
add 7341670 [TE] datasource - change epoch time column to aggregation granularity (#3458)
add f9317ec [TE] new detection pipeline - components (#3462)
add b4496b6 [TE] frontend - aaronucsd/fixed some styling issues for share template (THIRDEYE-2432) (#3457)
add 4e73ba3 [TE] detection - Input data fetcher interface (#3468)
add 2f7ddf8 Relocation manager should relocate segments from any servers (irrespective of the tag) to completed servers (#3466)
add a1cd143 Misc Cleanup: Removed unused member variable from (#3472)
add 506799f [TE] Percentage change and absolute change rule detector (#3467)
add eeaf9db [TE] Reset default lookback for merging anomalies (#3450)
add 3bd8fec [TE] datasource - update dataset if underline pinot table time field changed (#3456)
add ec9de38 [TE] rootcause - adjustment anomaly baseline rather than other numbers (#3461)
add 0b4fd51 [TE] Implement Threshold based Time Window Suppressor (#3463)
add a7df756 [TE] Ability to configure reference links like oncall run-book in the email alert (#3473)
add 1ffadef Enhance StarTreeV2ClusterIntegrationTest to cover multi-trees case (#3448)
add d1fb928 [TE] frontend - aaronucsd/home - changes to sort the application list (#3465)
add e7e9954 Fix typo in BaseRoutingTableBuilder (#3479)
add 19286f0 [TE] migrate minute-level and hourly properties (#3480)
add e0b0f3a [TE] detection - site-wide impact rule filter (#3482)
add c9a4e60 [TE] frontend - aarouncsd/Create Alert - Yaml quick fix (#3483)
add e358d7a [TE] frontend - harleyjj/rootcause - integration test for inconsistent data warning in rootcause-anomaly compoment (#3464)
add 3fee99d [TE] frontend harleyjj/manage remove WoW and change buildMetricDataUrl to take user inputs (#3485)
add 2d1bc7a [TE] frontend harleyjj/rootcause patch integration test for inconsistent data warning (#3488)
add e2dface [TE] dataframe - tolerate complex column names (#3491)
add e8516cb [TE] alert filter UX improvements (#3489)
add 6711f67 [TE] site wide impact filter - config global metric from yaml (#3490)
add 1beedd5 Enhance controller periodic task and scheduler (#3475)
add 285649f [PINOT-7328] Reduce lock contention in physical planning phase by reducing the total number of tasks (#3470)
add f6b5dfb [TE] config - enable rca holiday ranking with dimensions by default (#3493)
add fa54c19 [TE] config - fix broken defaults (#3492)
add 402cf3b Change build status to point apache incubator repository (#3498)
add ddccedb Add configuration merging tool
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 (5cbe3b8)
\
N -- N -- N refs/heads/add-config-merge-tool (ddccedb)
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:
.travis.yml | 9 +-
.travis_install.sh | 22 +-
.travis_test.sh | 2 +-
README.md | 2 +-
pinot-api/pom.xml | 4 +
.../linkedin/pinot/filesystem/AzurePinotFS.java | 51 +-
pinot-broker/pom.xml | 4 +
.../broker/helix/DefaultHelixBrokerConfig.java | 1 -
.../broker/broker/helix/HelixBrokerStarter.java | 14 +
.../TimeboundaryRefreshMessageHandlerFactory.java | 141 +
.../requesthandler/BaseBrokerRequestHandler.java | 11 +-
.../routing/HelixExternalViewBasedRouting.java | 6 +-
.../broker/routing/RoutingTableBuilderFactory.java | 16 +-
.../builder/BalancedRandomRoutingTableBuilder.java | 44 +-
.../BasePartitionAwareRoutingTableBuilder.java | 24 +-
.../routing/builder/BaseRoutingTableBuilder.java | 134 +-
.../builder/DefaultOfflineRoutingTableBuilder.java | 8 +-
.../DefaultRealtimeRoutingTableBuilder.java | 12 +-
.../builder/GeneratorBasedRoutingTableBuilder.java | 221 +-
...HighLevelConsumerBasedRoutingTableBuilder.java} | 59 +-
.../KafkaLowLevelConsumerRoutingTableBuilder.java | 160 -
.../builder/LargeClusterRoutingTableBuilder.java | 52 +-
.../LowLevelConsumerRoutingTableBuilder.java | 151 +
...l.java => LowLevelRoutingTableBuilderUtil.java} | 20 +-
.../PartitionAwareOfflineRoutingTableBuilder.java | 10 +-
.../PartitionAwareRealtimeRoutingTableBuilder.java | 26 +-
.../routing/builder/RoutingTableBuilder.java | 6 +-
.../broker/broker/HelixBrokerStarterTest.java | 99 +-
.../pinot/broker/routing/RoutingTableTest.java | 4 +-
.../BalancedRandomRoutingTableBuilderTest.java | 79 +-
... HighLevelConsumerRoutingTableBuilderTest.java} | 8 +-
.../LargeClusterRoutingTableBuilderTest.java | 6 +-
...> LowLevelConsumerRoutingTableBuilderTest.java} | 51 +-
...rtitionAwareOfflineRoutingTableBuilderTest.java | 22 +-
...titionAwareRealtimeRoutingTableBuilderTest.java | 4 +-
.../builder/RoutingTableBuilderTestUtil.java | 43 +
pinot-common/pom.xml | 14 +
.../pinot/common/config/IndexingConfig.java | 36 +-
.../pinot/common/config/RoutingConfig.java | 7 +-
.../SegmentsValidationAndRetentionConfig.java | 6 +-
.../pinot/common/config/StarTreeIndexConfig.java | 68 +
.../com/linkedin/pinot/common/data/FieldSpec.java | 75 +-
.../messages/TimeboundaryRefreshMessage.java | 42 +
.../pinot/common/metadata/ZKMetadataProvider.java | 55 +-
.../linkedin/pinot/common/metrics/BrokerMeter.java | 2 +
.../pinot/common/metrics/ControllerMeter.java | 3 +
.../linkedin/pinot/common/metrics/ServerGauge.java | 6 +
.../linkedin/pinot/common/metrics/ServerMeter.java | 8 +-
.../pinot/common/metrics/ValidationMetrics.java | 2 +-
.../protocols/SegmentCompletionProtocol.java | 8 +-
.../pinot/common/response/BrokerResponse.java | 5 +
.../response/broker/BrokerResponseNative.java | 28 +-
.../pinot/common/utils/CommonConstants.java | 19 +-
.../com/linkedin/pinot/common/utils/DataTable.java | 1 +
.../common/utils/FileUploadDownloadClient.java | 19 +
.../com/linkedin/pinot/common/utils/FileUtils.java | 28 +-
.../linkedin/pinot/common/utils/StringUtil.java | 40 +-
.../pinot/common/utils/StringUtilTest.java | 23 +-
pinot-controller/pom.xml | 4 +
.../linkedin/pinot/controller/ControllerConf.java | 45 +-
.../pinot/controller/ControllerStarter.java | 67 +-
.../api/resources/FileUploadPathProvider.java | 17 +-
.../PinotSegmentUploadRestletResource.java | 33 +-
.../controller/helix/SegmentStatusChecker.java | 127 +-
.../helix/core/PinotHelixResourceManager.java | 105 +-
.../helix/core/PinotTableIdealStateBuilder.java | 25 +-
.../helix/core/SegmentDeletionManager.java | 129 +-
.../helix/core/minion/PinotTaskManager.java | 64 +-
.../core/periodictask/ControllerPeriodicTask.java | 112 +
.../realtime/PinotLLCRealtimeSegmentManager.java | 169 +-
.../core/realtime/PinotRealtimeSegmentManager.java | 2 +-
.../core/realtime/SegmentCompletionManager.java | 2 +-
.../core/relocation/RealtimeSegmentRelocator.java | 114 +-
.../helix/core/retention/RetentionManager.java | 62 +-
.../helix/core/util/HelixSetupUtils.java | 4 +-
.../controller/validation/ValidationManager.java | 81 +-
.../controller/api/resources/TableViewsTest.java | 4 +-
.../controller/helix/SegmentStatusCheckerTest.java | 98 +-
.../periodictask/ControllerPeriodicTaskTest.java | 106 +
.../PinotLLCRealtimeSegmentManagerTest.java | 99 +-
.../segment/FlushThresholdUpdaterTest.java | 4 +-
.../rebalance/DefaultRebalanceStrategyTest.java | 4 +-
.../relocation/RealtimeSegmentRelocatorTest.java | 58 +-
.../helix/core/retention/RetentionManagerTest.java | 12 +-
.../core/util/SegmentDeletionManagerTest.java | 19 +-
.../controller/utils/SegmentMetadataMockUtils.java | 21 +
pinot-core/pom.xml | 4 +
.../pinot/core/crypt/PinotCrypterFactory.java | 55 +-
.../core/data/extractors/PlainFieldExtractor.java | 294 -
.../data/function/FunctionExpressionEvaluator.java | 89 +-
.../manager/config/TableDataManagerConfig.java | 7 -
.../manager/offline/TableDataManagerProvider.java | 13 +-
.../realtime/HLRealtimeSegmentDataManager.java | 71 +-
.../realtime/LLRealtimeSegmentDataManager.java | 98 +-
.../manager/realtime/RealtimeTableDataManager.java | 18 +-
.../core/data/readers/GenericRowRecordReader.java | 8 +-
.../recordtransformer/CompoundTransformer.java | 74 +
.../recordtransformer/DataTypeTransformer.java | 112 +
.../recordtransformer/ExpressionTransformer.java | 65 +
.../PinotDataType.java | 77 +-
.../RecordTransformer.java} | 26 +-
.../recordtransformer/SanitationTransformer.java | 74 +
.../data/recordtransformer/TimeTransformer.java | 65 +
.../generator/SegmentGeneratorConfig.java | 18 +-
...ixedByteSingleColumnMultiValueReaderWriter.java | 13 +-
...xedByteSingleColumnSingleValueReaderWriter.java | 2 +-
...ixedByteSingleValueMultiColumnReaderWriter.java | 5 +-
.../io/util/DictionaryDelegatingValueReader.java | 6 +-
.../core/io/util/FixedByteValueReaderWriter.java | 59 +-
.../linkedin/pinot/core/io/util/ValueReader.java | 2 +-
.../core/io/writer/impl/DirectMemoryManager.java | 3 +-
.../impl/FixedByteSingleValueMultiColWriter.java | 10 +-
.../impl/v1/FixedByteChunkSingleValueWriter.java | 6 +-
.../impl/v1/VarByteChunkSingleValueWriter.java | 5 +-
.../pinot/core/minion/BackfillDateTimeColumn.java | 4 +-
.../core/operator/CombineGroupByOperator.java | 4 +
.../operator/blocks/IntermediateResultsBlock.java | 8 +
.../pinot/core/periodictask/BasePeriodicTask.java | 52 +
.../PeriodicTask.java} | 55 +-
.../core/periodictask/PeriodicTaskScheduler.java | 80 +
.../linkedin/pinot/core/plan/CombinePlanNode.java | 28 +-
.../core/plan/maker/InstancePlanMakerImplV2.java | 6 +
.../core/query/reduce/BrokerReduceService.java | 3 +
.../query/scheduler/QuerySchedulerFactory.java | 2 +-
.../query/selection/SelectionOperatorUtils.java | 61 +-
.../converter/RealtimeSegmentConverter.java | 10 +-
.../dictionary/BytesOffHeapMutableDictionary.java | 66 +-
.../dictionary/BytesOnHeapMutableDictionary.java | 51 +-
...sumerFactory.java => KafkaConsumerFactory.java} | 6 +-
.../impl/kafka/KafkaJSONMessageDecoder.java | 4 +-
.../impl/kafka/KafkaStreamConfigProperties.java | 1 -
.../impl/kafka/KafkaStreamLevelConsumer.java | 20 -
.../impl/kafka/KafkaStreamMetadataProvider.java | 16 +-
.../realtime/impl/kafka/SimpleConsumerFactory.java | 64 +-
.../pinot/core/realtime/stream/MessageBatch.java | 10 +-
.../pinot/core/realtime/stream/OffsetCriteria.java | 210 +
.../realtime/stream/PartitionLevelConsumer.java | 2 +-
.../realtime/stream/PartitionOffsetFetcher.java | 4 +-
.../pinot/core/realtime/stream/StreamConfig.java | 58 +-
.../realtime/stream/StreamConfigProperties.java | 8 +-
.../realtime/stream/StreamConsumerFactory.java | 16 +-
.../core/realtime/stream/StreamLevelConsumer.java | 41 +-
.../core/realtime/stream/StreamMessageDecoder.java | 10 +-
.../realtime/stream/StreamMetadataProvider.java | 6 +-
.../RecordReaderSegmentCreationDataSource.java | 18 +-
.../segment/creator/SegmentIndexCreationInfo.java | 36 -
.../creator/impl/SegmentColumnarIndexCreator.java | 12 -
.../creator/impl/SegmentDictionaryCreator.java | 12 +-
.../impl/SegmentIndexCreationDriverImpl.java | 88 +-
.../fwd/SingleValueVarByteRawIndexCreator.java | 3 -
.../stats/BytesColumnPredIndexStatsCollector.java | 82 +-
.../index/column/PhysicalColumnIndexContainer.java | 7 +-
.../segment/index/readers/BytesDictionary.java | 4 +-
.../{ => name}/DefaultSegmentNameGenerator.java | 2 +-
.../name/NormalizedDateSegmentNameGenerator.java | 160 +
.../segment/{ => name}/SegmentNameGenerator.java | 4 +-
.../core/startree/OffHeapStarTreeBuilder.java | 6 +-
.../startree/v2/builder/StarTreeIndexCombiner.java | 5 +-
.../v2/builder/StarTreeV2BuilderConfig.java | 23 +-
.../com/linkedin/pinot/core/util/AvroUtils.java | 1 -
.../pinot/core/crypt/PinotCrypterFactoryTest.java | 38 +-
.../data/extractors/PlainFieldExtractorTest.java | 245 -
.../function/FunctionExpressionEvaluatorTest.java | 34 +-
.../realtime/LLRealtimeSegmentDataManagerTest.java | 4 +-
.../data/recordtransformer/PinotDataTypeTest.java | 144 +
.../recordtransformer/RecordTransformerTest.java | 158 +
.../periodictask/PeriodicTaskSchedulerTest.java | 85 +
.../pinot/core/plan/CombinePlanNodeTest.java | 36 +
.../impl/dictionary/MutableDictionaryTest.java | 23 +-
.../kafka/KafkaPartitionLevelConsumerTest.java | 4 +-
.../core/realtime/stream/OffsetCriteriaTest.java | 96 +
.../core/realtime/stream/StreamConfigTest.java | 29 +-
.../segment/index/creator/RawIndexCreatorTest.java | 31 +-
.../readers/ImmutableDictionaryReaderTest.java | 115 +-
.../DefaultSegmentNameGeneratorTest.java | 2 +-
.../NormalizedDateSegmentNameGeneratorTest.java | 140 +
.../linkedin/pinot/queries/BaseQueriesTest.java | 19 +-
...terSegmentAggregationMultiValueQueriesTest.java | 14 +
...erSegmentAggregationSingleValueQueriesTest.java | 14 +
pinot-distribution/pom.xml | 4 +
pinot-filesystem/pom.xml | 8 +
.../linkedin/pinot/filesystem/LocalPinotFS.java | 75 +-
.../com/linkedin/pinot/filesystem/PinotFS.java | 42 +-
.../pinot/filesystem/LocalPinotFSTest.java | 46 +-
.../pinot/filesystem/PinotFSFactoryTest.java | 13 +-
pinot-hadoop-filesystem/pom.xml | 8 +
.../linkedin/pinot/filesystem/HadoopPinotFS.java | 29 +-
pinot-hadoop/pom.xml | 6 +-
.../mapper/HadoopSegmentCreationMapReduceJob.java | 26 +-
pinot-integration-tests/pom.xml | 12 +
.../tests/BaseClusterIntegrationTest.java | 4 +-
.../pinot/integration/tests/ClusterTest.java | 2 +-
...lakyConsumerRealtimeClusterIntegrationTest.java | 20 -
.../tests/SegmentCompletionIntegrationTests.java | 5 +-
.../tests/StarTreeClusterIntegrationTest.java | 9 +-
.../tests/StarTreeV2ClusterIntegrationTest.java | 62 +-
pinot-minion/pom.xml | 4 +
.../com/linkedin/pinot/minion/MinionStarter.java | 6 +
pinot-perf/pom.xml | 4 +
pinot-server/pom.xml | 47 +-
.../starter/helix/HelixInstanceDataManager.java | 3 +
.../starter/helix/SegmentFetcherAndLoader.java | 2 +
pinot-tools/pom.xml | 4 +
.../pinot/tools/admin/PinotAdministrator.java | 2 +
.../converter/ColumnarToStarTreeConverter.java | 4 +-
.../segment/converter/SegmentMergeCommand.java | 282 +
.../meetupRsvp_realtime_table_config.json | 1 +
pinot-transport/pom.xml | 4 +
pom.xml | 66 +-
thirdeye/thirdeye-frontend/.gitignore | 1 +
thirdeye/thirdeye-frontend/.travis.yml | 3 -
.../thirdeye-frontend/app/adapters/application.js | 2 +-
thirdeye/thirdeye-frontend/app/adapters/base.js | 16 +-
.../thirdeye-frontend/app/adapters/share-config.js | 13 +
thirdeye/thirdeye-frontend/app/mirage/config.js | 8 +
.../app/mirage/endpoints/rootcause.js | 155 +-
.../app/mirage/endpoints/selfserve.js | 10 +-
.../thirdeye-frontend/app/mocks/alertConfig.js | 6 +-
thirdeye/thirdeye-frontend/app/mocks/anomalies.js | 2 +-
.../app/mocks/anomalyPerformance.js | 2 +-
.../app/mocks/metricPeripherals.js | 2 +-
.../app/mocks/timeseriesCompare.js | 2 +-
thirdeye/thirdeye-frontend/app/models/.gitkeep | 0
.../thirdeye-frontend/app/models/share-config.js | 8 +
.../app/pods/application/route.js | 10 +-
.../app/pods/components/anomaly-graph/component.js | 23 +-
.../app/pods/components/entity-filter/component.js | 117 +-
.../app/pods/components/entity-filter/template.hbs | 81 +-
.../pods/components/rootcause-anomaly/component.js | 46 +-
.../pods/components/rootcause-anomaly/template.hbs | 89 +-
.../pods/components/rootcause-header/template.hbs | 7 +-
.../pods/components/rootcause-metrics/component.js | 6 -
.../pods/components/rootcause-metrics/template.hbs | 9 -
.../pods/components/self-serve-graph/template.hbs | 2 +-
.../components/share-custom-template/component.js | 125 +
.../components/share-custom-template/template.hbs | 39 +
.../custom/anomalies-table/resolution/component.js | 14 +-
.../custom/anomalies-table/resolution/template.hbs | 15 +-
.../app/pods/home/index/controller.js | 13 +
.../app/pods/home/index/template.hbs | 11 +-
.../app/pods/home/share-dashboard/controller.js | 31 +-
.../app/pods/home/share-dashboard/route.js | 6 +
.../app/pods/home/share-dashboard/template.hbs | 113 +-
.../app/pods/manage/alert/explore/controller.js | 18 +-
.../app/pods/manage/alert/explore/route.js | 2 +
.../app/pods/manage/alert/explore/template.hbs | 13 +-
.../app/pods/manage/alerts/index/controller.js | 428 +-
.../app/pods/manage/alerts/index/route.js | 152 +-
.../app/pods/manage/alerts/index/template.hbs | 124 +-
.../pods/partials/rootcause/metrics/template.hbs | 10 +
.../app/pods/preview/template.hbs | 28 -
.../app/pods/rootcause/controller.js | 138 +-
.../thirdeye-frontend/app/pods/rootcause/route.js | 109 +-
.../app/pods/rootcause2/controller.js | 1216 --
.../thirdeye-frontend/app/pods/rootcause2/route.js | 391 -
.../app/pods/rootcause2/template.hbs | 290 -
.../app/pods/self-serve/create-alert/controller.js | 43 +-
.../app/pods/self-serve/create-alert/route.js | 1 -
.../app/pods/self-serve/create-alert/template.hbs | 781 +-
.../pods/self-serve/import-metric/controller.js | 25 +-
.../app/pods/self-serve/import-metric/template.hbs | 12 +
.../app/pods/services/api/anomalies/service.js | 37 +-
.../app/pods/services/api/dimensions/service.js | 2 +-
.../pods/services/api/share-dashboard/service.js | 9 +-
.../services/api/share-template-config/service.js | 46 +
.../app/pods/services/duration/service.js | 11 +-
.../app/pods/services/query-cache/service.js | 30 +-
.../services/rootcause-aggregates-cache/service.js | 28 +-
.../rootcause-anomalyfunction-cache/service.js | 1 -
.../services/rootcause-breakdowns-cache/service.js | 20 +-
.../services/rootcause-entities-cache/service.js | 1 -
.../app/pods/services/rootcause-fetcher/service.js | 230 +
.../services/rootcause-scores-cache/service.js | 31 +-
.../services/rootcause-timeseries-cache/service.js | 20 +-
thirdeye/thirdeye-frontend/app/router.js | 1 -
thirdeye/thirdeye-frontend/app/serializers/base.js | 12 +-
.../app/serializers/performance.js | 16 +-
.../app/serializers/share-config.js | 19 +
.../thirdeye-frontend/app/serializers/share.js | 16 +-
.../app/shared/anomaliesTableColumns.js | 2 +-
.../app/shared/dimensionAnalysisTableConfig.js | 2 +-
.../app/shared/filterBarConfig.js | 2 +-
thirdeye/thirdeye-frontend/app/styles/app.scss | 2 +-
.../app/styles/components/entity-filter.scss | 57 +-
.../app/styles/components/rootcause-anomaly.scss | 10 +
.../app/styles/components/te-anomaly-table.scss | 17 +-
.../app/styles/components/te-radio.scss | 1 +
.../pods/home/share-dashboard/share-dashboard.scss | 22 -
.../app/styles/pods/manage/alerts.scss | 19 +-
.../app/styles/shared/_placeholders.scss | 10 +
.../app/styles/shared/_styles.scss | 43 +-
.../app/styles/shared/_variable.scss | 3 +
thirdeye/thirdeye-frontend/app/utils/anomaly.js | 2 +-
.../thirdeye-frontend/app/utils/api/self-serve.js | 2 +-
thirdeye/thirdeye-frontend/app/utils/constants.js | 33 +
.../app/utils/manage-alert-utils.js | 68 +-
thirdeye/thirdeye-frontend/app/utils/rca-utils.js | 2 +-
thirdeye/thirdeye-frontend/app/utils/utils.js | 2 +-
thirdeye/thirdeye-frontend/ember-cli-build.js | 7 +
thirdeye/thirdeye-frontend/package-lock.json | 18991 -------------------
thirdeye/thirdeye-frontend/package.json | 7 +-
thirdeye/thirdeye-frontend/pom.xml | 14 +-
thirdeye/thirdeye-frontend/testem.js | 7 +-
.../tests/acceptance/rootcause-test.js | 20 +-
.../acceptance/self-serve-alert-tuning-test.js | 4 +-
.../acceptance/self-serve-import-metric-test.js | 4 +-
.../tests/acceptance/self-serve-onboarding-test.js | 4 +-
.../components/entity-filter/component-test.js | 130 +
.../components/rootcause-anomaly/component-test.js | 102 +
.../component-test.js | 12 +-
.../share-custom-template/component-test.js | 70 +
thirdeye/thirdeye-frontend/yarn.lock | 4322 ++---
thirdeye/thirdeye-pinot/config/dashboard.yml | 7 +-
thirdeye/thirdeye-pinot/config/detector.yml | 9 +-
thirdeye/thirdeye-pinot/config/rca.yml | 6 +-
thirdeye/thirdeye-pinot/pom.xml | 43 -
.../alert/content/BaseEmailContentFormatter.java | 3 +
.../EmailContentFormatterConfiguration.java | 5 +-
.../thirdeye/anomaly/SmtpConfiguration.java | 25 +-
.../anomaly/ThirdEyeAnomalyApplication.java | 4 +
.../anomaly/ThirdEyeAnomalyConfiguration.java | 18 -
.../anomaly/alert/util/AnomalyReportGenerator.java | 8 +-
.../thirdeye/anomaly/alert/util/EmailHelper.java | 11 +-
.../anomaly/alert/util/EmailScreenshotHelper.java | 8 +-
.../anomaly/alert/v2/AlertTaskRunnerV2.java | 36 +-
.../detection/DetectionJobSchedulerUtils.java | 4 +-
.../thirdeye/anomaly/merge/AnomalyMergeConfig.java | 5 +-
.../thirdeye/anomaly/onboard/ReplayTaskRunner.java | 5 +-
.../tasks/FunctionCreationOnboardingTask.java | 10 +-
.../onboard/AutoOnboardPinotMetadataSource.java | 16 +-
.../thirdeye/auto/onboard/ConfigGenerator.java | 20 +-
.../thirdeye/common/ThirdEyeConfiguration.java | 21 +-
.../dashboard/ThirdEyeDashboardApplication.java | 6 +
.../dashboard/ThirdEyeDashboardConfiguration.java | 1 +
.../dashboard/resources/EmailResource.java | 18 +-
.../dashboard/resources/OnboardResource.java | 87 +-
.../dashboard/resources/v2/ResourceUtils.java | 2 +-
.../resources/v2/RootCauseMetricResource.java | 5 -
.../resources/v2/UserDashboardResource.java | 4 +-
.../resources/v2/pojo/AnomalyDetails.java | 18 +-
.../com/linkedin/thirdeye/dataframe/DataFrame.java | 19 +-
.../thirdeye/dataframe/util/DataFrameUtils.java | 4 -
.../thirdeye/dataframe/util/MetricSlice.java | 3 +-
.../linkedin/thirdeye/datalayer/ScriptRunner.java | 4 +-
.../thirdeye/datalayer/dto/DetectionConfigDTO.java | 11 +
.../thirdeye/datalayer/pojo/AlertConfigBean.java | 9 +
.../datalayer/pojo/DetectionAlertConfigBean.java | 25 +-
.../datalayer/pojo/DetectionConfigBean.java | 9 +
.../thirdeye/datasource/pinot/PqlUtils.java | 25 +-
.../linkedin/thirdeye/detection/DataProvider.java | 17 +-
.../thirdeye/detection/DefaultDataProvider.java | 36 +-
.../detection/DefaultInputDataFetcher.java | 87 +
.../thirdeye/detection/DetectionPipeline.java | 59 +-
.../thirdeye/detection/DetectionResource.java | 15 +-
...{DetectionPipeline.java => DetectionUtils.java} | 153 +-
.../com/linkedin/thirdeye/detection/InputData.java | 66 -
.../thirdeye/detection/InputDataFetcher.java | 18 +-
.../linkedin/thirdeye/detection/InputDataSpec.java | 98 -
.../Pattern.java} | 15 +-
.../detection/StaticDetectionPipeline.java | 12 +-
.../thirdeye/detection/alert/AlertUtils.java | 53 +
.../detection/alert/DetectionAlertTaskFactory.java | 63 +-
.../detection/alert/DetectionAlertTaskRunner.java | 72 +-
.../alert/StatefulDetectionAlertFilter.java | 6 +-
.../filter/DimensionDetectionAlertFilter.java | 20 +-
.../detection/alert/filter/LegacyAlertFilter.java | 8 +-
.../ToAllRecipientsDetectionAlertFilter.java | 13 +-
.../alert/scheme/DetectionEmailAlerter.java | 218 +-
.../alert/suppress/DetectionAlertSuppressor.java | 22 +
.../DetectionAlertTimeWindowSuppressor.java | 127 +
.../detection/algorithm/BaselineAlgorithm.java | 4 +-
.../detection/algorithm/DimensionWrapper.java | 1 +
.../algorithm/LegacyAnomalyFunctionAlgorithm.java | 6 +-
.../detection/algorithm/LegacyMergeWrapper.java | 5 +-
.../thirdeye/detection/algorithm/MergeWrapper.java | 7 +-
.../detection/algorithm/MovingWindowAlgorithm.java | 7 +-
.../detection/algorithm/ThresholdAlgorithm.java | 4 +-
.../stage/AnomalyDetectionStageWrapper.java | 167 +-
.../algorithm/stage/AnomalyFilterStageWrapper.java | 1 -
.../stage/BaselineRuleDetectionStage.java | 25 +-
.../algorithm/stage/BaselineRuleFilterStage.java | 11 +-
.../detection/algorithm/stage/StageUtils.java | 50 -
.../stage/StaticAnomalyDetectionStage.java | 62 +-
.../algorithm/stage/StaticAnomalyFilterStage.java | 19 +-
.../algorithm/stage/StaticGrouperStage.java | 50 -
.../stage/ThresholdRuleDetectionStage.java | 23 +-
.../algorithm/stage/ThresholdRuleFilterStage.java | 17 +-
.../thirdeye/detection/annotation/Components.java | 49 +
.../annotation/DetectionConfigurationResource.java | 37 +
.../detection/annotation/DetectionRegistry.java | 145 +
.../annotation/DetectionTag.java} | 14 +-
.../thirdeye/detection/annotation/Param.java | 41 +
.../annotation/PresentationOption.java} | 20 +-
.../thirdeye/detection/annotation/Tune.java | 22 +-
.../thirdeye/detection/annotation/Yaml.java | 22 +-
.../detection/baseline/BaselineProvider.java | 51 -
.../detection/baseline/RuleBaselineProvider.java | 97 -
.../detection/baseline/StaticBaselineProvider.java | 105 -
.../components/AbsoluteChangeRuleDetector.java | 108 +
.../components/PercentageChangeRuleDetector.java | 116 +
.../detection/components/RuleBaselineProvider.java | 68 +
.../SitewideImpactRuleAnomalyFilter.java | 126 +
.../components/ThresholdRuleAnomalyFilter.java | 77 +
.../components/ThresholdRuleDetector.java | 92 +
.../finetune/GridSearchTuningAlgorithm.java | 6 +-
.../detection/finetune/TuningAlgorithm.java | 4 +-
.../spec/AbsoluteChangeRuleDetectorSpec.java | 59 +
.../thirdeye/detection/spec/AbstractSpec.java | 22 +-
.../spec/PercentageChangeRuleDetectorSpec.java | 56 +
.../detection/spec/RuleBaselineProviderSpec.java | 50 +
.../spec/SitewideImpactRuleAnomalyFilterSpec.java | 72 +
.../detection/spec/ThresholdRuleDetectorSpec.java | 33 +-
.../detection/spec/ThresholdRuleFilterSpec.java | 33 +-
.../components/AnomalyDetector.java} | 26 +-
.../spi/components/AnomalyFilter.java} | 15 +-
.../spi/components/BaseComponent.java} | 11 +-
.../detection/spi/components/BaselineProvider.java | 44 +
.../thirdeye/detection/spi/components/Grouper.java | 28 +-
.../thirdeye/detection/spi/components/Tunable.java | 36 +
.../detection/{ => spi/model}/AnomalySlice.java | 29 +-
.../detection/{ => spi/model}/EventSlice.java | 4 +-
.../thirdeye/detection/spi/model/InputData.java | 118 +
.../detection/spi/model/InputDataSpec.java | 177 +
.../thirdeye/detection/spi/model/TimeSeries.java | 64 +
.../detection/wrapper/AnomalyDetectorWrapper.java | 203 +
.../AnomalyFilterWrapper.java} | 39 +-
.../BaselineFillingMergeWrapper.java | 66 +-
.../ChildKeepingMergeWrapper.java | 11 +-
.../yaml/CompositePipelineConfigTranslator.java | 241 +-
.../thirdeye/detection/yaml/DetectionRegistry.java | 75 -
.../yaml/YamlDetectionAlertConfigTranslator.java | 2 +
.../yaml/YamlDetectionConfigTranslator.java | 67 +-
.../yaml/YamlDetectionTranslatorLoader.java | 18 +-
.../thirdeye/detection/yaml/YamlResource.java | 65 +-
.../detection/yaml/YamlTranslationResult.java | 84 +
.../thirdeye/rootcause/impl/MetricEntity.java | 1 -
.../rootcause/impl/RCAFrameworkRunner.java | 3 -
.../dashboard/views/admin/thirdeye-admin.ftl | 4 +-
.../thirdeye/detector/holiday-anomaly-report.ftl | 30 +-
.../com/linkedin/thirdeye/detector/lib/utils.ftl | 12 +
.../src/main/resources/schema/create-schema.sql | 2 +-
.../com/linkedin/thirdeye/TestDBResources.java | 134 -
...HierarchicalAnomaliesEmailContentFormatter.java | 10 +
...TestMultipleAnomaliesEmailContentFormatter.java | 11 +
...TestOnboardingNotificationContentFormatter.java | 10 +
.../AutoOnboardPinotMetricsServiceTest.java | 14 +
.../dashboard/resource/OnboardResourceTest.java | 8 +-
.../linkedin/thirdeye/dataframe/DataFrameTest.java | 14 +
.../thirdeye/datalayer/bao/DAOTestBase.java | 9 +-
.../thirdeye/detection/DataProviderTest.java | 16 +-
.../detection/DefaultInputDataFetcherTest.java | 54 +
.../thirdeye/detection/MockDataProvider.java | 17 +-
.../alert/DetectionAlertTaskFactoryTest.java | 40 +-
.../thirdeye/detection/alert/SendAlertTest.java | 23 +-
.../filter/DimensionDetectionAlertFilterTest.java | 9 +-
.../ToAllRecipientsDetectionAlertFilterTest.java | 9 +-
.../alert/scheme/AnotherRandomAlerter.java | 5 +-
.../detection/alert/scheme/RandomAlerter.java | 5 +-
.../DetectionTimeWindowSuppressorTest.java | 157 +
.../detection/algorithm/BaselineAlgorithmTest.java | 7 +-
.../LegacyAnomalyFunctionAlgorithmTest.java | 1 -
.../algorithm/MovingWindowAlgorithmTest.java | 3 +-
.../stage/AnomalyDetectionStageWrapperTest.java | 87 +
.../stage/BaselineRuleDetectionStageTest.java | 1 -
.../detection/baseline/MockBaselineProvider.java | 50 -
.../components/AbsoluteChangeRuleDetectorTest.java | 94 +
.../detection/components/MockBaselineProvider.java | 45 +
.../PercentageChangeRuleDetectorTest.java} | 108 +-
.../RuleBaselineProviderTest.java | 21 +-
.../SitewideImpactRuleAnomalyFilterTest.java | 105 +
.../components/ThresholdRuleAnomalyFilterTest.java | 170 +
.../ThresholdRuleDetectorTest.java} | 48 +-
.../finetune/GridSearchTuningAlgorithmTest.java | 4 +-
.../MergeDimensionThresholdIntegrationTest.java | 6 +-
.../thirdeye/detection/spec/AbstractSpecTest.java | 69 +
.../detection/spec/MockBaselineProviderSpec.java | 43 +
.../linkedin/thirdeye/detection/spec/TestSpec.java | 70 +
.../wrapper/AnomalyDetectorWrapperTest.java | 92 +
.../BaselineFillingMergeWrapperTest.java | 20 +-
.../ChildKeepingMergeWrapperTest.java | 4 +-
.../CompositePipelineConfigTranslatorTest.java | 182 +-
.../yaml/MockYamlDetectionConfigTranslator.java | 8 +-
.../YamlDetectionAlertConfigTranslatorTest.java | 6 +-
.../yaml/YamlDetectionConfigTranslatorTest.java | 7 +-
.../tools/anomaly/report/AnomalyReportDriver.java | 7 +-
.../anomaly/report/GenerateAnomalyReport.java | 6 +-
.../compositePipelineTranslatorTestResult-1.json | 61 +
.../compositePipelineTranslatorTestResult-2.json | 30 +
.../thirdeye/detection/yaml/pipeline-config-1.yaml | 34 +
.../thirdeye/detection/yaml/pipeline-config-2.yaml | 22 +
.../thirdeye/detection/yaml/pipeline-config.yaml | 29 -
491 files changed, 15296 insertions(+), 29418 deletions(-)
create mode 100644 pinot-broker/src/main/java/com/linkedin/pinot/broker/broker/helix/TimeboundaryRefreshMessageHandlerFactory.java
rename pinot-broker/src/main/java/com/linkedin/pinot/broker/routing/builder/{KafkaHighLevelConsumerBasedRoutingTableBuilder.java => HighLevelConsumerBasedRoutingTableBuilder.java} (52%)
delete mode 100644 pinot-broker/src/main/java/com/linkedin/pinot/broker/routing/builder/KafkaLowLevelConsumerRoutingTableBuilder.java
create mode 100644 pinot-broker/src/main/java/com/linkedin/pinot/broker/routing/builder/LowLevelConsumerRoutingTableBuilder.java
rename pinot-broker/src/main/java/com/linkedin/pinot/broker/routing/builder/{KafkaLowLevelRoutingTableBuilderUtil.java => LowLevelRoutingTableBuilderUtil.java} (78%)
rename pinot-broker/src/test/java/com/linkedin/pinot/broker/routing/builder/{KafkaHighLevelConsumerRoutingTableBuilderTest.java => HighLevelConsumerRoutingTableBuilderTest.java} (93%)
rename pinot-broker/src/test/java/com/linkedin/pinot/broker/routing/builder/{KafkaLowLevelConsumerRoutingTableBuilderTest.java => LowLevelConsumerRoutingTableBuilderTest.java} (77%)
create mode 100644 pinot-broker/src/test/java/com/linkedin/pinot/broker/routing/builder/RoutingTableBuilderTestUtil.java
create mode 100644 pinot-common/src/main/java/com/linkedin/pinot/common/config/StarTreeIndexConfig.java
create mode 100644 pinot-common/src/main/java/com/linkedin/pinot/common/messages/TimeboundaryRefreshMessage.java
create mode 100644 pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/periodictask/ControllerPeriodicTask.java
create mode 100644 pinot-controller/src/test/java/com/linkedin/pinot/controller/helix/core/periodictask/ControllerPeriodicTaskTest.java
delete mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/data/extractors/PlainFieldExtractor.java
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/CompoundTransformer.java
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/DataTypeTransformer.java
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/ExpressionTransformer.java
rename pinot-core/src/main/java/com/linkedin/pinot/core/data/{extractors => recordtransformer}/PinotDataType.java (83%)
rename pinot-core/src/main/java/com/linkedin/pinot/core/data/{extractors/FieldExtractor.java => recordtransformer/RecordTransformer.java} (58%)
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/SanitationTransformer.java
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/data/recordtransformer/TimeTransformer.java
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/periodictask/BasePeriodicTask.java
copy pinot-core/src/main/java/com/linkedin/pinot/core/{realtime/stream/StreamLevelConsumer.java => periodictask/PeriodicTask.java} (50%)
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/periodictask/PeriodicTaskScheduler.java
copy pinot-core/src/main/java/com/linkedin/pinot/core/realtime/impl/kafka/{SimpleConsumerFactory.java => KafkaConsumerFactory.java} (87%)
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/realtime/stream/OffsetCriteria.java
rename pinot-core/src/main/java/com/linkedin/pinot/core/segment/{ => name}/DefaultSegmentNameGenerator.java (99%)
create mode 100644 pinot-core/src/main/java/com/linkedin/pinot/core/segment/name/NormalizedDateSegmentNameGenerator.java
copy pinot-core/src/main/java/com/linkedin/pinot/core/segment/{ => name}/SegmentNameGenerator.java (86%)
delete mode 100644 pinot-core/src/test/java/com/linkedin/pinot/core/data/extractors/PlainFieldExtractorTest.java
create mode 100644 pinot-core/src/test/java/com/linkedin/pinot/core/data/recordtransformer/PinotDataTypeTest.java
create mode 100644 pinot-core/src/test/java/com/linkedin/pinot/core/data/recordtransformer/RecordTransformerTest.java
create mode 100644 pinot-core/src/test/java/com/linkedin/pinot/core/periodictask/PeriodicTaskSchedulerTest.java
create mode 100644 pinot-core/src/test/java/com/linkedin/pinot/core/realtime/stream/OffsetCriteriaTest.java
rename pinot-core/src/test/java/com/linkedin/pinot/core/segment/{ => name}/DefaultSegmentNameGeneratorTest.java (99%)
create mode 100644 pinot-core/src/test/java/com/linkedin/pinot/core/segment/name/NormalizedDateSegmentNameGeneratorTest.java
create mode 100644 pinot-tools/src/main/java/com/linkedin/pinot/tools/segment/converter/SegmentMergeCommand.java
create mode 100644 thirdeye/thirdeye-frontend/app/adapters/share-config.js
delete mode 100644 thirdeye/thirdeye-frontend/app/models/.gitkeep
create mode 100644 thirdeye/thirdeye-frontend/app/models/share-config.js
create mode 100644 thirdeye/thirdeye-frontend/app/pods/components/share-custom-template/component.js
create mode 100644 thirdeye/thirdeye-frontend/app/pods/components/share-custom-template/template.hbs
delete mode 100644 thirdeye/thirdeye-frontend/app/pods/rootcause2/controller.js
delete mode 100644 thirdeye/thirdeye-frontend/app/pods/rootcause2/route.js
delete mode 100644 thirdeye/thirdeye-frontend/app/pods/rootcause2/template.hbs
create mode 100644 thirdeye/thirdeye-frontend/app/pods/services/api/share-template-config/service.js
create mode 100644 thirdeye/thirdeye-frontend/app/pods/services/rootcause-fetcher/service.js
create mode 100644 thirdeye/thirdeye-frontend/app/serializers/share-config.js
delete mode 100644 thirdeye/thirdeye-frontend/app/styles/pods/home/share-dashboard/share-dashboard.scss
create mode 100644 thirdeye/thirdeye-frontend/app/styles/shared/_placeholders.scss
delete mode 100644 thirdeye/thirdeye-frontend/package-lock.json
create mode 100644 thirdeye/thirdeye-frontend/tests/integration/pods/components/entity-filter/component-test.js
create mode 100644 thirdeye/thirdeye-frontend/tests/integration/pods/components/rootcause-anomaly/component-test.js
create mode 100644 thirdeye/thirdeye-frontend/tests/integration/pods/components/share-custom-template/component-test.js
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/DefaultInputDataFetcher.java
copy thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/{DetectionPipeline.java => DetectionUtils.java} (54%)
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/InputData.java
copy pinot-core/src/main/java/com/linkedin/pinot/core/segment/SegmentNameGenerator.java => thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/InputDataFetcher.java (62%)
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/InputDataSpec.java
copy thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/{datalayer/dto/DetectionConfigDTO.java => detection/Pattern.java} (78%)
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/alert/suppress/DetectionAlertSuppressor.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/alert/suppress/DetectionAlertTimeWindowSuppressor.java
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/algorithm/stage/StageUtils.java
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/algorithm/stage/StaticGrouperStage.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/annotation/Components.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/annotation/DetectionConfigurationResource.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/annotation/DetectionRegistry.java
copy thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/{datalayer/dto/DetectionConfigDTO.java => detection/annotation/DetectionTag.java} (78%)
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/annotation/Param.java
copy thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/{datalayer/dto/DetectionConfigDTO.java => detection/annotation/PresentationOption.java} (53%)
copy pinot-core/src/main/java/com/linkedin/pinot/core/segment/SegmentNameGenerator.java => thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/annotation/Tune.java (50%)
rename pinot-core/src/main/java/com/linkedin/pinot/core/segment/SegmentNameGenerator.java => thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/annotation/Yaml.java (54%)
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/baseline/BaselineProvider.java
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/baseline/RuleBaselineProvider.java
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/baseline/StaticBaselineProvider.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/components/AbsoluteChangeRuleDetector.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/components/PercentageChangeRuleDetector.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/components/RuleBaselineProvider.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/components/SitewideImpactRuleAnomalyFilter.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/components/ThresholdRuleAnomalyFilter.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/components/ThresholdRuleDetector.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spec/AbsoluteChangeRuleDetectorSpec.java
rename pinot-core/src/main/java/com/linkedin/pinot/core/data/extractors/FieldExtractorFactory.java => thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spec/AbstractSpec.java (55%)
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spec/PercentageChangeRuleDetectorSpec.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spec/RuleBaselineProviderSpec.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spec/SitewideImpactRuleAnomalyFilterSpec.java
copy pinot-core/src/test/java/com/linkedin/pinot/core/crypt/PinotCrypterFactoryTest.java => thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spec/ThresholdRuleDetectorSpec.java (56%)
copy pinot-core/src/test/java/com/linkedin/pinot/core/crypt/PinotCrypterFactoryTest.java => thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spec/ThresholdRuleFilterSpec.java (56%)
rename thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/{baseline/BaselineProviderLoader.java => spi/components/AnomalyDetector.java} (50%)
copy thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/{datalayer/dto/DetectionConfigDTO.java => detection/spi/components/AnomalyFilter.java} (57%)
copy thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/{datalayer/dto/DetectionConfigDTO.java => detection/spi/components/BaseComponent.java} (69%)
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spi/components/BaselineProvider.java
copy pinot-core/src/main/java/com/linkedin/pinot/core/realtime/stream/PartitionLevelConsumer.java => thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spi/components/Grouper.java (53%)
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spi/components/Tunable.java
rename thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/{ => spi/model}/AnomalySlice.java (69%)
rename thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/{ => spi/model}/EventSlice.java (97%)
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spi/model/InputData.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spi/model/InputDataSpec.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/spi/model/TimeSeries.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/wrapper/AnomalyDetectorWrapper.java
copy thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/{algorithm/stage/AnomalyFilterStageWrapper.java => wrapper/AnomalyFilterWrapper.java} (67%)
rename thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/{algorithm => wrapper}/BaselineFillingMergeWrapper.java (59%)
rename thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/{algorithm => wrapper}/ChildKeepingMergeWrapper.java (89%)
delete mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/yaml/DetectionRegistry.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/detection/yaml/YamlTranslationResult.java
create mode 100644 thirdeye/thirdeye-pinot/src/main/resources/com/linkedin/thirdeye/detector/lib/utils.ftl
delete mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/TestDBResources.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/DefaultInputDataFetcherTest.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/alert/suppress/DetectionTimeWindowSuppressorTest.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/algorithm/stage/AnomalyDetectionStageWrapperTest.java
delete mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/baseline/MockBaselineProvider.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/components/AbsoluteChangeRuleDetectorTest.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/components/MockBaselineProvider.java
copy thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/{algorithm/stage/BaselineRuleDetectionStageTest.java => components/PercentageChangeRuleDetectorTest.java} (52%)
rename thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/{baseline => components}/RuleBaselineProviderTest.java (77%)
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/components/SitewideImpactRuleAnomalyFilterTest.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/components/ThresholdRuleAnomalyFilterTest.java
copy thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/{algorithm/LegacyAnomalyFunctionAlgorithmTest.java => components/ThresholdRuleDetectorTest.java} (68%)
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/spec/AbstractSpecTest.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/spec/MockBaselineProviderSpec.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/spec/TestSpec.java
create mode 100644 thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/wrapper/AnomalyDetectorWrapperTest.java
rename thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/{algorithm => wrapper}/BaselineFillingMergeWrapperTest.java (82%)
rename thirdeye/thirdeye-pinot/src/test/java/com/linkedin/thirdeye/detection/{algorithm => wrapper}/ChildKeepingMergeWrapperTest.java (98%)
create mode 100644 thirdeye/thirdeye-pinot/src/test/resources/com/linkedin/thirdeye/detection/yaml/compositePipelineTranslatorTestResult-1.json
create mode 100644 thirdeye/thirdeye-pinot/src/test/resources/com/linkedin/thirdeye/detection/yaml/compositePipelineTranslatorTestResult-2.json
create mode 100644 thirdeye/thirdeye-pinot/src/test/resources/com/linkedin/thirdeye/detection/yaml/pipeline-config-1.yaml
create mode 100644 thirdeye/thirdeye-pinot/src/test/resources/com/linkedin/thirdeye/detection/yaml/pipeline-config-2.yaml
delete mode 100644 thirdeye/thirdeye-pinot/src/test/resources/com/linkedin/thirdeye/detection/yaml/pipeline-config.yaml
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org