You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ne...@apache.org on 2019/01/08 23:12:31 UTC
[incubator-pinot] branch split_validation_manager_periodic_tasks
updated (f3d7748 -> 53d112f)
This is an automated email from the ASF dual-hosted git repository.
nehapawar pushed a change to branch split_validation_manager_periodic_tasks
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from f3d7748 Using new defaults for each periodic task
add ef32663 [TE] backend - use task actual start time as start_time instead of create time (#3638)
add f7387e9 [TE] task - add metrics for task execution and gaude for backlog size (#3643)
add d1a46a6 Revert "[TE] task - add metrics for task execution and gaude for backlog size (#3643)" (#3645)
add c25e5ea Use ZkCacheBaseDataAccessor to cache instance configs in PinotHelixResourceManager (#3633)
add d95cb69 [TE] fix database connection close issue (#3647)
add a031e05 remove legacy codes (#3641)
add 0ea2232 [TE] Skip scheduling detection task if one is already in the queue (#3660)
add 6300558 [TE] fix detection config DTO revert in yaml alert creation (#3662)
add 06dc0e9 [TE] rootcause - fix slider and offset quirks (#3663)
add 969e471 [TE] frontend - harleyjj/home - make email share available even when there are no anomalies (#3632)
add 842678d [TE] task - yet another backlog gauge fix (#3666)
add 46ad4f9 Update license header (#3664)
add 8430409 Split ValidationManager duties into separate ControllerPeriodicTasks
add e64b393 Change access modifier of some fields
add 2f50d8e Move some code inside the if check for table type
add 123bb8c Review comments
add b097306 Use controller validation frequency as default values for new periodic validation tasks
add 0c38d6d Change DEFAULT_OFFLINE_SEGMENT_INTERVAL_CHECKER_FREQUENCY_IN_SECONDS to 24 hours, to match current default behavior (segment level validation interval)
add 5dab3b1 Using new defaults for each periodic task
add 53d112f Merge branch 'split_validation_manager_periodic_tasks' of github.com:linkedin/pinot into split_validation_manager_periodic_tasks
No new revisions were added by this update.
Summary of changes:
.codecov.yml | 25 +--
.travis_install.sh | 25 +--
.travis_test.sh | 25 +--
contrib/pinot-druid-benchmark/pom.xml | 25 +--
contrib/pinot-druid-benchmark/run_benchmark.sh | 25 +--
.../linkedin/pinotdruidbenchmark/DataMerger.java | 25 +--
.../pinotdruidbenchmark/DataSeparator.java | 25 +--
.../pinotdruidbenchmark/DruidResponseTime.java | 25 +--
.../pinotdruidbenchmark/DruidThroughput.java | 25 +--
.../pinotdruidbenchmark/PinotResponseTime.java | 25 +--
.../pinotdruidbenchmark/PinotThroughput.java | 25 +--
docs/conf.py | 25 +--
docs/make.bat | 25 +--
license.header | 16 ++
pinot-api/pom.xml | 25 +--
.../linkedin/pinot/client/AbstractResultSet.java | 25 +--
.../pinot/client/AggregationResultSet.java | 25 +--
.../com/linkedin/pinot/client/BrokerResponse.java | 25 +--
.../com/linkedin/pinot/client/BrokerSelector.java | 25 +--
.../java/com/linkedin/pinot/client/Connection.java | 25 +--
.../linkedin/pinot/client/ConnectionFactory.java | 25 +--
.../pinot/client/DynamicBrokerSelector.java | 25 +--
.../linkedin/pinot/client/ExternalViewReader.java | 25 +--
.../linkedin/pinot/client/GroupByResultSet.java | 25 +--
.../client/JsonAsyncHttpPinotClientTransport.java | 25 +--
.../JsonAsyncHttpPinotClientTransportFactory.java | 25 +--
.../pinot/client/PinotClientException.java | 25 +--
.../pinot/client/PinotClientTransport.java | 25 +--
.../pinot/client/PinotClientTransportFactory.java | 25 +--
.../linkedin/pinot/client/PreparedStatement.java | 25 +--
.../java/com/linkedin/pinot/client/ResultSet.java | 25 +--
.../com/linkedin/pinot/client/ResultSetGroup.java | 25 +--
.../linkedin/pinot/client/SelectionResultSet.java | 25 +--
.../pinot/client/SimpleBrokerSelector.java | 25 +--
.../java/com/linkedin/pinot/client/TextTable.java | 25 +--
.../com/linkedin/pinot/client/package-info.java | 29 +--
.../pinot/client/ConnectionFactoryTest.java | 25 +--
.../pinot/client/PreparedStatementTest.java | 25 +--
.../linkedin/pinot/client/ResultSetGroupTest.java | 25 +--
pinot-azure-filesystem/pom.xml | 25 +--
.../linkedin/pinot/filesystem/AzurePinotFS.java | 25 +--
.../pinot/filesystem/test/AzurePinotFSTest.java | 25 +--
.../datalake/store/MockADLFileInputStream.java | 25 +--
pinot-broker/pom.xml | 25 +--
.../linkedin/pinot/broker/api/AccessControl.java | 25 +--
.../pinot/broker/api/RequestStatistics.java | 26 +--
.../pinot/broker/api/RequesterIdentity.java | 25 +--
.../broker/api/resources/PinotBrokerDebug.java | 25 +--
.../api/resources/PinotBrokerHealthCheck.java | 25 +--
.../broker/api/resources/PinotClientRequest.java | 25 +--
.../pinot/broker/broker/AccessControlFactory.java | 25 +--
.../broker/AllowAllAccessControlFactory.java | 25 +--
.../broker/broker/BrokerAdminApiApplication.java | 25 +--
.../pinot/broker/broker/BrokerServerBuilder.java | 25 +--
...okerResourceOnlineOfflineStateModelFactory.java | 25 +--
.../broker/broker/helix/ClusterChangeMediator.java | 25 +--
.../broker/helix/DefaultHelixBrokerConfig.java | 25 +--
.../broker/broker/helix/HelixBrokerStarter.java | 25 +--
.../helix/LiveInstancesChangeListenerImpl.java | 25 +--
.../TimeboundaryRefreshMessageHandlerFactory.java | 25 +--
.../broker/pruner/PartitionZKMetadataPruner.java | 25 +--
.../pinot/broker/pruner/SegmentPrunerContext.java | 25 +--
.../broker/pruner/SegmentZKMetadataPruner.java | 25 +--
.../pruner/SegmentZKMetadataPrunerProvider.java | 25 +--
.../pruner/SegmentZKMetadataPrunerService.java | 25 +--
.../pinot/broker/queryquota/HitCounter.java | 25 +--
.../pinot/broker/queryquota/QueryQuotaConfig.java | 25 +--
.../broker/queryquota/TableQueryQuotaManager.java | 25 +--
.../requesthandler/BaseBrokerRequestHandler.java | 25 +--
.../requesthandler/BrokerRequestHandler.java | 25 +--
.../requesthandler/BrokerRequestOptimizer.java | 25 +--
.../ConnectionPoolBrokerRequestHandler.java | 25 +--
.../FilterQueryOptimizerRequest.java | 25 +--
.../requesthandler/FilterQueryTreeOptimizer.java | 25 +--
...enNestedPredicatesFilterQueryTreeOptimizer.java | 25 +--
...ualitiesToInClauseFilterQueryTreeOptimizer.java | 25 +--
.../broker/requesthandler/OptimizationFlags.java | 25 +--
.../broker/requesthandler/RangeMergeOptimizer.java | 25 +--
.../SingleConnectionBrokerRequestHandler.java | 25 +--
.../pinot/broker/routing/CfgBasedRouting.java | 25 +--
.../routing/HelixExternalViewBasedRouting.java | 25 +--
.../HelixExternalViewBasedTimeBoundaryService.java | 25 +--
.../pinot/broker/routing/RoutingTable.java | 25 +--
.../broker/routing/RoutingTableBuilderFactory.java | 25 +--
.../broker/routing/RoutingTableLookupRequest.java | 25 +--
.../pinot/broker/routing/TimeBoundaryService.java | 25 +--
.../builder/BalancedRandomRoutingTableBuilder.java | 25 +--
.../BasePartitionAwareRoutingTableBuilder.java | 25 +--
.../routing/builder/BaseRoutingTableBuilder.java | 25 +--
.../builder/DefaultOfflineRoutingTableBuilder.java | 25 +--
.../DefaultRealtimeRoutingTableBuilder.java | 25 +--
.../builder/GeneratorBasedRoutingTableBuilder.java | 25 +--
.../HighLevelConsumerBasedRoutingTableBuilder.java | 25 +--
.../builder/LargeClusterRoutingTableBuilder.java | 25 +--
.../LowLevelConsumerRoutingTableBuilder.java | 25 +--
.../builder/LowLevelRoutingTableBuilderUtil.java | 25 +--
.../PartitionAwareOfflineRoutingTableBuilder.java | 25 +--
.../PartitionAwareRealtimeRoutingTableBuilder.java | 25 +--
.../routing/builder/RoutingTableBuilder.java | 25 +--
.../builder/RoutingTableInstancePruner.java | 25 +--
.../routing/selector/MergedSegmentSelector.java | 25 +--
.../broker/routing/selector/SegmentSelector.java | 25 +--
.../routing/selector/SegmentSelectorProvider.java | 25 +--
.../pinot/broker/broker/BrokerTestUtils.java | 25 +--
.../EmptyBrokerOnlineOfflineStateModelFactory.java | 25 +--
...EmptySegmentOnlineOfflineStateModelFactory.java | 25 +--
.../broker/broker/HelixBrokerStarterTest.java | 25 +--
.../broker/broker/HelixBrokerStarterUtilsTest.java | 25 +--
.../broker/pruner/SegmentZKMetadataPrunerTest.java | 25 +--
.../pinot/broker/queryquota/HitCounterTest.java | 25 +--
.../queryquota/TableQueryQuotaManagerTest.java | 25 +--
.../broker/requesthandler/FilterOptimizerTest.java | 25 +--
...tiesToInClauseFilterQueryTreeOptimizerTest.java | 25 +--
.../requesthandler/OptimizationFlagsTest.java | 25 +--
.../requesthandler/RangeMergeOptimizerTest.java | 25 +--
.../broker/routing/RandomRoutingTableTest.java | 25 +--
.../pinot/broker/routing/RoutingTableTest.java | 25 +--
.../broker/routing/TimeBoundaryServiceTest.java | 25 +--
.../BalancedRandomRoutingTableBuilderTest.java | 25 +--
.../HighLevelConsumerRoutingTableBuilderTest.java | 25 +--
.../LargeClusterRoutingTableBuilderTest.java | 25 +--
.../LowLevelConsumerRoutingTableBuilderTest.java | 25 +--
...rtitionAwareOfflineRoutingTableBuilderTest.java | 25 +--
...titionAwareRealtimeRoutingTableBuilderTest.java | 25 +--
.../builder/RoutingTableBuilderTestUtil.java | 25 +--
.../selector/MergedSegmentSelectorTest.java | 25 +--
.../pinot/broker/util/FakePropertyStore.java | 25 +--
pinot-common/pom.xml | 25 +--
.../antlr4/com/linkedin/pinot/pql/parsers/PQL2.g4 | 25 +--
.../main/java/com/linkedin/pinot/common/Utils.java | 25 +--
.../config/AdjustTableNameChildKeyTransformer.java | 25 +--
.../pinot/common/config/ChildKeyHandler.java | 25 +--
.../pinot/common/config/ChildKeyTransformer.java | 25 +--
.../pinot/common/config/ColumnPartitionConfig.java | 25 +--
.../config/ColumnPartitionMapChildKeyHandler.java | 25 +--
.../pinot/common/config/CombinedConfig.java | 25 +--
.../pinot/common/config/CombinedConfigLoader.java | 25 +--
...CombinedConfigSeparatorChildKeyTransformer.java | 25 +--
.../linkedin/pinot/common/config/ConfigDoc.java | 25 +--
.../linkedin/pinot/common/config/ConfigKey.java | 25 +--
.../common/config/ConfigNodeLifecycleAware.java | 25 +--
.../linkedin/pinot/common/config/Deserializer.java | 25 +--
.../com/linkedin/pinot/common/config/Duration.java | 25 +--
.../linkedin/pinot/common/config/DurationDsl.java | 25 +--
.../pinot/common/config/IndexingConfig.java | 25 +--
.../common/config/NamedListChildKeyHandler.java | 25 +--
.../linkedin/pinot/common/config/NestedConfig.java | 25 +--
.../pinot/common/config/OfflineTagConfig.java | 25 +--
.../pinot/common/config/PinotTaskConfig.java | 25 +--
.../linkedin/pinot/common/config/QuotaConfig.java | 25 +--
.../pinot/common/config/RealtimeTagConfig.java | 25 +--
.../config/RemapTableTypesChildKeyTransformer.java | 25 +--
.../common/config/ReplicaGroupStrategyConfig.java | 25 +--
.../pinot/common/config/RoutingConfig.java | 25 +--
.../common/config/SegmentPartitionConfig.java | 25 +--
.../SegmentsValidationAndRetentionConfig.java | 25 +--
.../linkedin/pinot/common/config/Serializer.java | 25 +--
.../common/config/SimpleMapChildKeyHandler.java | 25 +--
.../linkedin/pinot/common/config/SingleKeyDsl.java | 25 +--
.../pinot/common/config/StarTreeIndexConfig.java | 25 +--
.../common/config/StreamConsumptionConfig.java | 25 +--
.../linkedin/pinot/common/config/TableConfig.java | 25 +--
.../pinot/common/config/TableCustomConfig.java | 25 +--
.../pinot/common/config/TableNameBuilder.java | 25 +--
.../pinot/common/config/TableTaskConfig.java | 25 +--
.../linkedin/pinot/common/config/TagConfig.java | 25 +--
.../linkedin/pinot/common/config/TagNameUtils.java | 25 +--
.../pinot/common/config/TagOverrideConfig.java | 25 +--
.../config/TaskConfigMapChildKeyHandler.java | 25 +--
.../com/linkedin/pinot/common/config/Tenant.java | 25 +--
.../linkedin/pinot/common/config/TenantConfig.java | 25 +--
.../common/config/TypedMapChildKeyHandler.java | 25 +--
.../pinot/common/config/UseChildKeyHandler.java | 25 +--
.../common/config/UseChildKeyTransformers.java | 25 +--
.../com/linkedin/pinot/common/config/UseDsl.java | 25 +--
.../pinot/common/data/DateTimeFieldSpec.java | 25 +--
.../data/DateTimeFieldSpecChildKeyHandler.java | 25 +--
.../common/data/DateTimeFormatPatternSpec.java | 25 +--
.../pinot/common/data/DateTimeFormatSpec.java | 25 +--
.../pinot/common/data/DateTimeFormatUnitSpec.java | 25 +--
.../pinot/common/data/DateTimeGranularitySpec.java | 25 +--
.../pinot/common/data/DimensionFieldSpec.java | 25 +--
.../data/DimensionFieldSpecChildKeyHandler.java | 25 +--
.../com/linkedin/pinot/common/data/FieldSpec.java | 25 +--
.../pinot/common/data/MetricFieldSpec.java | 25 +--
.../data/MetricFieldSpecChildKeyHandler.java | 25 +--
.../com/linkedin/pinot/common/data/RowEvent.java | 25 +--
.../com/linkedin/pinot/common/data/Schema.java | 25 +--
.../com/linkedin/pinot/common/data/Segment.java | 25 +--
.../pinot/common/data/StarTreeIndexSpec.java | 25 +--
.../linkedin/pinot/common/data/TimeFieldSpec.java | 25 +--
.../pinot/common/data/TimeGranularitySpec.java | 25 +--
.../common/exception/HttpErrorStatusException.java | 25 +--
.../common/exception/InvalidConfigException.java | 25 +--
.../pinot/common/exception/QueryException.java | 25 +--
.../common/exception/TableNotFoundException.java | 25 +--
.../pinot/common/http/MultiGetRequest.java | 25 +--
.../pinot/common/lineage/SegmentGroup.java | 25 +--
.../pinot/common/lineage/SegmentMergeLineage.java | 25 +--
.../lineage/SegmentMergeLineageAccessHelper.java | 25 +--
.../common/messages/SegmentRefreshMessage.java | 25 +--
.../common/messages/SegmentReloadMessage.java | 25 +--
.../messages/TimeboundaryRefreshMessage.java | 25 +--
.../linkedin/pinot/common/metadata/ZKMetadata.java | 25 +--
.../pinot/common/metadata/ZKMetadataProvider.java | 25 +--
.../metadata/instance/InstanceZKMetadata.java | 25 +--
.../metadata/segment/ColumnPartitionMetadata.java | 25 +--
.../segment/LLCRealtimeSegmentZKMetadata.java | 25 +--
.../metadata/segment/OfflineSegmentZKMetadata.java | 25 +--
.../segment/RealtimeSegmentZKMetadata.java | 25 +--
.../metadata/segment/SegmentPartitionMetadata.java | 25 +--
.../common/metadata/segment/SegmentZKMetadata.java | 25 +--
.../SegmentZKMetadataCustomMapModifier.java | 25 +--
.../pinot/common/metrics/AbstractMetrics.java | 25 +--
.../pinot/common/metrics/AggregatedCounter.java | 25 +--
.../pinot/common/metrics/AggregatedHistogram.java | 25 +--
.../pinot/common/metrics/AggregatedLongGauge.java | 25 +--
.../pinot/common/metrics/AggregatedMeter.java | 25 +--
.../common/metrics/AggregatedMetricsRegistry.java | 25 +--
.../linkedin/pinot/common/metrics/BrokerGauge.java | 25 +--
.../linkedin/pinot/common/metrics/BrokerMeter.java | 25 +--
.../pinot/common/metrics/BrokerMetrics.java | 25 +--
.../pinot/common/metrics/BrokerQueryPhase.java | 25 +--
.../linkedin/pinot/common/metrics/BrokerTimer.java | 25 +--
.../pinot/common/metrics/ControllerGauge.java | 25 +--
.../pinot/common/metrics/ControllerMeter.java | 25 +--
.../pinot/common/metrics/ControllerMetrics.java | 25 +--
.../pinot/common/metrics/ControllerTimer.java | 25 +--
...eporterMetricsRegistryRegistrationListener.java | 25 +--
.../pinot/common/metrics/LatencyMetric.java | 25 +--
.../pinot/common/metrics/MetricsHelper.java | 25 +--
.../MetricsRegistryRegistrationListener.java | 25 +--
.../linkedin/pinot/common/metrics/ServerGauge.java | 25 +--
.../linkedin/pinot/common/metrics/ServerMeter.java | 25 +--
.../pinot/common/metrics/ServerMetrics.java | 25 +--
.../pinot/common/metrics/ServerQueryPhase.java | 25 +--
.../linkedin/pinot/common/metrics/ServerTimer.java | 25 +--
.../pinot/common/metrics/ValidationMetrics.java | 25 +--
.../common/partition/PartitionAssignment.java | 25 +--
.../partition/ReplicaGroupPartitionAssignment.java | 25 +--
.../ReplicaGroupPartitionAssignmentGenerator.java | 25 +--
.../StreamPartitionAssignmentGenerator.java | 25 +--
.../protocols/SegmentCompletionProtocol.java | 25 +--
.../linkedin/pinot/common/query/ReduceService.java | 25 +--
.../pinot/common/query/ReduceServiceRegistry.java | 25 +--
.../pinot/common/request/AggregationInfo.java | 18 ++
.../pinot/common/request/BrokerRequest.java | 18 ++
.../pinot/common/request/FilterOperator.java | 18 ++
.../linkedin/pinot/common/request/FilterQuery.java | 18 ++
.../pinot/common/request/FilterQueryMap.java | 18 ++
.../com/linkedin/pinot/common/request/GroupBy.java | 18 ++
.../pinot/common/request/HavingFilterQuery.java | 18 ++
.../pinot/common/request/HavingFilterQueryMap.java | 18 ++
.../pinot/common/request/InstanceRequest.java | 18 ++
.../linkedin/pinot/common/request/QuerySource.java | 18 ++
.../linkedin/pinot/common/request/QueryType.java | 18 ++
.../linkedin/pinot/common/request/Selection.java | 18 ++
.../pinot/common/request/SelectionSort.java | 18 ++
.../request/transform/TransformExpressionTree.java | 25 +--
.../pinot/common/response/BrokerResponse.java | 25 +--
.../common/response/BrokerResponseFactory.java | 25 +--
.../pinot/common/response/ProcessingException.java | 18 ++
.../pinot/common/response/ServerInstance.java | 25 +--
.../common/response/broker/AggregationResult.java | 25 +--
.../response/broker/BrokerResponseNative.java | 25 +--
.../common/response/broker/GroupByResult.java | 25 +--
.../response/broker/QueryProcessingException.java | 25 +--
.../common/response/broker/SelectionResults.java | 25 +--
.../common/restlet/resources/RebalanceResult.java | 25 +--
.../common/restlet/resources/ResourceUtils.java | 25 +--
.../common/restlet/resources/SegmentSizeInfo.java | 25 +--
.../common/restlet/resources/TableSegments.java | 25 +--
.../common/restlet/resources/TableSizeInfo.java | 25 +--
.../pinot/common/restlet/resources/TablesList.java | 25 +--
.../linkedin/pinot/common/segment/ReadMode.java | 25 +--
.../pinot/common/segment/SegmentMetadata.java | 25 +--
.../pinot/common/segment/StarTreeMetadata.java | 25 +--
.../common/segment/fetcher/HdfsSegmentFetcher.java | 25 +--
.../common/segment/fetcher/HttpSegmentFetcher.java | 25 +--
.../segment/fetcher/HttpsSegmentFetcher.java | 25 +--
.../segment/fetcher/LocalFileSegmentFetcher.java | 25 +--
.../pinot/common/segment/fetcher/NoOpFetcher.java | 25 +--
.../segment/fetcher/PinotFSSegmentFetcher.java | 25 +--
.../common/segment/fetcher/SegmentFetcher.java | 25 +--
.../segment/fetcher/SegmentFetcherFactory.java | 25 +--
.../common/utils/ClientSSLContextGenerator.java | 26 +--
.../pinot/common/utils/CommonConstants.java | 25 +--
.../linkedin/pinot/common/utils/DataSchema.java | 25 +--
.../com/linkedin/pinot/common/utils/DataSize.java | 25 +--
.../com/linkedin/pinot/common/utils/DataTable.java | 25 +--
.../linkedin/pinot/common/utils/EqualityUtils.java | 25 +--
.../common/utils/FileUploadDownloadClient.java | 25 +--
.../com/linkedin/pinot/common/utils/FileUtils.java | 25 +--
.../pinot/common/utils/HLCSegmentName.java | 25 +--
.../com/linkedin/pinot/common/utils/HashUtil.java | 25 +--
.../pinot/common/utils/KafkaStarterUtils.java | 25 +--
.../pinot/common/utils/LLCSegmentName.java | 25 +--
.../com/linkedin/pinot/common/utils/LLCUtils.java | 25 +--
.../com/linkedin/pinot/common/utils/LogUtils.java | 25 +--
.../pinot/common/utils/NamedThreadFactory.java | 18 ++
.../com/linkedin/pinot/common/utils/NetUtil.java | 25 +--
.../com/linkedin/pinot/common/utils/Pairs.java | 25 +--
.../pinot/common/utils/PrimitiveArrayUtils.java | 25 +--
.../linkedin/pinot/common/utils/SchemaUtils.java | 25 +--
.../linkedin/pinot/common/utils/SegmentName.java | 25 +--
.../linkedin/pinot/common/utils/ServerType.java | 25 +--
.../linkedin/pinot/common/utils/ServiceStatus.java | 25 +--
.../pinot/common/utils/SimpleHttpResponse.java | 25 +--
.../linkedin/pinot/common/utils/StringUtil.java | 25 +--
.../pinot/common/utils/TarGzCompressionUtils.java | 25 +--
.../linkedin/pinot/common/utils/TenantRole.java | 25 +--
.../com/linkedin/pinot/common/utils/ZkStarter.java | 25 +--
.../pinot/common/utils/helix/HelixHelper.java | 25 +--
.../PinotHelixPropertyStoreZnRecordProvider.java | 25 +--
.../pinot/common/utils/primitive/ByteArray.java | 25 +--
.../common/utils/request/FilterQueryTree.java | 25 +--
.../common/utils/request/HavingQueryTree.java | 25 +--
.../pinot/common/utils/request/QueryTree.java | 25 +--
.../pinot/common/utils/request/RequestUtils.java | 25 +--
.../utils/retry/AttemptFailureException.java | 25 +--
.../utils/retry/AttemptsExceededException.java | 25 +--
.../pinot/common/utils/retry/BaseRetryPolicy.java | 25 +--
.../utils/retry/ExponentialBackoffRetryPolicy.java | 25 +--
.../common/utils/retry/FixedDelayRetryPolicy.java | 25 +--
.../common/utils/retry/NoDelayRetryPolicy.java | 25 +--
.../utils/retry/RetriableOperationException.java | 25 +--
.../pinot/common/utils/retry/RetryPolicies.java | 25 +--
.../pinot/common/utils/retry/RetryPolicy.java | 25 +--
.../pinot/common/utils/time/TimeConverter.java | 25 +--
.../pinot/common/utils/time/TimeUtils.java | 25 +--
.../common/utils/webhdfs/WebHdfsV1Client.java | 25 +--
.../pinot/pql/parsers/AbstractCompiler.java | 25 +--
.../pinot/pql/parsers/Pql2AstListener.java | 25 +--
.../pql/parsers/Pql2CompilationException.java | 25 +--
.../linkedin/pinot/pql/parsers/Pql2Compiler.java | 25 +--
.../pinot/pql/parsers/pql2/ast/AstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/BaseAstNode.java | 25 +--
.../parsers/pql2/ast/BetweenPredicateAstNode.java | 25 +--
.../pql/parsers/pql2/ast/BinaryMathOpAstNode.java | 25 +--
.../parsers/pql2/ast/BooleanOperatorAstNode.java | 25 +--
.../pql2/ast/ComparisonPredicateAstNode.java | 25 +--
.../ast/ExpressionParenthesisGroupAstNode.java | 25 +--
.../pql2/ast/FloatingPointLiteralAstNode.java | 25 +--
.../pql/parsers/pql2/ast/FunctionCallAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/GroupByAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/HavingAstNode.java | 25 +--
.../pql/parsers/pql2/ast/IdentifierAstNode.java | 25 +--
.../pql/parsers/pql2/ast/InPredicateAstNode.java | 25 +--
.../parsers/pql2/ast/IntegerLiteralAstNode.java | 25 +--
.../pql/parsers/pql2/ast/IsPredicateAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/LimitAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/LiteralAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/OptionAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/OptionsAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/OrderByAstNode.java | 25 +--
.../parsers/pql2/ast/OrderByExpressionAstNode.java | 25 +--
.../pql/parsers/pql2/ast/OutputColumnAstNode.java | 25 +--
.../parsers/pql2/ast/OutputColumnListAstNode.java | 25 +--
.../pql/parsers/pql2/ast/PredicateAstNode.java | 25 +--
.../pql/parsers/pql2/ast/PredicateListAstNode.java | 25 +--
.../pql2/ast/PredicateParenthesisGroupAstNode.java | 25 +--
.../pql2/ast/RegexpLikePredicateAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/SelectAstNode.java | 25 +--
.../parsers/pql2/ast/StarColumnListAstNode.java | 25 +--
.../parsers/pql2/ast/StarExpressionAstNode.java | 25 +--
.../pql/parsers/pql2/ast/StringLiteralAstNode.java | 25 +--
.../pql/parsers/pql2/ast/TableNameAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/TopAstNode.java | 25 +--
.../pinot/pql/parsers/pql2/ast/WhereAstNode.java | 25 +--
.../com/linkedin/pinot/pql/parsers/utils/Pair.java | 25 +--
.../main/java/com/linkedin/pinot/serde/SerDe.java | 25 +--
.../com/linkedin/pinot/startree/hll/HllConfig.java | 25 +--
.../linkedin/pinot/startree/hll/HllConstants.java | 25 +--
.../linkedin/pinot/startree/hll/HllSizeUtils.java | 25 +--
.../pinot/common/config/IndexingConfigTest.java | 25 +--
.../pinot/common/config/QuotaConfigTest.java | 25 +--
.../pinot/common/config/TableConfigTest.java | 25 +--
.../pinot/common/config/TagOverrideConfigTest.java | 25 +--
.../linkedin/pinot/common/config/TenantTest.java | 25 +--
.../common/config/TestConfigSerialization.java | 25 +--
.../pinot/common/data/DateTimeFormatSpecTest.java | 25 +--
.../common/data/DateTimeGranularitySpecTest.java | 25 +--
.../linkedin/pinot/common/data/FieldSpecTest.java | 25 +--
.../com/linkedin/pinot/common/data/SchemaTest.java | 25 +--
.../pinot/common/http/MultiGetRequestTest.java | 25 +--
.../common/lineage/SegmentMergeLineageTest.java | 25 +--
.../common/metadata/InstanceZKMetadataTest.java | 25 +--
.../metadata/MetadataEqualsHashCodeTest.java | 25 +--
.../pinot/common/metadata/MetadataUtils.java | 25 +--
.../common/metadata/SegmentZKMetadataTest.java | 25 +--
.../pinot/common/metrics/MetricsHelperTest.java | 25 +--
.../common/partition/IdealStateBuilderUtil.java | 25 +--
.../StreamPartitionAssignmentGeneratorTest.java | 25 +--
.../pinot/common/query/gen/AvroQueryGenerator.java | 25 +--
.../transform/TransformExpressionTreeTest.java | 25 +--
.../segment/fetcher/SegmentFetcherFactoryTest.java | 25 +--
.../pinot/common/utils/DataSchemaTest.java | 25 +--
.../linkedin/pinot/common/utils/DataSizeTest.java | 25 +--
.../pinot/common/utils/EqualityUtilsTest.java | 25 +--
.../common/utils/FileUploadDownloadClientTest.java | 25 +--
.../pinot/common/utils/SegmentNameBuilderTest.java | 25 +--
.../pinot/common/utils/ServiceStatusTest.java | 25 +--
.../pinot/common/utils/StringUtilTest.java | 25 +--
.../common/utils/TarGzCompressionUtilsTest.java | 25 +--
.../com/linkedin/pinot/common/utils/UtilsTest.java | 25 +--
.../pinot/common/utils/retry/RetryPolicyTest.java | 25 +--
.../pinot/common/utils/time/TimeConverterTest.java | 25 +--
.../pinot/pql/parsers/Pql2CompilerTest.java | 25 +--
.../request/BrokerRequestSerializationTest.java | 25 +--
.../pinot/request/BrokerResponseNativeTest.java | 25 +--
pinot-common/src/thrift/request.thrift | 25 +--
pinot-common/src/thrift/response.thrift | 25 +--
pinot-controller/pom.xml | 25 +--
.../linkedin/pinot/controller/ControllerConf.java | 28 +--
.../controller/ControllerLeadershipManager.java | 26 +--
.../pinot/controller/ControllerStarter.java | 25 +--
.../controller/LeadershipChangeSubscriber.java | 25 +--
.../pinot/controller/api/CallableHttpGet.java | 25 +--
.../api/ControllerAdminApiApplication.java | 25 +--
.../pinot/controller/api/access/AccessControl.java | 25 +--
.../api/access/AccessControlFactory.java | 25 +--
.../api/access/AllowAllAccessFactory.java | 25 +--
.../api/events/DefaultMetadataEventNotifier.java | 25 +--
.../DefaultMetadataEventNotifierFactory.java | 25 +--
.../api/events/MetadataEventNotifier.java | 25 +--
.../api/events/MetadataEventNotifierFactory.java | 25 +--
.../controller/api/events/SchemaEventType.java | 25 +--
.../pinot/controller/api/pojos/Instance.java | 25 +--
.../pinot/controller/api/resources/Constants.java | 25 +--
.../resources/ControllerApplicationException.java | 25 +--
.../api/resources/ControllerResponseFilter.java | 25 +--
.../api/resources/FileUploadPathProvider.java | 25 +--
.../controller/api/resources/HeaderAdder.java | 25 +--
.../InvalidControllerConfigException.java | 25 +--
.../resources/LLCSegmentCompletionHandlers.java | 25 +--
.../api/resources/LandingPageHandler.java | 25 +--
.../api/resources/PinotControllerHealthCheck.java | 25 +--
.../resources/PinotControllerResponseFilter.java | 25 +--
.../resources/PinotInstanceRestletResource.java | 25 +--
.../api/resources/PinotSchemaRestletResource.java | 25 +--
.../api/resources/PinotSegmentRestletResource.java | 25 +--
.../PinotSegmentUploadRestletResource.java | 25 +--
.../resources/PinotTableConfigRestletResource.java | 25 +--
.../api/resources/PinotTableIndexingConfigs.java | 25 +--
.../api/resources/PinotTableInstances.java | 25 +--
.../api/resources/PinotTableMetadataConfigs.java | 25 +--
.../api/resources/PinotTableRestletResource.java | 25 +--
.../controller/api/resources/PinotTableSchema.java | 25 +--
.../api/resources/PinotTableSegmentConfigs.java | 25 +--
.../api/resources/PinotTableTenantConfigs.java | 25 +--
.../api/resources/PinotTaskRestletResource.java | 25 +--
.../api/resources/PinotTenantRestletResource.java | 25 +--
.../api/resources/PinotVersionRestletResource.java | 25 +--
.../controller/api/resources/PqlQueryResource.java | 25 +--
.../api/resources/ServerTableSizeReader.java | 25 +--
.../pinot/controller/api/resources/StateType.java | 25 +--
.../api/resources/StringResultResponse.java | 25 +--
.../controller/api/resources/SuccessResponse.java | 25 +--
.../pinot/controller/api/resources/TableSize.java | 25 +--
.../pinot/controller/api/resources/TableViews.java | 25 +--
.../resources/WebApplicationExceptionMapper.java | 25 +--
.../controller/api/upload/SegmentValidator.java | 25 +--
.../pinot/controller/api/upload/ZKOperator.java | 25 +--
.../helix/ControllerRequestBuilderUtil.java | 25 +--
.../helix/ControllerRequestURLBuilder.java | 25 +--
.../EmptyBrokerOnlineOfflineStateModelFactory.java | 25 +--
...EmptySegmentOnlineOfflineStateModelFactory.java | 25 +--
.../controller/helix/SegmentStatusChecker.java | 25 +--
...erResourceOnlineOfflineStateModelGenerator.java | 25 +--
.../helix/core/PinotHelixResourceManager.java | 60 +++---
...lixSegmentOnlineOfflineStateModelGenerator.java | 25 +--
.../helix/core/PinotResourceManagerResponse.java | 25 +--
.../helix/core/PinotTableIdealStateBuilder.java | 25 +--
.../helix/core/SegmentDeletionManager.java | 25 +--
.../controller/helix/core/TableRebalancer.java | 25 +--
.../helix/core/minion/ClusterInfoProvider.java | 25 +--
.../core/minion/PinotHelixTaskResourceManager.java | 25 +--
.../helix/core/minion/PinotTaskManager.java | 25 +--
.../generator/ConvertToRawIndexTaskGenerator.java | 25 +--
.../core/minion/generator/PinotTaskGenerator.java | 25 +--
.../minion/generator/TaskGeneratorRegistry.java | 25 +--
.../core/minion/generator/TaskGeneratorUtils.java | 25 +--
.../core/periodictask/ControllerPeriodicTask.java | 25 +--
.../ControllerPeriodicTaskScheduler.java | 26 +--
.../realtime/PinotLLCRealtimeSegmentManager.java | 25 +--
.../core/realtime/PinotRealtimeSegmentManager.java | 25 +--
.../core/realtime/SegmentCompletionManager.java | 25 +--
.../helix/core/realtime/TableConfigCache.java | 25 +--
.../segment/CommittingSegmentDescriptor.java | 25 +--
.../segment/DefaultFlushThresholdUpdater.java | 25 +--
.../segment/FlushThresholdUpdateManager.java | 25 +--
.../realtime/segment/FlushThresholdUpdater.java | 25 +--
.../SegmentSizeBasedFlushThresholdUpdater.java | 25 +--
.../rebalance/DefaultRebalanceSegmentStrategy.java | 25 +--
.../core/rebalance/RebalanceSegmentStrategy.java | 25 +--
.../rebalance/RebalanceSegmentStrategyFactory.java | 25 +--
.../rebalance/RebalanceUserConfigConstants.java | 25 +--
.../ReplicaGroupRebalanceSegmentStrategy.java | 25 +--
.../core/relocation/RealtimeSegmentRelocator.java | 25 +--
.../helix/core/retention/RetentionManager.java | 25 +--
.../core/retention/strategy/RetentionStrategy.java | 25 +--
.../retention/strategy/TimeRetentionStrategy.java | 25 +--
.../BalanceNumSegmentAssignmentStrategy.java | 25 +--
.../core/sharding/BucketizedSegmentStrategy.java | 25 +--
.../core/sharding/RandomAssignmentStrategy.java | 25 +--
.../ReplicaGroupSegmentAssignmentStrategy.java | 25 +--
.../core/sharding/SegmentAssignmentStrategy.java | 25 +--
.../sharding/SegmentAssignmentStrategyEnum.java | 25 +--
.../sharding/SegmentAssignmentStrategyFactory.java | 25 +--
.../helix/core/util/HelixSetupUtils.java | 29 ++-
.../helix/core/util/ZKMetadataUtils.java | 25 +--
.../controller/helix/starter/HelixConfig.java | 25 +--
.../controller/util/AutoAddInvertedIndex.java | 25 +--
.../controller/util/SegmentCompletionUtils.java | 25 +--
.../controller/util/TableRetentionValidator.java | 25 +--
.../pinot/controller/util/TableSizeReader.java | 25 +--
.../validation/OfflineSegmentIntervalChecker.java | 25 +--
.../controller/validation/StorageQuotaChecker.java | 25 +--
.../api/resources/AccessControlTest.java | 25 +--
.../api/resources/FileUploadPathProviderTest.java | 25 +--
.../api/resources/PinotFileUploadTest.java | 25 +--
.../PinotInstanceRestletResourceTest.java | 25 +--
.../resources/PinotSchemaRestletResourceTest.java | 25 +--
.../resources/PinotSegmentRestletResourceTest.java | 25 +--
.../resources/PinotTableRestletResourceTest.java | 25 +--
.../resources/PinotTenantRestletResourceTest.java | 25 +--
.../SegmentCompletionProtocolDeserTest.java | 25 +--
.../api/resources/SegmentCompletionUtilsTest.java | 25 +--
.../api/resources/ServerTableSizeReaderTest.java | 25 +--
.../api/resources/TableSizeReaderTest.java | 25 +--
.../controller/api/resources/TableViewsTest.java | 25 +--
.../helix/ControllerInstanceToggleTest.java | 25 +--
.../controller/helix/ControllerSentinelTestV2.java | 25 +--
.../controller/helix/ControllerTenantTest.java | 25 +--
.../pinot/controller/helix/ControllerTest.java | 25 +--
.../pinot/controller/helix/HelixHelperTest.java | 25 +--
.../controller/helix/PinotResourceManagerTest.java | 25 +--
.../controller/helix/SegmentStatusCheckerTest.java | 25 +--
.../helix/core/PinotHelixResourceManagerTest.java | 121 ++++++++++--
.../periodictask/ControllerPeriodicTaskTest.java | 25 +--
.../PinotLLCRealtimeSegmentManagerTest.java | 25 +--
.../helix/core/realtime/SegmentCompletionTest.java | 25 +--
.../segment/FlushThresholdUpdaterTest.java | 25 +--
.../rebalance/DefaultRebalanceStrategyTest.java | 25 +--
.../ReplicaGroupRebalanceStrategyTest.java | 25 +--
.../relocation/RealtimeSegmentRelocatorTest.java | 25 +--
.../helix/core/retention/RetentionManagerTest.java | 25 +--
.../strategy/TimeRetentionStrategyTest.java | 25 +--
.../sharding/SegmentAssignmentStrategyTest.java | 25 +--
.../core/util/SegmentDeletionManagerTest.java | 25 +--
.../helix/core/util/TableRebalancerTest.java | 25 +--
.../controller/utils/ReplicaGroupTestUtils.java | 25 +--
.../controller/utils/SegmentMetadataMockUtils.java | 25 +--
.../validation/StorageQuotaCheckerTest.java | 25 +--
.../validation/ValidationManagerTest.java | 25 +--
pinot-core/pom.xml | 25 +--
.../com/linkedin/pinot/core/bloom/BloomFilter.java | 25 +--
.../linkedin/pinot/core/bloom/BloomFilterType.java | 25 +--
.../linkedin/pinot/core/bloom/BloomFilterUtil.java | 25 +--
.../pinot/core/bloom/GuavaOnHeapBloomFilter.java | 25 +--
.../core/bloom/SegmentBloomFilterFactory.java | 25 +--
.../pinot/core/common/BaseBlockValSet.java | 25 +--
.../java/com/linkedin/pinot/core/common/Block.java | 25 +--
.../pinot/core/common/BlockDocIdIterator.java | 25 +--
.../linkedin/pinot/core/common/BlockDocIdSet.java | 25 +--
.../pinot/core/common/BlockDocIdValueIterator.java | 25 +--
.../pinot/core/common/BlockDocIdValueSet.java | 25 +--
.../linkedin/pinot/core/common/BlockMetadata.java | 25 +--
.../pinot/core/common/BlockMultiValIterator.java | 25 +--
.../pinot/core/common/BlockSingleValIterator.java | 25 +--
.../pinot/core/common/BlockValIterator.java | 25 +--
.../linkedin/pinot/core/common/BlockValSet.java | 25 +--
.../com/linkedin/pinot/core/common/Constants.java | 25 +--
.../linkedin/pinot/core/common/DataBlockCache.java | 25 +--
.../linkedin/pinot/core/common/DataFetcher.java | 25 +--
.../com/linkedin/pinot/core/common/DataSource.java | 25 +--
.../pinot/core/common/DataSourceMetadata.java | 25 +--
.../pinot/core/common/MinionConstants.java | 25 +--
.../pinot/core/common/ObjectSerDeUtils.java | 25 +--
.../com/linkedin/pinot/core/common/Operator.java | 25 +--
.../com/linkedin/pinot/core/common/Predicate.java | 25 +--
.../core/common/datatable/DataTableBuilder.java | 25 +--
.../core/common/datatable/DataTableFactory.java | 25 +--
.../core/common/datatable/DataTableImplV2.java | 25 +--
.../core/common/datatable/DataTableUtils.java | 25 +--
.../core/common/predicate/BaseInPredicate.java | 25 +--
.../pinot/core/common/predicate/EqPredicate.java | 25 +--
.../pinot/core/common/predicate/InPredicate.java | 25 +--
.../pinot/core/common/predicate/NEqPredicate.java | 25 +--
.../core/common/predicate/NotInPredicate.java | 25 +--
.../core/common/predicate/RangePredicate.java | 25 +--
.../core/common/predicate/RegexpLikePredicate.java | 25 +--
.../pinot/core/crypt/NoOpPinotCrypter.java | 25 +--
.../linkedin/pinot/core/crypt/PinotCrypter.java | 25 +--
.../pinot/core/crypt/PinotCrypterFactory.java | 25 +--
.../com/linkedin/pinot/core/data/GenericRow.java | 25 +--
.../core/data/aggregator/AvgValueAggregator.java | 25 +--
.../core/data/aggregator/CountValueAggregator.java | 25 +--
.../DistinctCountHLLValueAggregator.java | 25 +--
.../core/data/aggregator/MaxValueAggregator.java | 25 +--
.../aggregator/MinMaxRangeValueAggregator.java | 25 +--
.../core/data/aggregator/MinValueAggregator.java | 25 +--
.../aggregator/PercentileEstValueAggregator.java | 25 +--
.../PercentileTDigestValueAggregator.java | 25 +--
.../core/data/aggregator/SumValueAggregator.java | 25 +--
.../core/data/aggregator/ValueAggregator.java | 25 +--
.../data/aggregator/ValueAggregatorFactory.java | 25 +--
.../data/function/FunctionExpressionEvaluator.java | 25 +--
.../pinot/core/data/function/FunctionInfo.java | 25 +--
.../pinot/core/data/function/FunctionInvoker.java | 25 +--
.../pinot/core/data/function/FunctionRegistry.java | 25 +--
.../core/data/manager/BaseTableDataManager.java | 25 +--
.../core/data/manager/InstanceDataManager.java | 25 +--
.../core/data/manager/SegmentDataManager.java | 25 +--
.../pinot/core/data/manager/TableDataManager.java | 25 +--
.../manager/config/InstanceDataManagerConfig.java | 25 +--
.../manager/config/TableDataManagerConfig.java | 25 +--
.../offline/ImmutableSegmentDataManager.java | 25 +--
.../manager/offline/OfflineTableDataManager.java | 25 +--
.../manager/offline/TableDataManagerProvider.java | 25 +--
.../realtime/HLRealtimeSegmentDataManager.java | 25 +--
.../realtime/LLRealtimeSegmentDataManager.java | 25 +--
.../realtime/RealtimeSegmentDataManager.java | 25 +--
.../manager/realtime/RealtimeTableDataManager.java | 25 +--
.../realtime/SegmentBuildTimeLeaseExtender.java | 25 +--
.../core/data/manager/realtime/TimerService.java | 25 +--
.../data/partition/ByteArrayPartitionFunction.java | 25 +--
.../data/partition/ModuloPartitionFunction.java | 25 +--
.../data/partition/MurmurPartitionFunction.java | 25 +--
.../core/data/partition/PartitionFunction.java | 25 +--
.../data/partition/PartitionFunctionFactory.java | 25 +--
.../pinot/core/data/readers/AvroRecordReader.java | 25 +--
.../pinot/core/data/readers/CSVRecordReader.java | 25 +--
.../core/data/readers/CSVRecordReaderConfig.java | 25 +--
.../pinot/core/data/readers/FileFormat.java | 25 +--
.../core/data/readers/GenericRowRecordReader.java | 25 +--
.../pinot/core/data/readers/JSONRecordReader.java | 25 +--
.../readers/MultiplePinotSegmentRecordReader.java | 25 +--
.../data/readers/PinotSegmentColumnReader.java | 25 +--
.../data/readers/PinotSegmentRecordReader.java | 25 +--
.../pinot/core/data/readers/RecordReader.java | 25 +--
.../core/data/readers/RecordReaderConfig.java | 25 +--
.../core/data/readers/RecordReaderFactory.java | 25 +--
.../pinot/core/data/readers/RecordReaderUtils.java | 25 +--
.../core/data/readers/ThriftRecordReader.java | 25 +--
.../data/readers/ThriftRecordReaderConfig.java | 25 +--
.../core/data/readers/sort/PinotSegmentSorter.java | 25 +--
.../core/data/readers/sort/SegmentSorter.java | 25 +--
.../recordtransformer/CompoundTransformer.java | 25 +--
.../recordtransformer/DataTypeTransformer.java | 25 +--
.../recordtransformer/ExpressionTransformer.java | 25 +--
.../core/data/recordtransformer/PinotDataType.java | 25 +--
.../data/recordtransformer/RecordTransformer.java | 25 +--
.../recordtransformer/SanitationTransformer.java | 25 +--
.../data/recordtransformer/TimeTransformer.java | 25 +--
.../pinot/core/indexsegment/IndexSegment.java | 25 +--
.../pinot/core/indexsegment/IndexSegmentUtils.java | 25 +--
.../generator/SegmentGeneratorConfig.java | 25 +--
.../indexsegment/generator/SegmentVersion.java | 25 +--
.../indexsegment/immutable/ImmutableSegment.java | 25 +--
.../immutable/ImmutableSegmentImpl.java | 25 +--
.../immutable/ImmutableSegmentLoader.java | 25 +--
.../core/indexsegment/mutable/MutableSegment.java | 25 +--
.../indexsegment/mutable/MutableSegmentImpl.java | 25 +--
.../pinot/core/io/compression/ChunkCompressor.java | 25 +--
.../io/compression/ChunkCompressorFactory.java | 25 +--
.../core/io/compression/ChunkDecompressor.java | 25 +--
.../core/io/compression/PassThroughCompressor.java | 25 +--
.../io/compression/PassThroughDecompressor.java | 25 +--
.../core/io/compression/SnappyCompressor.java | 25 +--
.../core/io/compression/SnappyDecompressor.java | 25 +--
.../reader/BaseSingleColumnMultiValueReader.java | 25 +--
.../reader/BaseSingleColumnSingleValueReader.java | 25 +--
.../pinot/core/io/reader/DataFileReader.java | 25 +--
.../pinot/core/io/reader/ReaderContext.java | 25 +--
.../io/reader/SingleColumnMultiValueReader.java | 25 +--
.../io/reader/SingleColumnSingleValueReader.java | 25 +--
.../io/reader/SingleValueMultiColumnReader.java | 25 +--
.../core/io/reader/impl/ChunkReaderContext.java | 25 +--
.../impl/FixedByteSingleValueMultiColReader.java | 25 +--
.../io/reader/impl/UnSortedValueReaderContext.java | 25 +--
.../reader/impl/v1/BaseChunkSingleValueReader.java | 25 +--
.../reader/impl/v1/FixedBitMultiValueReader.java | 25 +--
.../reader/impl/v1/FixedBitSingleValueReader.java | 25 +--
.../impl/v1/FixedByteChunkSingleValueReader.java | 25 +--
.../core/io/reader/impl/v1/SortedIndexReader.java | 25 +--
.../io/reader/impl/v1/SortedIndexReaderImpl.java | 25 +--
.../impl/v1/VarByteChunkSingleValueReader.java | 25 +--
.../BaseSingleColumnMultiValueReaderWriter.java | 25 +--
.../BaseSingleColumnSingleValueReaderWriter.java | 25 +--
.../BaseSingleValueMultiColumnReaderWriter.java | 25 +--
.../readerwriter/PinotDataBufferMemoryManager.java | 25 +--
.../RealtimeIndexOffHeapMemoryManager.java | 25 +--
...ixedByteSingleColumnMultiValueReaderWriter.java | 25 +--
...xedByteSingleColumnSingleValueReaderWriter.java | 25 +--
...ixedByteSingleValueMultiColumnReaderWriter.java | 25 +--
.../io/util/DictionaryDelegatingValueReader.java | 26 +--
.../core/io/util/FixedBitIntReaderWriter.java | 25 +--
.../core/io/util/FixedByteValueReaderWriter.java | 25 +--
.../pinot/core/io/util/PinotDataBitSet.java | 25 +--
.../linkedin/pinot/core/io/util/ValueReader.java | 25 +--
.../pinot/core/io/writer/DataFileWriter.java | 25 +--
.../io/writer/SingleColumnMultiValueWriter.java | 25 +--
.../io/writer/SingleColumnSingleValueWriter.java | 25 +--
.../io/writer/SingleValueMultiColumnWriter.java | 25 +--
.../core/io/writer/impl/DirectMemoryManager.java | 25 +--
.../impl/FixedByteSingleValueMultiColWriter.java | 25 +--
.../core/io/writer/impl/MmapMemoryManager.java | 25 +--
.../writer/impl/MutableOffHeapByteArrayStore.java | 25 +--
.../core/io/writer/impl/OffHeapStringStore.java | 29 +--
.../writer/impl/v1/BaseChunkSingleValueWriter.java | 25 +--
.../writer/impl/v1/FixedBitMultiValueWriter.java | 25 +--
.../writer/impl/v1/FixedBitSingleValueWriter.java | 25 +--
.../impl/v1/FixedByteChunkSingleValueWriter.java | 25 +--
.../impl/v1/VarByteChunkSingleValueWriter.java | 25 +--
.../core/metadata/DefaultMetadataExtractor.java | 25 +--
.../pinot/core/metadata/MetadataExtractor.java | 25 +--
.../core/metadata/MetadataExtractorFactory.java | 25 +--
.../pinot/core/minion/BackfillDateTimeColumn.java | 25 +--
.../pinot/core/minion/RawIndexConverter.java | 25 +--
.../pinot/core/minion/SegmentConverter.java | 25 +--
.../linkedin/pinot/core/minion/SegmentPurger.java | 25 +--
.../minion/rollup/MergeRollupSegmentConverter.java | 25 +--
.../pinot/core/minion/rollup/MergeType.java | 25 +--
.../core/minion/rollup/RollupRecordAggregator.java | 25 +--
.../rollup/aggregate/MaxValueAggregator.java | 25 +--
.../rollup/aggregate/SumValueAggregator.java | 25 +--
.../minion/rollup/aggregate/ValueAggregator.java | 25 +--
.../rollup/aggregate/ValueAggregatorFactory.java | 25 +--
.../minion/segment/DefaultRecordPartitioner.java | 25 +--
.../core/minion/segment/MapperRecordReader.java | 25 +--
.../core/minion/segment/RecordAggregator.java | 25 +--
.../core/minion/segment/RecordPartitioner.java | 25 +--
.../core/minion/segment/RecordTransformer.java | 25 +--
.../core/minion/segment/ReducerRecordReader.java | 25 +--
.../linkedin/pinot/core/operator/BaseOperator.java | 25 +--
.../core/operator/CombineGroupByOperator.java | 25 +--
.../pinot/core/operator/CombineOperator.java | 25 +--
.../pinot/core/operator/DocIdSetOperator.java | 25 +--
.../pinot/core/operator/ExecutionStatistics.java | 25 +--
.../core/operator/InstanceResponseOperator.java | 25 +--
.../pinot/core/operator/ProjectionOperator.java | 25 +--
.../core/operator/blocks/BlockMetadataImpl.java | 25 +--
.../pinot/core/operator/blocks/DocIdSetBlock.java | 25 +--
.../core/operator/blocks/EmptyFilterBlock.java | 25 +--
.../pinot/core/operator/blocks/FilterBlock.java | 25 +--
.../operator/blocks/InstanceResponseBlock.java | 25 +--
.../operator/blocks/IntermediateResultsBlock.java | 25 +--
.../core/operator/blocks/MultiValueBlock.java | 25 +--
.../core/operator/blocks/ProjectionBlock.java | 25 +--
.../core/operator/blocks/SingleValueBlock.java | 25 +--
.../pinot/core/operator/blocks/TransformBlock.java | 25 +--
.../operator/dociditerators/AndDocIdIterator.java | 25 +--
.../dociditerators/ArrayBasedDocIdIterator.java | 25 +--
.../dociditerators/BitmapDocIdIterator.java | 25 +--
.../dociditerators/EmptyBlockDocIdIterator.java | 25 +--
.../dociditerators/IndexBasedDocIdIterator.java | 25 +--
.../dociditerators/MVScanDocIdIterator.java | 25 +--
.../operator/dociditerators/OrDocIdIterator.java | 25 +--
.../RangelessBitmapDocIdIterator.java | 25 +--
.../dociditerators/SVScanDocIdIterator.java | 25 +--
.../dociditerators/ScanBasedDocIdIterator.java | 25 +--
.../dociditerators/SizeBasedDocIdIterator.java | 25 +--
.../dociditerators/SortedDocIdIterator.java | 25 +--
.../core/operator/docidsets/AndBlockDocIdSet.java | 25 +--
.../operator/docidsets/ArrayBasedDocIdSet.java | 25 +--
.../core/operator/docidsets/BitmapDocIdSet.java | 25 +--
.../docidsets/EmptyFilterBlockDocIdSet.java | 25 +--
.../operator/docidsets/FilterBlockDocIdSet.java | 25 +--
.../core/operator/docidsets/OrBlockDocIdSet.java | 25 +--
.../docidsets/ScanBasedMultiValueDocIdSet.java | 25 +--
.../docidsets/ScanBasedSingleValueDocIdSet.java | 25 +--
.../core/operator/docidsets/SizeBasedDocIdSet.java | 25 +--
.../core/operator/docidsets/SortedDocIdSet.java | 25 +--
.../core/operator/docidsets/StarTreeDocIdSet.java | 25 +--
.../docvaliterators/MultiValueIterator.java | 25 +--
.../docvaliterators/SingleValueIterator.java | 25 +--
.../core/operator/docvalsets/MultiValueSet.java | 25 +--
.../operator/docvalsets/ProjectionBlockValSet.java | 25 +--
.../core/operator/docvalsets/SingleValueSet.java | 25 +--
.../operator/docvalsets/TransformBlockValSet.java | 25 +--
.../core/operator/filter/AndFilterOperator.java | 25 +--
.../core/operator/filter/BaseFilterOperator.java | 25 +--
.../operator/filter/BitmapBasedFilterOperator.java | 25 +--
.../core/operator/filter/EmptyFilterOperator.java | 25 +--
.../core/operator/filter/FilterOperatorUtils.java | 25 +--
.../pinot/core/operator/filter/IntRanges.java | 25 +--
.../operator/filter/MatchAllFilterOperator.java | 25 +--
.../core/operator/filter/OrFilterOperator.java | 25 +--
.../operator/filter/ScanBasedFilterOperator.java | 25 +--
.../SortedInvertedIndexBasedFilterOperator.java | 25 +--
.../BaseDictionaryBasedPredicateEvaluator.java | 25 +--
.../filter/predicate/BasePredicateEvaluator.java | 25 +--
.../BaseRawValueBasedPredicateEvaluator.java | 25 +--
.../predicate/EqualsPredicateEvaluatorFactory.java | 25 +--
.../predicate/InPredicateEvaluatorFactory.java | 25 +--
.../NotEqualsPredicateEvaluatorFactory.java | 25 +--
.../predicate/NotInPredicateEvaluatorFactory.java | 25 +--
.../filter/predicate/PredicateEvaluator.java | 25 +--
.../predicate/PredicateEvaluatorProvider.java | 25 +--
.../predicate/RangePredicateEvaluatorFactory.java | 25 +--
.../RegexpLikePredicateEvaluatorFactory.java | 25 +--
.../operator/query/AggregationGroupByOperator.java | 25 +--
.../core/operator/query/AggregationOperator.java | 25 +--
.../query/DictionaryBasedAggregationOperator.java | 25 +--
.../operator/query/EmptySelectionOperator.java | 25 +--
.../query/MetadataBasedAggregationOperator.java | 25 +--
.../core/operator/query/SelectionOnlyOperator.java | 25 +--
.../operator/query/SelectionOrderByOperator.java | 25 +--
.../core/operator/transform/TransformOperator.java | 25 +--
.../transform/TransformResultMetadata.java | 25 +--
.../function/AdditionTransformFunction.java | 25 +--
.../transform/function/BaseTransformFunction.java | 25 +--
.../DateTimeConversionTransformFunction.java | 25 +--
.../function/DivisionTransformFunction.java | 25 +--
.../function/IdentifierTransformFunction.java | 25 +--
.../function/LiteralTransformFunction.java | 25 +--
.../function/MultiplicationTransformFunction.java | 25 +--
.../function/SubtractionTransformFunction.java | 25 +--
.../function/TimeConversionTransformFunction.java | 25 +--
.../transform/function/TransformFunction.java | 25 +--
.../function/TransformFunctionFactory.java | 25 +--
.../function/ValueInTransformFunction.java | 25 +--
.../transform/transformer/DataTransformer.java | 25 +--
.../datetime/BaseDateTimeTransformer.java | 25 +--
.../datetime/DateTimeTransformerFactory.java | 25 +--
.../datetime/EpochToEpochTransformer.java | 25 +--
.../datetime/EpochToSDFTransformer.java | 25 +--
.../datetime/SDFToEpochTransformer.java | 25 +--
.../transformer/datetime/SDFToSDFTransformer.java | 25 +--
.../timeunit/CustomTimeUnitTransformer.java | 25 +--
.../timeunit/JavaTimeUnitTransformer.java | 25 +--
.../transformer/timeunit/TimeUnitTransformer.java | 25 +--
.../timeunit/TimeUnitTransformerFactory.java | 25 +--
.../pinot/core/periodictask/BasePeriodicTask.java | 25 +--
.../pinot/core/periodictask/PeriodicTask.java | 25 +--
.../core/periodictask/PeriodicTaskScheduler.java | 25 +--
.../core/plan/AggregationFunctionInitializer.java | 25 +--
.../core/plan/AggregationGroupByPlanNode.java | 25 +--
.../pinot/core/plan/AggregationPlanNode.java | 25 +--
.../linkedin/pinot/core/plan/CombinePlanNode.java | 25 +--
.../plan/DictionaryBasedAggregationPlanNode.java | 25 +--
.../linkedin/pinot/core/plan/DocIdSetPlanNode.java | 25 +--
.../linkedin/pinot/core/plan/FilterPlanNode.java | 25 +--
.../linkedin/pinot/core/plan/GlobalPlanImplV0.java | 25 +--
.../pinot/core/plan/InstanceResponsePlanNode.java | 25 +--
.../plan/MetadataBasedAggregationPlanNode.java | 25 +--
.../java/com/linkedin/pinot/core/plan/Plan.java | 25 +--
.../com/linkedin/pinot/core/plan/PlanNode.java | 25 +--
.../pinot/core/plan/ProjectionPlanNode.java | 25 +--
.../pinot/core/plan/SelectionPlanNode.java | 25 +--
.../pinot/core/plan/TransformPlanNode.java | 25 +--
.../core/plan/maker/BrokerRequestPreProcessor.java | 25 +--
.../core/plan/maker/InstancePlanMakerImplV2.java | 25 +--
.../linkedin/pinot/core/plan/maker/PlanMaker.java | 25 +--
.../query/aggregation/AggregationExecutor.java | 25 +--
.../aggregation/AggregationFunctionContext.java | 25 +--
.../query/aggregation/AggregationResultHolder.java | 25 +--
.../aggregation/DefaultAggregationExecutor.java | 25 +--
.../aggregation/DoubleAggregationResultHolder.java | 25 +--
.../aggregation/ObjectAggregationResultHolder.java | 25 +--
.../aggregation/function/AggregationFunction.java | 25 +--
.../function/AggregationFunctionFactory.java | 25 +--
.../function/AggregationFunctionType.java | 25 +--
.../function/AggregationFunctionUtils.java | 25 +--
.../function/AggregationFunctionVisitorBase.java | 25 +--
.../function/AvgAggregationFunction.java | 25 +--
.../function/AvgMVAggregationFunction.java | 25 +--
.../function/CountAggregationFunction.java | 25 +--
.../function/CountMVAggregationFunction.java | 25 +--
.../function/DistinctCountAggregationFunction.java | 25 +--
.../DistinctCountHLLAggregationFunction.java | 25 +--
.../DistinctCountHLLMVAggregationFunction.java | 25 +--
.../DistinctCountMVAggregationFunction.java | 25 +--
.../function/FastHLLAggregationFunction.java | 25 +--
.../function/MaxAggregationFunction.java | 25 +--
.../function/MaxMVAggregationFunction.java | 25 +--
.../function/MinAggregationFunction.java | 25 +--
.../function/MinMVAggregationFunction.java | 25 +--
.../function/MinMaxRangeAggregationFunction.java | 25 +--
.../function/MinMaxRangeMVAggregationFunction.java | 25 +--
.../function/PercentileAggregationFunction.java | 25 +--
.../function/PercentileEstAggregationFunction.java | 25 +--
.../PercentileEstMVAggregationFunction.java | 25 +--
.../function/PercentileMVAggregationFunction.java | 25 +--
.../PercentileTDigestAggregationFunction.java | 25 +--
.../PercentileTDigestMVAggregationFunction.java | 25 +--
.../function/SumAggregationFunction.java | 25 +--
.../function/SumMVAggregationFunction.java | 25 +--
.../aggregation/function/customobject/AvgPair.java | 25 +--
.../function/customobject/MinMaxRangePair.java | 25 +--
.../function/customobject/QuantileDigest.java | 25 +--
.../groupby/AggregationGroupByResult.java | 25 +--
.../groupby/AggregationGroupByTrimmingService.java | 25 +--
.../groupby/DefaultGroupByExecutor.java | 25 +--
.../groupby/DictionaryBasedGroupKeyGenerator.java | 25 +--
.../groupby/DoubleGroupByResultHolder.java | 25 +--
.../query/aggregation/groupby/GroupByExecutor.java | 25 +--
.../aggregation/groupby/GroupByResultHolder.java | 25 +--
.../aggregation/groupby/GroupKeyGenerator.java | 25 +--
.../NoDictionaryMultiColumnGroupKeyGenerator.java | 25 +--
.../NoDictionarySingleColumnGroupKeyGenerator.java | 25 +--
.../groupby/ObjectGroupByResultHolder.java | 25 +--
.../groupby/utils/BaseValueToIdMap.java | 25 +--
.../aggregation/groupby/utils/DoubleToIdMap.java | 25 +--
.../aggregation/groupby/utils/FloatToIdMap.java | 25 +--
.../aggregation/groupby/utils/IntToIdMap.java | 25 +--
.../aggregation/groupby/utils/LongToIdMap.java | 25 +--
.../aggregation/groupby/utils/StringToIdMap.java | 25 +--
.../aggregation/groupby/utils/ValueToIdMap.java | 25 +--
.../groupby/utils/ValueToIdMapFactory.java | 25 +--
.../core/query/config/QueryExecutorConfig.java | 25 +--
.../core/query/config/QueryPlannerConfig.java | 25 +--
.../core/query/config/SegmentPrunerConfig.java | 25 +--
.../query/exception/BadQueryRequestException.java | 25 +--
.../pinot/core/query/executor/QueryExecutor.java | 25 +--
.../query/executor/ServerQueryExecutorV1Impl.java | 25 +--
.../core/query/pruner/AbstractSegmentPruner.java | 25 +--
.../query/pruner/ColumnValueSegmentPruner.java | 25 +--
.../core/query/pruner/DataSchemaSegmentPruner.java | 25 +--
.../core/query/pruner/PartitionSegmentPruner.java | 25 +--
.../pinot/core/query/pruner/SegmentPruner.java | 25 +--
.../core/query/pruner/SegmentPrunerProvider.java | 25 +--
.../core/query/pruner/SegmentPrunerService.java | 25 +--
.../core/query/pruner/ValidSegmentPruner.java | 25 +--
.../pinot/core/query/reduce/BetweenComparison.java | 25 +--
.../core/query/reduce/BrokerReduceService.java | 25 +--
.../pinot/core/query/reduce/CombineService.java | 25 +--
.../core/query/reduce/ComparisonFunction.java | 25 +--
.../pinot/core/query/reduce/EqualComparison.java | 25 +--
.../core/query/reduce/GreaterEqualComparison.java | 25 +--
.../core/query/reduce/GreaterThanComparison.java | 25 +--
.../query/reduce/HavingClauseComparisonTree.java | 25 +--
.../core/query/reduce/InAndNotInComparison.java | 25 +--
.../core/query/reduce/LessEqualComparison.java | 25 +--
.../core/query/reduce/LessThanComparison.java | 25 +--
.../core/query/reduce/NotEqualComparison.java | 25 +--
.../core/query/request/ServerQueryRequest.java | 25 +--
.../core/query/request/context/TimerContext.java | 25 +--
.../query/scheduler/AbstractSchedulerGroup.java | 25 +--
.../query/scheduler/MultiLevelPriorityQueue.java | 25 +--
.../query/scheduler/OutOfCapacityException.java | 25 +--
.../core/query/scheduler/PriorityScheduler.java | 25 +--
.../pinot/core/query/scheduler/QueryScheduler.java | 25 +--
.../query/scheduler/QuerySchedulerFactory.java | 25 +--
.../pinot/core/query/scheduler/SchedulerGroup.java | 25 +--
.../query/scheduler/SchedulerGroupAccountant.java | 25 +--
.../query/scheduler/SchedulerGroupFactory.java | 25 +--
.../core/query/scheduler/SchedulerGroupMapper.java | 25 +--
.../query/scheduler/SchedulerPriorityQueue.java | 25 +--
.../query/scheduler/SchedulerQueryContext.java | 25 +--
.../query/scheduler/TableBasedGroupMapper.java | 25 +--
.../query/scheduler/fcfs/BoundedFCFSScheduler.java | 25 +--
.../query/scheduler/fcfs/FCFSQueryScheduler.java | 25 +--
.../query/scheduler/fcfs/FCFSSchedulerGroup.java | 25 +--
.../resources/BoundedAccountingExecutor.java | 25 +--
.../resources/PolicyBasedResourceManager.java | 25 +--
.../scheduler/resources/QueryExecutorService.java | 25 +--
.../scheduler/resources/ResourceLimitPolicy.java | 25 +--
.../query/scheduler/resources/ResourceManager.java | 25 +--
.../resources/UnboundedResourceManager.java | 25 +--
.../tokenbucket/TokenPriorityScheduler.java | 25 +--
.../scheduler/tokenbucket/TokenSchedulerGroup.java | 25 +--
.../core/query/selection/SelectionFetcher.java | 25 +--
.../query/selection/SelectionOperatorService.java | 25 +--
.../query/selection/SelectionOperatorUtils.java | 25 +--
.../comparator/CompositeDocIdValComparator.java | 25 +--
.../comparator/DocIdDoubleValComparator.java | 25 +--
.../comparator/DocIdFloatValComparator.java | 25 +--
.../comparator/DocIdIntValComparator.java | 25 +--
.../comparator/DocIdLongValComparator.java | 25 +--
.../selection/comparator/IDocIdValComparator.java | 25 +--
.../DoubleArraySelectionColumnIterator.java | 25 +--
.../iterator/DoubleSelectionColumnIterator.java | 25 +--
.../FloatArraySelectionColumnIterator.java | 25 +--
.../iterator/FloatSelectionColumnIterator.java | 25 +--
.../iterator/IntArraySelectionColumnIterator.java | 25 +--
.../iterator/IntSelectionColumnIterator.java | 25 +--
.../iterator/LongArraySelectionColumnIterator.java | 25 +--
.../iterator/LongSelectionColumnIterator.java | 25 +--
.../iterator/SelectionColumnIterator.java | 25 +--
.../SelectionMultiValueColumnIterator.java | 25 +--
...SelectionSingleValueColumnWithDictIterator.java | 25 +--
.../StringArraySelectionColumnIterator.java | 25 +--
.../iterator/StringSelectionColumnIterator.java | 25 +--
.../com/linkedin/pinot/core/query/utils/Pair.java | 25 +--
.../linkedin/pinot/core/query/utils/TrieNode.java | 25 +--
.../converter/RealtimeSegmentConverter.java | 25 +--
.../converter/RealtimeSegmentRecordReader.java | 25 +--
.../converter/stats/RealtimeColumnStatistics.java | 25 +--
.../stats/RealtimeNoDictionaryColStatistics.java | 25 +--
.../RealtimeSegmentSegmentCreationDataSource.java | 25 +--
.../stats/RealtimeSegmentStatsContainer.java | 25 +--
.../core/realtime/impl/RealtimeSegmentConfig.java | 25 +--
.../realtime/impl/RealtimeSegmentStatsHistory.java | 25 +--
.../dictionary/BaseOffHeapMutableDictionary.java | 25 +--
.../dictionary/BaseOnHeapMutableDictionary.java | 25 +--
.../dictionary/BytesOffHeapMutableDictionary.java | 25 +--
.../dictionary/BytesOnHeapMutableDictionary.java | 25 +--
.../dictionary/DoubleOffHeapMutableDictionary.java | 25 +--
.../dictionary/DoubleOnHeapMutableDictionary.java | 25 +--
.../dictionary/FloatOffHeapMutableDictionary.java | 25 +--
.../dictionary/FloatOnHeapMutableDictionary.java | 25 +--
.../dictionary/IntOffHeapMutableDictionary.java | 25 +--
.../dictionary/IntOnHeapMutableDictionary.java | 25 +--
.../dictionary/LongOffHeapMutableDictionary.java | 25 +--
.../dictionary/LongOnHeapMutableDictionary.java | 25 +--
.../impl/dictionary/MutableDictionary.java | 25 +--
.../impl/dictionary/MutableDictionaryFactory.java | 25 +--
.../dictionary/StringOffHeapMutableDictionary.java | 25 +--
.../dictionary/StringOnHeapMutableDictionary.java | 25 +--
.../invertedindex/RealtimeInvertedIndexReader.java | 25 +--
.../impl/kafka/AvroRecordToPinotRowGenerator.java | 25 +--
.../realtime/impl/kafka/ConsumerAndIterator.java | 25 +--
.../impl/kafka/KafkaAvroMessageDecoder.java | 25 +--
.../realtime/impl/kafka/KafkaBrokerWrapper.java | 25 +--
.../impl/kafka/KafkaConnectionHandler.java | 25 +--
.../realtime/impl/kafka/KafkaConsumerFactory.java | 25 +--
.../realtime/impl/kafka/KafkaConsumerManager.java | 25 +--
.../impl/kafka/KafkaHighLevelStreamConfig.java | 25 +--
.../impl/kafka/KafkaJSONMessageDecoder.java | 25 +--
.../impl/kafka/KafkaLowLevelStreamConfig.java | 25 +--
.../impl/kafka/KafkaPartitionLevelConsumer.java | 25 +--
.../impl/kafka/KafkaSimpleConsumerFactory.java | 25 +--
.../impl/kafka/KafkaSimpleConsumerFactoryImpl.java | 25 +--
.../impl/kafka/KafkaStreamConfigProperties.java | 25 +--
.../impl/kafka/KafkaStreamLevelConsumer.java | 25 +--
.../impl/kafka/KafkaStreamMetadataProvider.java | 25 +--
.../realtime/impl/kafka/SimpleConsumerFactory.java | 25 +--
.../impl/kafka/SimpleConsumerMessageBatch.java | 25 +--
.../ConsumingSegmentAssignmentStrategy.java | 25 +--
.../segment/RealtimeSegmentAssignmentStrategy.java | 25 +--
.../pinot/core/realtime/stream/MessageBatch.java | 25 +--
.../pinot/core/realtime/stream/OffsetCriteria.java | 25 +--
.../realtime/stream/PartitionCountFetcher.java | 25 +--
.../realtime/stream/PartitionLevelConsumer.java | 25 +--
.../stream/PartitionLevelStreamConfig.java | 25 +--
.../realtime/stream/PartitionOffsetFetcher.java | 25 +--
.../stream/PermanentConsumerException.java | 25 +--
.../pinot/core/realtime/stream/StreamConfig.java | 25 +--
.../realtime/stream/StreamConfigProperties.java | 25 +--
.../realtime/stream/StreamConsumerFactory.java | 25 +--
.../stream/StreamConsumerFactoryProvider.java | 25 +--
.../realtime/stream/StreamDecoderProvider.java | 25 +--
.../core/realtime/stream/StreamLevelConsumer.java | 25 +--
.../core/realtime/stream/StreamMessageDecoder.java | 25 +--
.../realtime/stream/StreamMetadataProvider.java | 25 +--
.../stream/TransientConsumerException.java | 25 +--
.../creator/BaseSingleValueRawIndexCreator.java | 25 +--
.../segment/creator/ColumnIndexCreationInfo.java | 25 +--
.../core/segment/creator/ColumnStatistics.java | 25 +--
.../core/segment/creator/ForwardIndexCreator.java | 25 +--
.../core/segment/creator/ForwardIndexType.java | 25 +--
.../core/segment/creator/InvertedIndexCreator.java | 25 +--
.../core/segment/creator/InvertedIndexType.java | 25 +--
.../creator/MultiValueForwardIndexCreator.java | 25 +--
.../RecordReaderSegmentCreationDataSource.java | 25 +--
.../segment/creator/SegmentCreationDataSource.java | 25 +--
.../pinot/core/segment/creator/SegmentCreator.java | 25 +--
.../creator/SegmentIndexCreationDriver.java | 25 +--
.../segment/creator/SegmentIndexCreationInfo.java | 25 +--
.../creator/SegmentPreIndexStatsCollector.java | 25 +--
.../creator/SegmentPreIndexStatsContainer.java | 25 +--
.../creator/SingleValueForwardIndexCreator.java | 25 +--
.../creator/SingleValueRawIndexCreator.java | 25 +--
.../core/segment/creator/StatsCollectorConfig.java | 25 +--
.../creator/impl/SegmentColumnarIndexCreator.java | 25 +--
.../creator/impl/SegmentCreationDriverFactory.java | 25 +--
.../creator/impl/SegmentDictionaryCreator.java | 25 +--
.../impl/SegmentIndexCreationDriverImpl.java | 25 +--
.../core/segment/creator/impl/V1Constants.java | 25 +--
.../creator/impl/bloom/BloomFilterCreator.java | 25 +--
.../fwd/MultiValueUnsortedForwardIndexCreator.java | 25 +--
.../fwd/SingleValueFixedByteRawIndexCreator.java | 25 +--
.../fwd/SingleValueSortedForwardIndexCreator.java | 25 +--
.../SingleValueUnsortedForwardIndexCreator.java | 25 +--
.../fwd/SingleValueVarByteRawIndexCreator.java | 25 +--
.../inv/OffHeapBitmapInvertedIndexCreator.java | 25 +--
.../impl/inv/OnHeapBitmapInvertedIndexCreator.java | 25 +--
.../stats/AbstractColumnStatisticsCollector.java | 25 +--
.../stats/BytesColumnPredIndexStatsCollector.java | 25 +--
.../stats/DoubleColumnPreIndexStatsCollector.java | 25 +--
.../stats/FloatColumnPreIndexStatsCollector.java | 25 +--
.../stats/IntColumnPreIndexStatsCollector.java | 25 +--
.../stats/LongColumnPreIndexStatsCollector.java | 25 +--
.../stats/SegmentPreIndexStatsCollectorImpl.java | 25 +--
.../stats/StringColumnPreIndexStatsCollector.java | 25 +--
.../pinot/core/segment/index/ColumnMetadata.java | 25 +--
.../core/segment/index/SegmentMetadataImpl.java | 25 +--
.../segment/index/column/ColumnIndexContainer.java | 25 +--
.../index/column/PhysicalColumnIndexContainer.java | 25 +--
.../index/converter/SegmentFormatConverter.java | 25 +--
.../converter/SegmentFormatConverterFactory.java | 25 +--
.../converter/SegmentV1V2ToV3FormatConverter.java | 25 +--
.../index/data/source/ColumnDataSource.java | 25 +--
.../segment/index/loader/IndexLoadingConfig.java | 25 +--
.../core/segment/index/loader/LoaderUtils.java | 25 +--
.../segment/index/loader/SegmentPreProcessor.java | 25 +--
.../index/loader/V3RemoveIndexException.java | 25 +--
.../loader/bloomfilter/BloomFilterHandler.java | 25 +--
.../ColumnMinMaxValueGenerator.java | 25 +--
.../ColumnMinMaxValueGeneratorMode.java | 25 +--
.../defaultcolumn/BaseDefaultColumnHandler.java | 25 +--
.../loader/defaultcolumn/DefaultColumnHandler.java | 25 +--
.../defaultcolumn/DefaultColumnHandlerFactory.java | 25 +--
.../defaultcolumn/DefaultColumnStatistics.java | 26 +--
.../defaultcolumn/V1DefaultColumnHandler.java | 25 +--
.../defaultcolumn/V3DefaultColumnHandler.java | 25 +--
.../loader/invertedindex/InvertedIndexHandler.java | 25 +--
.../core/segment/index/readers/BaseDictionary.java | 25 +--
.../index/readers/BitmapInvertedIndexReader.java | 25 +--
.../segment/index/readers/BloomFilterReader.java | 25 +--
.../segment/index/readers/BytesDictionary.java | 25 +--
.../core/segment/index/readers/Dictionary.java | 25 +--
.../segment/index/readers/DoubleDictionary.java | 25 +--
.../segment/index/readers/FloatDictionary.java | 25 +--
.../index/readers/ImmutableDictionaryReader.java | 25 +--
.../core/segment/index/readers/IntDictionary.java | 25 +--
.../segment/index/readers/InvertedIndexReader.java | 25 +--
.../core/segment/index/readers/LongDictionary.java | 25 +--
.../segment/index/readers/OnHeapDictionary.java | 25 +--
.../index/readers/OnHeapDoubleDictionary.java | 25 +--
.../index/readers/OnHeapFloatDictionary.java | 25 +--
.../segment/index/readers/OnHeapIntDictionary.java | 25 +--
.../index/readers/OnHeapLongDictionary.java | 25 +--
.../index/readers/OnHeapStringDictionary.java | 25 +--
.../segment/index/readers/StringDictionary.java | 25 +--
.../core/segment/memory/BasePinotLBuffer.java | 25 +--
.../pinot/core/segment/memory/PinotByteBuffer.java | 25 +--
.../pinot/core/segment/memory/PinotDataBuffer.java | 25 +--
.../segment/memory/PinotNativeOrderLBuffer.java | 25 +--
.../segment/memory/PinotNonNativeOrderLBuffer.java | 25 +--
.../segment/name/DefaultSegmentNameGenerator.java | 25 +--
.../name/NormalizedDateSegmentNameGenerator.java | 25 +--
.../core/segment/name/SegmentNameGenerator.java | 25 +--
.../core/segment/store/ColumnIndexDirectory.java | 25 +--
.../pinot/core/segment/store/ColumnIndexType.java | 25 +--
.../core/segment/store/FilePerIndexDirectory.java | 25 +--
.../pinot/core/segment/store/IndexEntry.java | 25 +--
.../pinot/core/segment/store/IndexKey.java | 25 +--
.../pinot/core/segment/store/SegmentDirectory.java | 25 +--
.../core/segment/store/SegmentDirectoryPaths.java | 25 +--
.../segment/store/SegmentLocalFSDirectory.java | 25 +--
.../segment/store/SingleFileIndexDirectory.java | 25 +--
.../virtualcolumn/BaseVirtualColumnProvider.java | 25 +--
.../virtualcolumn/DocIdVirtualColumnProvider.java | 25 +--
.../HostNameVirtualColumnProvider.java | 25 +--
.../IntSingleValueDataFileReader.java | 25 +--
.../SegmentNameVirtualColumnProvider.java | 25 +--
.../SingleStringVirtualColumnProvider.java | 25 +--
.../virtualcolumn/VirtualColumnContext.java | 25 +--
.../virtualcolumn/VirtualColumnIndexContainer.java | 25 +--
.../virtualcolumn/VirtualColumnProvider.java | 25 +--
.../VirtualColumnProviderFactory.java | 25 +--
.../core/segment/virtualcolumn/package-info.java | 25 +--
.../pinot/core/startree/DimensionBuffer.java | 25 +--
.../linkedin/pinot/core/startree/MetricBuffer.java | 25 +--
.../pinot/core/startree/OffHeapStarTree.java | 25 +--
.../core/startree/OffHeapStarTreeBuilder.java | 25 +--
.../pinot/core/startree/OffHeapStarTreeNode.java | 25 +--
.../com/linkedin/pinot/core/startree/StarTree.java | 25 +--
.../pinot/core/startree/StarTreeBuilder.java | 25 +--
.../pinot/core/startree/StarTreeBuilderConfig.java | 25 +--
.../pinot/core/startree/StarTreeBuilderUtils.java | 25 +--
.../pinot/core/startree/StarTreeDataTable.java | 25 +--
.../linkedin/pinot/core/startree/StarTreeNode.java | 25 +--
.../pinot/core/startree/StarTreeUtils.java | 25 +--
.../executor/StarTreeAggregationExecutor.java | 25 +--
.../startree/executor/StarTreeGroupByExecutor.java | 25 +--
.../linkedin/pinot/core/startree/hll/HllUtil.java | 25 +--
.../startree/operator/StarTreeFilterOperator.java | 25 +--
.../startree/plan/StarTreeDocIdSetPlanNode.java | 25 +--
.../core/startree/plan/StarTreeFilterPlanNode.java | 25 +--
.../startree/plan/StarTreeProjectionPlanNode.java | 25 +--
.../startree/plan/StarTreeTransformPlanNode.java | 25 +--
.../startree/v2/AggregationFunctionColumnPair.java | 25 +--
.../pinot/core/startree/v2/StarTreeV2.java | 25 +--
.../core/startree/v2/StarTreeV2Constants.java | 25 +--
.../pinot/core/startree/v2/StarTreeV2Metadata.java | 25 +--
.../startree/v2/builder/BaseSingleTreeBuilder.java | 25 +--
.../startree/v2/builder/MultipleTreesBuilder.java | 25 +--
.../v2/builder/OffHeapSingleTreeBuilder.java | 25 +--
.../v2/builder/OnHeapSingleTreeBuilder.java | 25 +--
.../startree/v2/builder/SingleTreeBuilder.java | 25 +--
.../startree/v2/builder/StarTreeIndexCombiner.java | 25 +--
.../v2/builder/StarTreeV2BuilderConfig.java | 25 +--
.../v2/store/StarTreeDimensionDataSource.java | 25 +--
.../startree/v2/store/StarTreeIndexContainer.java | 25 +--
.../startree/v2/store/StarTreeIndexMapUtils.java | 25 +--
.../startree/v2/store/StarTreeLoaderUtils.java | 25 +--
.../v2/store/StarTreeMetricDataSource.java | 25 +--
.../pinot/core/transport/AsyncQueryResponse.java | 25 +--
.../pinot/core/transport/DataTableHandler.java | 25 +--
.../linkedin/pinot/core/transport/QueryRouter.java | 25 +--
.../com/linkedin/pinot/core/transport/Server.java | 25 +--
.../pinot/core/transport/ServerChannels.java | 25 +--
.../pinot/core/transport/ServerResponse.java | 25 +--
.../linkedin/pinot/core/util/ArrayCopyUtils.java | 25 +--
.../com/linkedin/pinot/core/util/AvroUtils.java | 25 +--
.../pinot/core/util/BaseIndexedPriorityQueue.java | 25 +--
.../com/linkedin/pinot/core/util/CrcUtils.java | 25 +--
.../linkedin/pinot/core/util/FixedIntArray.java | 25 +--
.../pinot/core/util/FixedIntArrayOffHeapIdMap.java | 25 +--
.../java/com/linkedin/pinot/core/util/IdMap.java | 25 +--
.../core/util/IntDoubleIndexedPriorityQueue.java | 25 +--
.../core/util/IntObjectIndexedPriorityQueue.java | 25 +--
.../com/linkedin/pinot/core/util/SizeUtil.java | 25 +--
.../pinot/core/util/SortedRangeIntersection.java | 25 +--
.../pinot/core/util/trace/TraceCallable.java | 25 +--
.../pinot/core/util/trace/TraceContext.java | 25 +--
.../pinot/core/util/trace/TraceRunnable.java | 25 +--
.../server/realtime/ControllerLeaderLocator.java | 25 +--
.../ServerSegmentCompletionProtocolHandler.java | 25 +--
.../pinot/core/common/DataFetcherTest.java | 25 +--
.../pinot/core/common/ObjectSerDeUtilsTest.java | 25 +--
.../core/common/RealtimeNoDictionaryTest.java | 25 +--
.../core/common/datatable/DataTableSerDeTest.java | 25 +--
.../core/common/docidsets/BitmapDocIdSetTest.java | 25 +--
.../core/common/docidsets/SortedDocIdSetTest.java | 25 +--
.../pinot/core/crypt/PinotCrypterFactoryTest.java | 25 +--
.../function/FunctionExpressionEvaluatorTest.java | 25 +--
.../data/manager/BaseTableDataManagerTest.java | 25 +--
.../realtime/LLRealtimeSegmentDataManagerTest.java | 25 +--
.../core/data/partition/PartitionFunctionTest.java | 25 +--
.../readers/BackfillDateTimeRecordReaderTest.java | 25 +--
.../core/data/readers/CSVRecordReaderTest.java | 25 +--
.../core/data/readers/JSONRecordReaderTest.java | 25 +--
.../MultiplePinotSegmentRecordReaderTest.java | 25 +--
.../data/readers/PinotSegmentRecordReaderTest.java | 25 +--
.../pinot/core/data/readers/PinotSegmentUtil.java | 25 +--
.../pinot/core/data/readers/RecordReaderTest.java | 25 +--
.../core/data/readers/ThriftRecordReaderTest.java | 25 +--
.../pinot/core/data/readers/ThriftSampleData.java | 25 +--
.../data/recordtransformer/PinotDataTypeTest.java | 25 +--
.../recordtransformer/RecordTransformerTest.java | 25 +--
.../recordtransformer/TimeTransformerTest.java | 25 +--
.../MutableSegmentImplAggregateMetricsTest.java | 25 +--
.../mutable/MutableSegmentImplTest.java | 25 +--
.../mutable/MutableSegmentImplTestUtils.java | 25 +--
.../pinot/core/io/util/PinotDataBitSetTest.java | 25 +--
.../impl/MmapMemoryManagerFileCleanupTest.java | 25 +--
.../core/io/writer/impl/MmapMemoryManagerTest.java | 25 +--
.../impl/MutableOffHeapByteArrayStoreTest.java | 25 +--
.../io/writer/impl/OffHeapStringStoreTest.java | 25 +--
.../metadata/MetadataExtractorFactoryTest.java | 25 +--
.../minion/MergeRollupSegmentConverterTest.java | 25 +--
.../pinot/core/minion/SegmentConverterTest.java | 25 +--
.../pinot/core/minion/SegmentPurgerTest.java | 25 +--
.../dociditerators/BitmapDocIdIteratorTest.java | 25 +--
.../RealtimeSingleValueIteratorTest.java | 25 +--
.../operator/filter/AndFilterOperatorTest.java | 25 +--
.../operator/filter/FilterOperatorUtilsTest.java | 25 +--
.../pinot/core/operator/filter/IntRangesTest.java | 25 +--
.../core/operator/filter/OrFilterOperatorTest.java | 25 +--
.../core/operator/filter/TestFilterOperator.java | 25 +--
.../function/AdditionTransformFunctionTest.java | 25 +--
.../function/BaseTransformFunctionTest.java | 25 +--
.../DateTimeConversionTransformFunctionTest.java | 25 +--
.../function/DivisionTransformFunctionTest.java | 25 +--
.../MultiplicationTransformFunctionTest.java | 25 +--
.../function/SubtractionTransformFunctionTest.java | 25 +--
.../TimeConversionTransformFunctionTest.java | 25 +--
.../function/ValueInTransformFunctionTest.java | 25 +--
.../datetime/DateTimeConverterTest.java | 25 +--
.../timeunit/TimeUnitTransformerTest.java | 25 +--
.../periodictask/PeriodicTaskSchedulerTest.java | 25 +--
.../pinot/core/plan/CombinePlanNodeTest.java | 25 +--
...adataAndDictionaryAggregationPlanMakerTest.java | 25 +--
.../pinot/core/predicate/InPredicateTest.java | 25 +--
.../NoDictionaryEqualsPredicateEvaluatorsTest.java | 25 +--
.../NoDictionaryInPredicateEvaluatorTest.java | 25 +--
.../NoDictionaryRangePredicateEvaluatorTest.java | 25 +--
.../predicate/PredicateEvaluatorTestUtils.java | 25 +--
...ngeOfflineDictionaryPredicateEvaluatorTest.java | 25 +--
.../function/AggregationFunctionFactoryTest.java | 25 +--
.../function/AggregationFunctionTypeTest.java | 25 +--
.../scheduler/MultiLevelPriorityQueueTest.java | 25 +--
.../query/scheduler/PrioritySchedulerTest.java | 25 +--
.../pinot/core/query/scheduler/TestHelper.java | 25 +--
.../core/query/scheduler/TestSchedulerGroup.java | 25 +--
.../query/scheduler/TestSchedulerGroupFactory.java | 25 +--
.../scheduler/fcfs/FCFSSchedulerGroupTest.java | 25 +--
.../resources/BoundedAccountingExecutorTest.java | 25 +--
.../scheduler/resources/ResourceManagerTest.java | 25 +--
.../resources/UnboundedResourceManagerTest.java | 25 +--
.../tokenbucket/TokenSchedulerGroupTest.java | 25 +--
.../impl/RealtimeSegmentStatsHistoryTest.java | 25 +--
.../impl/dictionary/DictionaryPerfRunner.java | 25 +--
.../impl/dictionary/MultiValueDictionaryTest.java | 25 +--
.../impl/dictionary/MutableDictionaryTest.java | 25 +--
.../kafka/AvroRecordToPinotRowGeneratorTest.java | 25 +--
.../impl/kafka/KafkaLowLevelStreamConfigTest.java | 25 +--
.../kafka/KafkaPartitionLevelConsumerTest.java | 25 +--
.../ConsumingSegmentAssignmentStrategyTest.java | 25 +--
.../stream/MetadataEqualsHashCodeTest.java | 25 +--
.../core/realtime/stream/OffsetCriteriaTest.java | 25 +--
.../core/realtime/stream/StreamConfigTest.java | 25 +--
.../core/segment/index/ColumnMetadataTest.java | 25 +--
.../segment/index/SegmentMetadataImplTest.java | 25 +--
.../SegmentV1V2ToV3FormatConverterTest.java | 25 +--
.../index/creator/BloomFilterCreatorTest.java | 25 +--
.../segment/index/creator/RawIndexCreatorTest.java | 25 +--
.../SegmentGenerationWithBytesTypeTest.java | 25 +--
.../SegmentGenerationWithTimeColumnTest.java | 25 +--
.../index/creator/SegmentPartitionTest.java | 25 +--
.../core/segment/index/loader/LoaderTest.java | 25 +--
.../core/segment/index/loader/LoaderUtilsTest.java | 25 +--
.../index/loader/SegmentPreProcessorTest.java | 25 +--
.../readers/ImmutableDictionaryReaderTest.java | 25 +--
.../core/segment/memory/PinotDataBufferTest.java | 25 +--
.../name/DefaultSegmentNameGeneratorTest.java | 25 +--
.../NormalizedDateSegmentNameGeneratorTest.java | 25 +--
.../store/ColumnIndexDirectoryTestHelper.java | 25 +--
.../segment/store/FilePerIndexDirectoryTest.java | 25 +--
.../segment/store/SegmentDirectoryPathsTest.java | 25 +--
.../segment/store/SegmentLocalFSDirectoryTest.java | 25 +--
.../store/SingleFileIndexDirectoryTest.java | 25 +--
.../pinot/core/startree/BaseStarTreeIndexTest.java | 25 +--
.../core/startree/OffHeapStarTreeBuilderTest.java | 25 +--
.../pinot/core/startree/StarTreeDataTableTest.java | 25 +--
.../startree/StarTreeIndexTestSegmentHelper.java | 25 +--
.../pinot/core/startree/SumStarTreeIndexTest.java | 25 +--
.../pinot/core/startree/TestStarTreeMetadata.java | 25 +--
.../pinot/core/startree/hll/HllFieldSizeTest.java | 25 +--
.../core/startree/hll/HllIndexCreationTest.java | 25 +--
.../core/startree/hll/HllStarTreeIndexTest.java | 25 +--
.../core/startree/hll/HllTypeConversionTest.java | 25 +--
.../OffHeapStarTreeBuilderWithHllFieldTest.java | 25 +--
.../hll/SegmentWithHllIndexCreateHelper.java | 25 +--
.../v2/AggregationFunctionColumnPairTest.java | 25 +--
.../pinot/core/startree/v2/AvgStarTreeV2Test.java | 25 +--
.../pinot/core/startree/v2/BaseStarTreeV2Test.java | 25 +--
.../core/startree/v2/CountStarTreeV2Test.java | 25 +--
.../v2/DistinctCountHLLStarTreeV2Test.java | 25 +--
.../pinot/core/startree/v2/MaxStarTreeV2Test.java | 25 +--
.../startree/v2/MinMaxRangeStarTreeV2Test.java | 25 +--
.../pinot/core/startree/v2/MinStarTreeV2Test.java | 25 +--
.../startree/v2/PercentileEstStarTreeV2Test.java | 25 +--
.../v2/PercentileTDigestStarTreeV2Test.java | 25 +--
.../v2/PreAggregatedAvgStarTreeV2Test.java | 25 +--
...reAggregatedDistinctCountHLLStarTreeV2Test.java | 25 +--
.../v2/PreAggregatedMinMaxRangeStarTreeV2Test.java | 25 +--
.../PreAggregatedPercentileEstStarTreeV2Test.java | 25 +--
...eAggregatedPercentileTDigestStarTreeV2Test.java | 25 +--
.../pinot/core/startree/v2/SumStarTreeV2Test.java | 25 +--
.../linkedin/pinot/core/transport/DummyServer.java | 25 +--
.../pinot/core/transport/QueryRouterTest.java | 25 +--
.../pinot/core/util/ArrayCopyUtilsTest.java | 25 +--
.../com/linkedin/pinot/core/util/CrcUtilsTest.java | 25 +--
.../pinot/core/util/DoubleComparisonUtil.java | 25 +--
.../core/util/SortedRangeIntersectionTest.java | 25 +--
.../pinot/core/util/trace/TraceContextTest.java | 25 +--
.../pinot/index/persist/AvroDataPublisherTest.java | 25 +--
.../pinot/index/reader/FileReaderTestUtils.java | 25 +--
.../pinot/index/reader/FixedBitMultiValueTest.java | 25 +--
.../FixedByteWidthRowColDataFileReaderTest.java | 25 +--
.../index/reader/SortedForwardIndexReaderTest.java | 25 +--
.../FixedByteChunkSingleValueReaderWriteTest.java | 25 +--
...ByteSingleColumnMultiValueReaderWriterTest.java | 25 +--
...yteSingleColumnSingleValueReaderWriterTest.java | 25 +--
...ByteSingleValueMultiColumnReaderWriterTest.java | 25 +--
.../VarByteChunkSingleValueReaderWriteTest.java | 25 +--
.../FixedByteWidthRowColDataFileWriterTest.java | 25 +--
.../pinot/queries/BaseMultiValueQueriesTest.java | 25 +--
.../linkedin/pinot/queries/BaseQueriesTest.java | 25 +--
.../pinot/queries/BaseSingleValueQueriesTest.java | 25 +--
.../linkedin/pinot/queries/FastHllQueriesTest.java | 25 +--
...nerSegmentAggregationMultiValueQueriesTest.java | 25 +--
...erSegmentAggregationSingleValueQueriesTest.java | 25 +--
...InnerSegmentSelectionMultiValueQueriesTest.java | 25 +--
...nnerSegmentSelectionSingleValueQueriesTest.java | 25 +--
...terSegmentAggregationMultiValueQueriesTest.java | 25 +--
...erSegmentAggregationSingleValueQueriesTest.java | 25 +--
.../queries/PercentileTDigestMVQueriesTest.java | 25 +--
.../queries/PercentileTDigestQueriesTest.java | 25 +--
.../linkedin/pinot/queries/QueriesTestUtils.java | 25 +--
.../DefaultAggregationExecutorTest.java | 25 +--
.../DoubleAggregationResultHolderTest.java | 25 +--
.../AggregationGroupByTrimmingServiceTest.java | 25 +--
.../DictionaryBasedGroupKeyGeneratorTest.java | 25 +--
.../groupby/DoubleGroupByResultHolderTest.java | 25 +--
.../groupby/NoDictionaryGroupKeyGeneratorTest.java | 25 +--
.../pinot/query/executor/QueryExecutorTest.java | 25 +--
.../query/pruner/ColumnValueSegmentPrunerTest.java | 25 +--
.../selection/SelectionOperatorServiceTest.java | 25 +--
.../converter/RealtimeSegmentConverterTest.java | 25 +--
.../pinot/reduce/HavingClauseComparisonTests.java | 25 +--
.../v1/creator/BitmapInvertedIndexCreatorTest.java | 25 +--
.../v1/creator/BitmapInvertedIndexTest.java | 25 +--
.../pinot/segments/v1/creator/BlocksTest.java | 25 +--
.../segments/v1/creator/DictionariesTest.java | 25 +--
.../v1/creator/FixedIntArrayIdMapTest.java | 25 +--
.../pinot/segments/v1/creator/IntArraysTest.java | 25 +--
.../v1/creator/OnHeapDictionariesTest.java | 25 +--
.../segments/v1/creator/SegmentTestUtils.java | 25 +--
.../realtime/ControllerLeaderLocatorTest.java | 25 +--
.../util/IntDoubleIndexedPriorityQueueTest.java | 25 +--
.../util/IntObjectIndexedPriorityQueueTest.java | 25 +--
.../java/com/linkedin/pinot/util/TestUtils.java | 25 +--
pinot-core/testng.xml | 25 +--
pinot-distribution/pinot-assembly.xml | 25 +--
pinot-distribution/pom.xml | 25 +--
pinot-filesystem/pom.xml | 25 +--
.../linkedin/pinot/filesystem/LocalPinotFS.java | 25 +--
.../com/linkedin/pinot/filesystem/PinotFS.java | 25 +--
.../linkedin/pinot/filesystem/PinotFSFactory.java | 26 +--
.../pinot/filesystem/LocalPinotFSTest.java | 25 +--
.../pinot/filesystem/PinotFSFactoryTest.java | 25 +--
pinot-hadoop-filesystem/pom.xml | 25 +--
.../linkedin/pinot/filesystem/HadoopPinotFS.java | 25 +--
pinot-hadoop/pom.xml | 25 +--
.../pinot/hadoop/PinotHadoopJobLauncher.java | 25 +--
.../com/linkedin/pinot/hadoop/io/FileHandler.java | 25 +--
.../pinot/hadoop/io/JsonPinotOutputFormat.java | 25 +--
.../pinot/hadoop/io/PinotOutputFormat.java | 25 +--
.../com/linkedin/pinot/hadoop/io/PinotRecord.java | 25 +--
.../pinot/hadoop/io/PinotRecordSerialization.java | 25 +--
.../pinot/hadoop/io/PinotRecordWriter.java | 25 +--
.../pinot/hadoop/job/ControllerRestApi.java | 25 +--
.../pinot/hadoop/job/JobConfigConstants.java | 25 +--
.../pinot/hadoop/job/SegmentCreationJob.java | 25 +--
.../pinot/hadoop/job/SegmentTarPushJob.java | 25 +--
.../pinot/hadoop/job/SegmentUriPushJob.java | 25 +--
.../mapper/HadoopSegmentCreationMapReduceJob.java | 25 +--
.../linkedin/pinot/hadoop/utils/PushLocation.java | 26 +--
.../pinot/hadoop/io/PinotOutputFormatTest.java | 25 +--
pinot-integration-tests/pom.xml | 25 +--
...umSegmentAssignmentStrategyIntegrationTest.java | 25 +--
.../tests/BaseClusterIntegrationTest.java | 25 +--
.../tests/BaseClusterIntegrationTestSet.java | 25 +--
.../tests/ChaosMonkeyIntegrationTest.java | 25 +--
.../tests/ClusterIntegrationTestUtils.java | 25 +--
.../pinot/integration/tests/ClusterTest.java | 25 +--
...vertToRawIndexMinionClusterIntegrationTest.java | 25 +--
.../DeleteAPIHybridClusterIntegrationTest.java | 25 +--
...lakyConsumerRealtimeClusterIntegrationTest.java | 25 +--
...mentBuildPushOfflineClusterIntegrationTest.java | 25 +--
.../tests/HybridClusterIntegrationTest.java | 25 +--
...ridClusterIntegrationTestCommandLineRunner.java | 25 +--
.../tests/LLCRealtimeClusterIntegrationTest.java | 25 +--
...CRealtimeClusterSplitCommitIntegrationTest.java | 25 +--
...onaryAggregationPlanClusterIntegrationTest.java | 25 +--
.../MultiNodesOfflineClusterIntegrationTest.java | 25 +--
.../tests/NewConfigApplyIntegrationTest.java | 26 +--
.../tests/OfflineClusterIntegrationTest.java | 25 +--
.../tests/PinotURIUploadIntegrationTest.java | 25 +--
.../pinot/integration/tests/QueryGenerator.java | 25 +--
.../tests/RealtimeClusterIntegrationTest.java | 25 +--
.../tests/SegmentCompletionIntegrationTests.java | 25 +--
.../tests/SimpleMinionClusterIntegrationTest.java | 25 +--
.../tests/StarTreeClusterIntegrationTest.java | 25 +--
.../tests/StarTreeV2ClusterIntegrationTest.java | 25 +--
.../tests/UploadRefreshDeleteIntegrationTest.java | 25 +--
pinot-minion/pom.xml | 25 +--
.../com/linkedin/pinot/minion/MinionContext.java | 25 +--
.../com/linkedin/pinot/minion/MinionStarter.java | 25 +--
.../minion/events/DefaultMinionEventObserver.java | 25 +--
.../events/DefaultMinionEventObserverFactory.java | 25 +--
.../events/EventObserverFactoryRegistry.java | 25 +--
.../pinot/minion/events/MinionEventObserver.java | 25 +--
.../minion/events/MinionEventObserverFactory.java | 25 +--
.../pinot/minion/exception/FatalException.java | 25 +--
.../minion/exception/TaskCancelledException.java | 25 +--
.../BaseMultipleSegmentsConversionExecutor.java | 25 +--
.../BaseSingleSegmentConversionExecutor.java | 25 +--
.../pinot/minion/executor/BaseTaskExecutor.java | 25 +--
.../executor/ConvertToRawIndexTaskExecutor.java | 25 +--
.../ConvertToRawIndexTaskExecutorFactory.java | 25 +--
.../pinot/minion/executor/PinotTaskExecutor.java | 25 +--
.../minion/executor/PinotTaskExecutorFactory.java | 25 +--
.../pinot/minion/executor/PurgeTaskExecutor.java | 25 +--
.../minion/executor/PurgeTaskExecutorFactory.java | 25 +--
.../minion/executor/SegmentConversionResult.java | 25 +--
.../minion/executor/SegmentConversionUtils.java | 25 +--
.../executor/TaskExecutorFactoryRegistry.java | 25 +--
.../linkedin/pinot/minion/metrics/MinionGauge.java | 25 +--
.../linkedin/pinot/minion/metrics/MinionMeter.java | 25 +--
.../pinot/minion/metrics/MinionMetrics.java | 25 +--
.../pinot/minion/metrics/MinionQueryPhase.java | 25 +--
.../linkedin/pinot/minion/metrics/MinionTimer.java | 25 +--
.../minion/taskfactory/TaskFactoryRegistry.java | 25 +--
.../minion/executor/PurgeTaskExecutorTest.java | 25 +--
pinot-perf/pom.xml | 25 +--
.../linkedin/pinot/perf/BenchmarkDictionary.java | 25 +--
.../pinot/perf/BenchmarkDictionaryCreation.java | 25 +--
.../perf/BenchmarkFixedIntArrayOffHeapIdMap.java | 25 +--
.../perf/BenchmarkOffHeapDictionaryMemory.java | 25 +--
.../pinot/perf/BenchmarkOfflineIndexReader.java | 25 +--
.../pinot/perf/BenchmarkOrDocIdIterator.java | 25 +--
.../linkedin/pinot/perf/BenchmarkQueryEngine.java | 25 +--
.../perf/BenchmarkRealtimeConsumptionSpeed.java | 25 +--
.../pinot/perf/BenchmarkStringDictionary.java | 25 +--
.../com/linkedin/pinot/perf/DictionaryDumper.java | 25 +--
.../pinot/perf/ForwardIndexWriterBenchmark.java | 25 +--
.../com/linkedin/pinot/perf/RawIndexBenchmark.java | 25 +--
.../linkedin/pinot/perf/RealtimeStressTest.java | 25 +--
.../pinot/perf/StringDictionaryPerfTest.java | 25 +--
pinot-server/pom.xml | 25 +--
.../api/resources/DefaultExceptionMapper.java | 25 +--
.../pinot/server/api/resources/ErrorInfo.java | 25 +--
.../pinot/server/api/resources/ErrorResponse.java | 25 +--
.../server/api/resources/HealthCheckResource.java | 25 +--
.../server/api/resources/MmapDebugResource.java | 25 +--
.../server/api/resources/SchedulerResource.java | 25 +--
.../server/api/resources/TableSizeResource.java | 25 +--
.../pinot/server/api/resources/TablesResource.java | 25 +--
.../pinot/server/conf/NettyServerConfig.java | 25 +--
.../com/linkedin/pinot/server/conf/ServerConf.java | 25 +--
.../server/request/ScheduledRequestHandler.java | 25 +--
.../pinot/server/starter/ServerBuilder.java | 25 +--
.../pinot/server/starter/ServerInstance.java | 25 +--
.../server/starter/helix/AdminApiApplication.java | 25 +--
.../helix/DefaultHelixStarterServerConfig.java | 25 +--
.../starter/helix/HelixInstanceDataManager.java | 25 +--
.../helix/HelixInstanceDataManagerConfig.java | 25 +--
.../server/starter/helix/HelixServerStarter.java | 25 +--
.../starter/helix/SegmentFetcherAndLoader.java | 25 +--
.../pinot/server/starter/helix/SegmentLocks.java | 25 +--
.../helix/SegmentMessageHandlerFactory.java | 25 +--
.../SegmentOnlineOfflineStateModelFactory.java | 25 +--
.../server/api/resources/BaseResourceTest.java | 25 +--
.../api/resources/TableSizeResourceTest.java | 25 +--
.../server/api/resources/TablesResourceTest.java | 25 +--
.../realtime/RealtimeTableDataManagerTest.java | 25 +--
.../request/ScheduledRequestHandlerTest.java | 25 +--
.../pinot/server/util/SegmentTestUtils.java | 25 +--
pinot-style.xml | 25 +--
pinot-tools/pom.xml | 25 +--
.../linkedin/pinot/tools/AbstractBaseCommand.java | 25 +--
.../pinot/tools/AutoAddInvertedIndexTool.java | 25 +--
.../linkedin/pinot/tools/ClusterStateVerifier.java | 25 +--
.../java/com/linkedin/pinot/tools/Command.java | 25 +--
.../com/linkedin/pinot/tools/HybridQuickstart.java | 25 +--
.../pinot/tools/PinotIdealstateChanger.java | 26 +--
.../pinot/tools/PinotNumReplicaChanger.java | 25 +--
.../pinot/tools/PinotSegmentRebalancer.java | 25 +--
.../linkedin/pinot/tools/PinotToolLauncher.java | 25 +--
.../com/linkedin/pinot/tools/PinotZKChanger.java | 25 +--
.../java/com/linkedin/pinot/tools/Quickstart.java | 25 +--
.../pinot/tools/QuickstartTableRequest.java | 25 +--
.../linkedin/pinot/tools/RealtimeQuickStart.java | 25 +--
.../com/linkedin/pinot/tools/SegmentDumpTool.java | 25 +--
.../java/com/linkedin/pinot/tools/SpeedTest.java | 25 +--
.../linkedin/pinot/tools/StarTreeIndexViewer.java | 25 +--
.../linkedin/pinot/tools/UpdateSegmentState.java | 25 +--
.../pinot/tools/ValidateTableRetention.java | 25 +--
.../pinot/tools/admin/PinotAdministrator.java | 25 +--
.../linkedin/pinot/tools/admin/PinotBroker.java | 25 +--
.../pinot/tools/admin/PinotController.java | 25 +--
.../linkedin/pinot/tools/admin/PinotServer.java | 25 +--
.../admin/command/AbstractBaseAdminCommand.java | 25 +--
.../tools/admin/command/AddSchemaCommand.java | 25 +--
.../pinot/tools/admin/command/AddTableCommand.java | 25 +--
.../tools/admin/command/AddTenantCommand.java | 25 +--
.../admin/command/ApplyTableConfigCommand.java | 25 +--
.../admin/command/AvroSchemaToPinotSchema.java | 25 +--
.../command/BackfillDateTimeColumnCommand.java | 25 +--
.../admin/command/ChangeNumReplicasCommand.java | 25 +--
.../tools/admin/command/ChangeTableState.java | 25 +--
.../tools/admin/command/CreateSegmentCommand.java | 25 +--
.../tools/admin/command/DeleteClusterCommand.java | 25 +--
.../tools/admin/command/GenerateDataCommand.java | 25 +--
.../tools/admin/command/MoveReplicaGroup.java | 25 +--
.../tools/admin/command/PostQueryCommand.java | 25 +--
.../tools/admin/command/QuickstartRunner.java | 25 +--
.../command/RealtimeProvisioningHelperCommand.java | 25 +--
.../tools/admin/command/RebalanceTableCommand.java | 25 +--
.../admin/command/ShowClusterInfoCommand.java | 25 +--
.../tools/admin/command/StartBrokerCommand.java | 25 +--
.../admin/command/StartControllerCommand.java | 25 +--
.../tools/admin/command/StartKafkaCommand.java | 25 +--
.../tools/admin/command/StartServerCommand.java | 25 +--
.../tools/admin/command/StartZookeeperCommand.java | 25 +--
.../tools/admin/command/StopProcessCommand.java | 25 +--
.../admin/command/StreamAvroIntoKafkaCommand.java | 25 +--
.../tools/admin/command/UploadSegmentCommand.java | 25 +--
.../tools/admin/command/ValidateConfigCommand.java | 25 +--
.../admin/command/VerifyClusterStateCommand.java | 25 +--
.../tools/admin/command/VerifySegmentState.java | 25 +--
.../pinot/tools/backfill/BackfillSegmentUtils.java | 25 +--
.../tools/config/validator/SchemaValidator.java | 25 +--
.../config/validator/TableConfigValidator.java | 25 +--
.../pinot/tools/data/generator/AvroWriter.java | 25 +--
.../pinot/tools/data/generator/DataGenerator.java | 25 +--
.../tools/data/generator/DataGeneratorSpec.java | 25 +--
.../pinot/tools/data/generator/Generator.java | 25 +--
.../tools/data/generator/GeneratorFactory.java | 25 +--
.../tools/data/generator/NumberGenerator.java | 25 +--
.../tools/data/generator/RangeDoubleGenerator.java | 25 +--
.../tools/data/generator/RangeFloatGenerator.java | 25 +--
.../tools/data/generator/RangeIntGenerator.java | 25 +--
.../tools/data/generator/RangeLongGenerator.java | 25 +--
.../tools/data/generator/SchemaAnnotation.java | 25 +--
.../tools/data/generator/StringGenerator.java | 25 +--
.../pinot/tools/perf/PerfBenchmarkDriver.java | 25 +--
.../pinot/tools/perf/PerfBenchmarkDriverConf.java | 25 +--
.../pinot/tools/perf/PerfBenchmarkRunner.java | 25 +--
.../com/linkedin/pinot/tools/perf/QueryRunner.java | 25 +--
.../pinot/tools/perf/ZookeeperLauncher.java | 25 +--
.../tools/query/comparison/ClusterStarter.java | 25 +--
.../tools/query/comparison/QueryComparison.java | 25 +--
.../query/comparison/QueryComparisonConfig.java | 25 +--
.../query/comparison/SegmentInfoProvider.java | 25 +--
.../query/comparison/StarQueryComparison.java | 25 +--
.../query/comparison/StarTreeQueryGenerator.java | 25 +--
.../tools/query/comparison/StatsGenerator.java | 25 +--
.../realtime/provisioning/MemoryEstimator.java | 25 +--
.../pinot/tools/scan/query/Aggregation.java | 25 +--
.../pinot/tools/scan/query/AggregationFunc.java | 25 +--
.../tools/scan/query/AggregationFuncFactory.java | 25 +--
.../pinot/tools/scan/query/AvgFunction.java | 25 +--
.../pinot/tools/scan/query/CountFunction.java | 25 +--
.../tools/scan/query/DistinctCountFunction.java | 25 +--
.../tools/scan/query/EqualsPredicateFilter.java | 25 +--
.../pinot/tools/scan/query/GroupByOperator.java | 25 +--
.../pinot/tools/scan/query/InPredicateFilter.java | 25 +--
.../pinot/tools/scan/query/MaxFunction.java | 25 +--
.../pinot/tools/scan/query/MinFunction.java | 25 +--
.../tools/scan/query/MinMaxRangeFunction.java | 25 +--
.../tools/scan/query/NotInPredicateFilter.java | 25 +--
.../pinot/tools/scan/query/NotPredicateFilter.java | 25 +--
.../pinot/tools/scan/query/PredicateFilter.java | 25 +--
.../pinot/tools/scan/query/Projection.java | 25 +--
.../pinot/tools/scan/query/QueryResponse.java | 25 +--
.../tools/scan/query/RangePredicateFilter.java | 25 +--
.../pinot/tools/scan/query/ResultTable.java | 25 +--
.../tools/scan/query/ScanBasedQueryProcessor.java | 25 +--
.../tools/scan/query/SegmentQueryProcessor.java | 25 +--
.../linkedin/pinot/tools/scan/query/Selection.java | 25 +--
.../pinot/tools/scan/query/SumFunction.java | 25 +--
.../com/linkedin/pinot/tools/scan/query/Utils.java | 25 +--
.../converter/ColumnarToStarTreeConverter.java | 25 +--
.../converter/DictionaryToRawIndexConverter.java | 25 +--
.../converter/PinotSegmentConvertCommand.java | 25 +--
.../segment/converter/PinotSegmentConverter.java | 25 +--
.../converter/PinotSegmentToAvroConverter.java | 25 +--
.../converter/PinotSegmentToCsvConverter.java | 25 +--
.../converter/PinotSegmentToJsonConverter.java | 25 +--
.../segment/converter/SegmentMergeCommand.java | 25 +--
.../pinot/tools/streams/AirlineDataStream.java | 25 +--
.../pinot/tools/streams/MeetupRsvpStream.java | 25 +--
pinot-transport/pom.xml | 25 +--
.../common/AbstractCompositeListenableFuture.java | 25 +--
.../transport/common/AsyncResponseFuture.java | 25 +--
.../linkedin/pinot/transport/common/Callback.java | 25 +--
.../pinot/transport/common/Cancellable.java | 25 +--
.../pinot/transport/common/CompositeFuture.java | 25 +--
.../pinot/transport/common/LinkedDequeue.java | 25 +--
.../linkedin/pinot/transport/common/NoneType.java | 25 +--
.../pinot/transport/common/SelectingFuture.java | 25 +--
.../transport/common/ServerResponseFuture.java | 25 +--
.../pinot/transport/conf/TransportClientConf.java | 25 +--
.../transport/config/ConnectionPoolConfig.java | 25 +--
.../transport/config/PerTableRoutingConfig.java | 25 +--
.../pinot/transport/config/RoutingTableConfig.java | 25 +--
.../pinot/transport/config/ThreadPoolConfig.java | 25 +--
.../transport/metrics/AggregatedPoolStats.java | 25 +--
.../metrics/AggregatedTransportClientMetrics.java | 25 +--
.../metrics/AggregatedTransportServerMetrics.java | 25 +--
.../pinot/transport/metrics/AsyncPoolStats.java | 25 +--
.../transport/metrics/NettyClientMetrics.java | 25 +--
.../transport/metrics/NettyServerMetrics.java | 25 +--
.../pinot/transport/metrics/PoolStats.java | 25 +--
.../pinot/transport/metrics/PoolStatsProvider.java | 25 +--
.../transport/metrics/TransportClientMetrics.java | 25 +--
.../transport/metrics/TransportServerMetrics.java | 25 +--
.../transport/netty/NettyClientConnection.java | 25 +--
.../pinot/transport/netty/NettyServer.java | 25 +--
.../transport/netty/NettyTCPClientConnection.java | 25 +--
.../pinot/transport/netty/NettyTCPServer.java | 25 +--
.../netty/PooledNettyClientResourceManager.java | 25 +--
.../linkedin/pinot/transport/pool/AsyncPool.java | 25 +--
.../pinot/transport/pool/AsyncPoolImpl.java | 25 +--
.../pool/AsyncPoolResourceManagerAdapter.java | 25 +--
.../linkedin/pinot/transport/pool/KeyedPool.java | 25 +--
.../pinot/transport/pool/KeyedPoolImpl.java | 25 +--
.../transport/pool/PooledResourceManager.java | 25 +--
.../transport/pool/SizeLimitExceededException.java | 25 +--
.../transport/scattergather/ScatterGather.java | 25 +--
.../transport/scattergather/ScatterGatherImpl.java | 25 +--
.../scattergather/ScatterGatherRequest.java | 25 +--
.../scattergather/ScatterGatherStats.java | 25 +--
.../test/java/com/linkedin/pinot/Checkable.java | 25 +--
.../test/java/com/linkedin/pinot/TestUtils.java | 25 +--
.../transport/common/CompositeFutureTest.java | 25 +--
.../pinot/transport/common/ResponseFutureTest.java | 25 +--
.../transport/common/SelectingFutureTest.java | 25 +--
.../pinot/transport/common/ServerInstanceTest.java | 25 +--
.../transport/netty/NettyCloseChannelTest.java | 25 +--
.../NettySingleConnectionIntegrationTest.java | 25 +--
.../pinot/transport/netty/NettyTestUtils.java | 25 +--
.../transport/perf/ScatterGatherPerfClient.java | 25 +--
.../transport/perf/ScatterGatherPerfServer.java | 25 +--
.../transport/perf/ScatterGatherPerfTester.java | 25 +--
.../pool/AsyncPoolResourceManagerAdapterTest.java | 25 +--
.../pinot/transport/pool/KeyedPoolImplTest.java | 25 +--
.../transport/scattergather/ScatterGatherTest.java | 25 +--
pom.xml | 39 ++--
.../rootcause-select-comparison-range/component.js | 90 +++------
.../component.js | 216 ---------------------
.../template.hbs | 74 -------
.../app/pods/home/index/template.hbs | 2 +-
.../app/pods/home/share-dashboard/route.js | 8 +-
thirdeye/thirdeye-frontend/app/utils/rca-utils.js | 76 +++++---
.../anomaly/alert/v2/AlertJobRunnerV2.java | 1 -
.../classification/ClassificationJobRunner.java | 1 -
.../anomaly/detection/DetectionJobRunner.java | 1 -
.../thirdeye/anomaly/monitor/MonitorJobRunner.java | 1 -
.../anomaly/onboard/DetectionOnboardResource.java | 1 -
.../linkedin/thirdeye/anomaly/task/TaskDriver.java | 25 +++
.../anomaly/utils/ThirdeyeMetricsUtil.java | 22 +++
.../checker/DataCompletenessJobRunner.java | 1 -
.../thirdeye/datalayer/bao/TaskManager.java | 3 +
.../datalayer/bao/jdbc/TaskManagerImpl.java | 35 +++-
.../thirdeye/detection/DetectionPipelineJob.java | 27 ++-
.../detection/alert/DetectionAlertJob.java | 1 -
.../thirdeye/detection/yaml/YamlResource.java | 11 +-
.../datalayer/bao/TestAnomalyTaskManager.java | 8 +
1718 files changed, 24161 insertions(+), 18949 deletions(-)
create mode 100644 license.header
delete mode 100644 thirdeye/thirdeye-frontend/app/pods/components/rootcause-select-comparison-range2/component.js
delete mode 100644 thirdeye/thirdeye-frontend/app/pods/components/rootcause-select-comparison-range2/template.hbs
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org