This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch standalone-pbnj
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from 3c72e6c Address comments
add db91339 [TE] clean up some legacy code (#4837)
add 5d0bcca [TE] frontend - harleyjj/bugs - Dont filter zeroes from
bounds and display error message on create alert (#4868)
add f3558b6 Capture the exact UPDATE operation in DefaultColumnHandler
(#4876)
add 2201a22 [TE] Generify centralized cache DAO and add certificate-based
authentication support for Couchbase (#4862)
add 3ec7548 Add getResultColumnName API to AggregationFunction to fetch
sql compliant result name (#4870)
add 8d08bcc Clean up the connection-pool based broker routing (#4850)
add 82359d0 Use Files.createDirectories instead of File.mkdirs in (#4878)
add d15b33a [TE] Bug fix in the rca dashboard/summary endpoint (#4880)
add 2552c0f Refactor pinot record reader dependency (#4872)
add a01d930 Adding pinot-standalone module to generate segments
add d051ead Make whole pipeline works
add 59905e6 Adding segment push jobs
add 242eb1d update comments 1
add 63e10fe rename pinot-ingestion-jobs module to pinot-batch-ingestion
add 0d9f64d Address comments
add 0711c1c Merge branch 'standalone-pbnj' of
github.com:apache/incubator-pinot into standalone-pbnj
add e77b42e Rebase and address comments
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 -
docs/code_modules.rst | 6 -
docs/record_reader.rst | 2 +-
.../hadoop/job/mappers/SegmentCreationMapper.java | 4 +-
.../spark/jobs/SparkSegmentCreationFunction.java | 4 +-
.../apache/pinot/ingestion/common/PushJobSpec.java | 12 +-
.../standalone/SegmentGenerationJobRunner.java | 23 +-
.../standalone/SegmentTarPushJobRunner.java | 10 +-
.../standalone/SegmentUriPushJobRunner.java | 10 +-
pinot-batch-ingestion/pom.xml | 11 -
pinot-broker/pom.xml | 4 -
.../pinot/broker/broker/BrokerServerBuilder.java | 24 +-
.../broker/broker/helix/HelixBrokerStarter.java | 10 -
.../broker/helix/LiveInstanceChangeHandler.java | 121 ----
.../ConnectionPoolBrokerRequestHandler.java | 423 ------------
.../pinot/common/response/ServerInstance.java | 172 -----
.../apache/pinot/common/utils/CommonConstants.java | 4 -
.../pinot/common/utils/TarGzCompressionUtils.java | 25 +-
pinot-core/pom.xml | 27 +
.../core/data/readers/RecordReaderFactory.java | 6 +
.../apache/pinot/core/data/table/TableResizer.java | 20 +-
.../generator/SegmentGeneratorConfig.java | 4 +-
.../query/AggregationGroupByOrderByOperator.java | 3 +-
.../aggregation/AggregationFunctionContext.java | 8 +
.../aggregation/function/AggregationFunction.java | 11 +-
.../function/AggregationFunctionUtils.java | 5 -
.../function/AvgAggregationFunction.java | 5 -
.../function/AvgMVAggregationFunction.java | 5 -
.../function/CountAggregationFunction.java | 5 +
.../function/CountMVAggregationFunction.java | 5 +
.../function/DistinctAggregationFunction.java | 5 -
.../function/DistinctCountAggregationFunction.java | 5 -
.../DistinctCountHLLAggregationFunction.java | 5 -
.../DistinctCountHLLMVAggregationFunction.java | 5 -
.../DistinctCountMVAggregationFunction.java | 5 -
.../DistinctCountRawHLLAggregationFunction.java | 5 -
.../DistinctCountRawHLLMVAggregationFunction.java | 5 -
.../function/FastHLLAggregationFunction.java | 5 -
.../function/MaxAggregationFunction.java | 5 -
.../function/MaxMVAggregationFunction.java | 5 -
.../function/MinAggregationFunction.java | 5 -
.../function/MinMVAggregationFunction.java | 5 -
.../function/MinMaxRangeAggregationFunction.java | 5 -
.../function/MinMaxRangeMVAggregationFunction.java | 5 -
.../function/PercentileAggregationFunction.java | 5 +
.../function/PercentileEstAggregationFunction.java | 5 +
.../PercentileEstMVAggregationFunction.java | 5 +
.../function/PercentileMVAggregationFunction.java | 5 +
.../PercentileTDigestAggregationFunction.java | 5 +
.../PercentileTDigestMVAggregationFunction.java | 5 +
.../function/SumAggregationFunction.java | 5 -
.../function/SumMVAggregationFunction.java | 5 -
.../stream/AvroRecordToPinotRowGenerator.java | 2 +-
...xException.java => V3UpdateIndexException.java} | 8 +-
.../defaultcolumn/BaseDefaultColumnHandler.java | 40 +-
.../defaultcolumn/V3DefaultColumnHandler.java | 8 +-
.../core/data/readers/CSVRecordReaderTest.java | 75 ---
.../core/data/readers/JSONRecordReaderTest.java | 69 --
.../data/readers/RecordReaderSampleDataTest.java | 3 +
.../pinot/core/data/readers/RecordReaderTest.java | 54 --
.../MutableSegmentImplNullValueVectorTest.java | 2 +-
.../mutable/MutableSegmentImplTest.java | 4 +-
.../fakestream/FakePartitionLevelConsumer.java | 2 +-
.../SegmentGenerationWithBytesTypeTest.java | 2 +-
.../InterSegmentOrderByMultiValueQueriesTest.java | 98 +--
.../InterSegmentOrderBySingleValueQueriesTest.java | 261 +++++---
.../org/apache/pinot/queries/QueriesTestUtils.java | 14 +-
.../pinot/segments/v1/creator/BlocksTest.java | 2 +-
.../segments/v1/creator/DictionariesTest.java | 2 +-
.../pinot/segments/v1/creator/IntArraysTest.java | 2 +-
pinot-distribution/pom.xml | 4 -
.../tests/ClusterIntegrationTestUtils.java | 2 +-
.../pinot/integration/tests/ClusterTest.java | 8 +-
.../tests/MapTypeClusterIntegrationTest.java | 2 +-
.../data/readers/ParquetRecordReaderTest.java | 96 ---
.../pinot-avro}/pom.xml | 55 +-
.../pinot/avro}/data/readers/AvroRecordReader.java | 4 +-
.../pinot/avro/data/readers}/AvroSchemaUtil.java | 2 +-
.../apache/pinot/avro/data/readers}/AvroUtils.java | 48 +-
.../avro/data/readers/AvroRecordReaderTest.java | 60 ++
.../pinot-csv}/pom.xml | 56 +-
.../CSVRecordReader.java | 3 +-
.../CSVRecordReaderConfig.java | 2 +-
.../CSVRecordReaderTest.java | 67 ++
.../pinot-json}/pom.xml | 52 +-
.../JSONRecordReader.java | 3 +-
.../JSONRecordReaderTest.java | 53 ++
.../pinot-orc}/pom.xml | 4 +-
.../pinot/orc/data/readers/ORCRecordReader.java | 0
.../orc/data/readers/ORCRecordReaderTest.java | 0
.../pinot-parquet}/pom.xml | 30 +-
.../parquet/data/readers/ParquetRecordReader.java | 5 +-
.../pinot/parquet/data/readers/ParquetUtils.java | 1 +
.../data/readers/ParquetRecordReaderTest.java | 66 ++
.../pinot-thrift}/pom.xml | 56 +-
.../ThriftRecordReader.java | 3 +-
.../ThriftRecordReaderConfig.java | 2 +-
.../ThriftRecordReaderTest.java | 6 +-
.../ThriftSampleData.java | 2 +-
pinot-server/pom.xml | 4 -
.../server/request/ScheduledRequestHandler.java | 77 ---
.../apache/pinot/server/starter/ServerBuilder.java | 14 +-
.../request/ScheduledRequestHandlerTest.java | 210 ------
.../apache/pinot/server/util/SegmentTestUtils.java | 2 +-
pinot-spi/pom.xml | 4 +
.../pinot/spi}/data/readers/RecordReaderUtils.java | 6 +-
.../spi/data/readers/AbstractRecordReaderTest.java | 167 +++++
.../spi}/data/readers/RecordReaderUtilsTest.java | 2 +-
.../admin/command/AvroSchemaToPinotSchema.java | 2 +-
.../admin/command/StreamAvroIntoKafkaCommand.java | 2 +-
.../converter/PinotSegmentToAvroConverter.java | 2 +-
pinot-transport/pom.xml | 114 ----
.../common/AbstractCompositeListenableFuture.java | 238 -------
.../transport/common/AsyncResponseFuture.java | 343 ----------
.../apache/pinot/transport/common/Callback.java | 39 --
.../apache/pinot/transport/common/Cancellable.java | 28 -
.../pinot/transport/common/CompositeFuture.java | 228 -------
.../pinot/transport/common/LinkedDequeue.java | 359 -----------
.../apache/pinot/transport/common/NoneType.java | 28 -
.../pinot/transport/common/SelectingFuture.java | 178 ------
.../transport/common/ServerResponseFuture.java | 96 ---
.../pinot/transport/conf/TransportClientConf.java | 77 ---
.../transport/config/ConnectionPoolConfig.java | 138 ----
.../transport/config/PerTableRoutingConfig.java | 145 -----
.../pinot/transport/config/RoutingTableConfig.java | 81 ---
.../pinot/transport/config/ThreadPoolConfig.java | 79 ---
.../transport/metrics/AggregatedPoolStats.java | 249 --------
.../metrics/AggregatedTransportClientMetrics.java | 200 ------
.../metrics/AggregatedTransportServerMetrics.java | 180 ------
.../pinot/transport/metrics/AsyncPoolStats.java | 239 -------
.../transport/metrics/NettyClientMetrics.java | 168 -----
.../transport/metrics/NettyServerMetrics.java | 138 ----
.../apache/pinot/transport/metrics/PoolStats.java | 164 -----
.../pinot/transport/metrics/PoolStatsProvider.java | 35 -
.../transport/metrics/TransportClientMetrics.java | 69 --
.../transport/metrics/TransportServerMetrics.java | 63 --
.../transport/netty/NettyClientConnection.java | 152 -----
.../apache/pinot/transport/netty/NettyServer.java | 313 ---------
.../transport/netty/NettyTCPClientConnection.java | 435 -------------
.../pinot/transport/netty/NettyTCPServer.java | 118 ----
.../netty/PooledNettyClientResourceManager.java | 146 -----
.../org/apache/pinot/transport/pool/AsyncPool.java | 136 ----
.../apache/pinot/transport/pool/AsyncPoolImpl.java | 711 ---------------------
.../pool/AsyncPoolResourceManagerAdapter.java | 125 ----
.../org/apache/pinot/transport/pool/KeyedPool.java | 108 ----
.../apache/pinot/transport/pool/KeyedPoolImpl.java | 223 -------
.../transport/pool/PooledResourceManager.java | 58 --
.../transport/pool/SizeLimitExceededException.java | 32 -
.../transport/scattergather/ScatterGather.java | 64 --
.../transport/scattergather/ScatterGatherImpl.java | 393 ------------
.../scattergather/ScatterGatherRequest.java | 65 --
.../scattergather/ScatterGatherStats.java | 112 ----
.../src/test/java/org/apache/pinot/Checkable.java | 31 -
.../src/test/java/org/apache/pinot/TestUtils.java | 57 --
.../transport/common/CompositeFutureTest.java | 662 -------------------
.../pinot/transport/common/ResponseFutureTest.java | 711 ---------------------
.../transport/common/SelectingFutureTest.java | 289 ---------
.../pinot/transport/common/ServerInstanceTest.java | 56 --
.../transport/netty/NettyCloseChannelTest.java | 123 ----
.../NettySingleConnectionIntegrationTest.java | 308 ---------
.../pinot/transport/netty/NettyTestUtils.java | 106 ---
.../transport/perf/ScatterGatherPerfClient.java | 481 --------------
.../transport/perf/ScatterGatherPerfServer.java | 204 ------
.../transport/perf/ScatterGatherPerfTester.java | 331 ----------
.../pool/AsyncPoolResourceManagerAdapterTest.java | 244 -------
.../pinot/transport/pool/KeyedPoolImplTest.java | 639 ------------------
.../transport/scattergather/ScatterGatherTest.java | 317 ---------
pom.xml | 19 +-
.../app/pods/self-serve/create-alert/controller.js | 8 +-
thirdeye/thirdeye-frontend/app/utils/utils.js | 2 +-
.../config/data-sources/cache-config.yml | 32 +-
.../anomaly/merge/AnomalyTimeBasedSummarizer.java | 1 +
.../context/AnomalyDetectionContext.java | 17 -
.../anomalydetection/context/AnomalyResult.java | 2 +
.../AbstractModularizedAnomalyFunction.java | 369 -----------
.../function/MinMaxThresholdFunction.java | 104 ---
.../ModularizedAnomalyFunctionModelProvider.java | 66 --
.../function/WeekOverWeekRuleFunction.java | 176 -----
.../model/data/AbstractDataModel.java | 36 --
.../anomalydetection/model/data/DataModel.java | 57 --
.../anomalydetection/model/data/NoopDataModel.java | 40 --
.../model/data/SeasonalDataModel.java | 82 ---
.../model/detection/AbstractDetectionModel.java | 36 --
.../model/detection/DetectionModel.java | 49 --
.../detection/MinMaxThresholdDetectionModel.java | 99 ---
.../model/detection/NoopDetectionModel.java | 32 -
.../detection/SimpleThresholdDetectionModel.java | 124 ----
.../model/merge/AbstractMergeModel.java | 36 --
.../anomalydetection/model/merge/MergeModel.java | 48 --
.../model/merge/MinMaxThresholdMergeModel.java | 93 ---
.../model/merge/NoPredictionMergeModel.java | 27 -
.../model/merge/NoopMergeModel.java | 31 -
.../model/merge/SimplePercentageMergeModel.java | 106 ---
.../model/prediction/AbstractPredictionModel.java | 36 --
.../ExpectedTimeSeriesPredictionModel.java | 31 -
.../model/prediction/NoopPredictionModel.java | 31 -
.../model/prediction/PredictionModel.java | 47 --
.../prediction/SeasonalAveragePredictionModel.java | 109 ----
.../transform/AbstractTransformationFunction.java | 36 --
.../model/transform/AnomalyRemovalFunction.java | 206 ------
.../transform/MovingAverageSmoothingFunction.java | 98 ---
.../TotalCountThresholdRemovalFunction.java | 70 --
.../model/transform/TransformationFunction.java | 54 --
.../model/transform/ZeroRemovalFunction.java | 53 --
.../api/user/dashboard/UserDashboardResource.java | 2 -
.../dashboard/resources/SummaryResource.java | 17 +-
.../datalayer/dto/MergedAnomalyResultDTO.java | 1 -
.../thirdeye/datasource/ThirdEyeCacheRegistry.java | 17 +-
.../thirdeye/detection/cache/CacheConfig.java | 26 +-
.../detection/cache/CacheConfigLoader.java | 7 +
.../pinot/thirdeye/detection/cache/CacheDAO.java | 41 ++
.../thirdeye/detection/cache/CacheDataSource.java | 28 +-
.../detection/cache/CentralizedCacheConfig.java | 2 +-
.../detection/cache/CouchbaseCacheDAO.java | 56 +-
.../detection/cache/DefaultTimeSeriesCache.java | 4 +-
.../thirdeye/detection/spi/model/AnomalySlice.java | 23 +-
.../org/apache/pinot/thirdeye/util/CacheUtils.java | 49 +-
.../merge/TestAnomalyTimeBasedSummarizer.java | 101 ---
.../function/TestAnomalyFunctionFactory.java | 67 --
.../function/TestMinMaxThresholdFunction.java | 206 ------
.../function/TestWeekOverWeekRuleFunction.java | 468 --------------
.../transform/testAnomalyRemovalFunction.java | 51 --
.../pinot/thirdeye/datalayer/DaoTestUtils.java | 15 -
.../bao/TestMergedAnomalyResultManager.java | 61 +-
.../pinot/thirdeye/detection/DataProviderTest.java | 29 +-
.../algorithm/LegacyAlertFilterWrapperTest.java | 109 ----
.../LegacyAnomalyFunctionAlgorithmTest.java | 98 ---
.../algorithm/LegacyDimensionWrapperTest.java | 154 -----
.../algorithm/LegacyMergeWrapperTest.java | 137 ----
.../LegacyEmulationIntegrationTest.java | 148 -----
.../AnomalyApplicationEndToEndTest.java | 435 -------------
231 files changed, 1333 insertions(+), 17820 deletions(-)
delete mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/LiveInstanceChangeHandler.java
delete mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/ConnectionPoolBrokerRequestHandler.java
delete mode 100644
pinot-common/src/main/java/org/apache/pinot/common/response/ServerInstance.java
copy
pinot-core/src/main/java/org/apache/pinot/core/segment/index/loader/{V3RemoveIndexException.java
=> V3UpdateIndexException.java} (80%)
delete mode 100644
pinot-core/src/test/java/org/apache/pinot/core/data/readers/CSVRecordReaderTest.java
delete mode 100644
pinot-core/src/test/java/org/apache/pinot/core/data/readers/JSONRecordReaderTest.java
delete mode 100644
pinot-core/src/test/java/org/apache/pinot/core/data/readers/RecordReaderTest.java
delete mode 100644
pinot-parquet/src/test/java/org/apache/pinot/parquet/data/readers/ParquetRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-avro}/pom.xml (72%)
rename {pinot-core/src/main/java/org/apache/pinot/core =>
pinot-record-readers/pinot-avro/src/main/java/org/apache/pinot/avro}/data/readers/AvroRecordReader.java
(96%)
copy {pinot-common/src/main/java/org/apache/pinot/common/utils =>
pinot-record-readers/pinot-avro/src/main/java/org/apache/pinot/avro/data/readers}/AvroSchemaUtil.java
(98%)
rename {pinot-core/src/main/java/org/apache/pinot/core/util =>
pinot-record-readers/pinot-avro/src/main/java/org/apache/pinot/avro/data/readers}/AvroUtils.java
(91%)
create mode 100644
pinot-record-readers/pinot-avro/src/test/java/org/apache/pinot/avro/data/readers/AvroRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-csv}/pom.xml (67%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-csv/src/main/java/org.apache.pinot.csv.data.readers}/CSVRecordReader.java
(97%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-csv/src/main/java/org.apache.pinot.csv.data.readers}/CSVRecordReaderConfig.java
(97%)
create mode 100644
pinot-record-readers/pinot-csv/src/test/java/org.apache.pinot.csv.data.readers/CSVRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-json}/pom.xml (67%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-json/src/main/java/org.apache.pinot.json.data.readers}/JSONRecordReader.java
(96%)
create mode 100644
pinot-record-readers/pinot-json/src/test/java/org.apache.pinot.json.data.readers/JSONRecordReaderTest.java
rename {pinot-orc => pinot-record-readers/pinot-orc}/pom.xml (96%)
rename {pinot-orc =>
pinot-record-readers/pinot-orc}/src/main/java/org/apache/pinot/orc/data/readers/ORCRecordReader.java
(100%)
rename {pinot-orc =>
pinot-record-readers/pinot-orc}/src/test/java/org/apache/pinot/orc/data/readers/ORCRecordReaderTest.java
(100%)
rename {pinot-parquet => pinot-record-readers/pinot-parquet}/pom.xml (86%)
rename {pinot-parquet =>
pinot-record-readers/pinot-parquet}/src/main/java/org/apache/pinot/parquet/data/readers/ParquetRecordReader.java
(96%)
rename {pinot-parquet =>
pinot-record-readers/pinot-parquet}/src/main/java/org/apache/pinot/parquet/data/readers/ParquetUtils.java
(98%)
create mode 100644
pinot-record-readers/pinot-parquet/src/test/java/org/apache/pinot/parquet/data/readers/ParquetRecordReaderTest.java
copy {pinot-hadoop-filesystem => pinot-record-readers/pinot-thrift}/pom.xml
(67%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/main/java/org.apache.pinot.thrift.data.readers}/ThriftRecordReader.java
(97%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/main/java/org.apache.pinot.thrift.data.readers}/ThriftRecordReaderConfig.java
(96%)
rename {pinot-core/src/test/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/test/java/org.apache.pinot.thrift.data.readers}/ThriftRecordReaderTest.java
(95%)
rename {pinot-core/src/test/java/org/apache/pinot/core/data/readers =>
pinot-record-readers/pinot-thrift/src/test/java/org.apache.pinot.thrift.data.readers}/ThriftSampleData.java
(99%)
delete mode 100644
pinot-server/src/main/java/org/apache/pinot/server/request/ScheduledRequestHandler.java
delete mode 100644
pinot-server/src/test/java/org/apache/pinot/server/request/ScheduledRequestHandlerTest.java
rename {pinot-core/src/main/java/org/apache/pinot/core =>
pinot-spi/src/main/java/org/apache/pinot/spi}/data/readers/RecordReaderUtils.java
(97%)
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/data/readers/AbstractRecordReaderTest.java
rename {pinot-core/src/test/java/org/apache/pinot/core =>
pinot-spi/src/test/java/org/apache/pinot/spi}/data/readers/RecordReaderUtilsTest.java
(98%)
delete mode 100644 pinot-transport/pom.xml
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/AbstractCompositeListenableFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/AsyncResponseFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/Callback.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/Cancellable.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/CompositeFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/LinkedDequeue.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/NoneType.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/SelectingFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/common/ServerResponseFuture.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/conf/TransportClientConf.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/ConnectionPoolConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/PerTableRoutingConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/RoutingTableConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/config/ThreadPoolConfig.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AggregatedPoolStats.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AggregatedTransportClientMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AggregatedTransportServerMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/AsyncPoolStats.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/NettyClientMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/NettyServerMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/PoolStats.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/PoolStatsProvider.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/TransportClientMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/metrics/TransportServerMetrics.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyClientConnection.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyServer.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyTCPClientConnection.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/NettyTCPServer.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/netty/PooledNettyClientResourceManager.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/AsyncPool.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/AsyncPoolImpl.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/AsyncPoolResourceManagerAdapter.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/KeyedPool.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/KeyedPoolImpl.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/PooledResourceManager.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/pool/SizeLimitExceededException.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGather.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGatherImpl.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGatherRequest.java
delete mode 100644
pinot-transport/src/main/java/org/apache/pinot/transport/scattergather/ScatterGatherStats.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/Checkable.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/TestUtils.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/CompositeFutureTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/ResponseFutureTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/SelectingFutureTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/common/ServerInstanceTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/netty/NettyCloseChannelTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/netty/NettySingleConnectionIntegrationTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/netty/NettyTestUtils.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/perf/ScatterGatherPerfClient.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/perf/ScatterGatherPerfServer.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/perf/ScatterGatherPerfTester.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/pool/AsyncPoolResourceManagerAdapterTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/pool/KeyedPoolImplTest.java
delete mode 100644
pinot-transport/src/test/java/org/apache/pinot/transport/scattergather/ScatterGatherTest.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/function/AbstractModularizedAnomalyFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/function/MinMaxThresholdFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/function/ModularizedAnomalyFunctionModelProvider.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/function/WeekOverWeekRuleFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/data/AbstractDataModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/data/DataModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/data/NoopDataModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/data/SeasonalDataModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/detection/AbstractDetectionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/detection/DetectionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/detection/MinMaxThresholdDetectionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/detection/NoopDetectionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/detection/SimpleThresholdDetectionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/merge/AbstractMergeModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/merge/MergeModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/merge/MinMaxThresholdMergeModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/merge/NoPredictionMergeModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/merge/NoopMergeModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/merge/SimplePercentageMergeModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/prediction/AbstractPredictionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/prediction/ExpectedTimeSeriesPredictionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/prediction/NoopPredictionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/prediction/PredictionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/prediction/SeasonalAveragePredictionModel.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/transform/AbstractTransformationFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/transform/AnomalyRemovalFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/transform/MovingAverageSmoothingFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/transform/TotalCountThresholdRemovalFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/transform/TransformationFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/anomalydetection/model/transform/ZeroRemovalFunction.java
create mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/cache/CacheDAO.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/anomaly/merge/TestAnomalyTimeBasedSummarizer.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/anomalydetection/function/TestAnomalyFunctionFactory.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/anomalydetection/function/TestMinMaxThresholdFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/anomalydetection/function/TestWeekOverWeekRuleFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/anomalydetection/model/transform/testAnomalyRemovalFunction.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/algorithm/LegacyAlertFilterWrapperTest.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/algorithm/LegacyAnomalyFunctionAlgorithmTest.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/algorithm/LegacyDimensionWrapperTest.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/algorithm/LegacyMergeWrapperTest.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/integration/LegacyEmulationIntegrationTest.java
delete mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/integration/AnomalyApplicationEndToEndTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
