You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by jl...@apache.org on 2021/02/26 18:04:52 UTC
[incubator-pinot] branch master updated (ead8aa9 -> e90a973)
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from ead8aa9 Remove the temporary code for backward-compatibility in DistinctCountAggregationFunction (#6617)
add e90a973 Decouple from yammer library (#6579)
No new revisions were added by this update.
Summary of changes:
.../broker/broker/helix/HelixBrokerStarter.java | 14 +-
.../LiteralOnlyBrokerRequestTest.java | 8 +-
.../pinot/common/metrics/AbstractMetrics.java | 63 +++----
.../pinot/common/metrics/AggregatedCounter.java | 131 --------------
.../pinot/common/metrics/AggregatedHistogram.java | 200 ---------------------
.../pinot/common/metrics/AggregatedLongGauge.java | 108 -----------
.../pinot/common/metrics/AggregatedMeter.java | 195 --------------------
.../common/metrics/AggregatedMetricsRegistry.java | 94 ----------
.../apache/pinot/common/metrics/BrokerMetrics.java | 8 +-
.../pinot/common/metrics/ControllerMetrics.java | 6 +-
...eporterMetricsRegistryRegistrationListener.java | 7 +-
.../apache/pinot/common/metrics/LatencyMetric.java | 95 ----------
.../apache/pinot/common/metrics/MetricsHelper.java | 149 +++------------
.../MetricsRegistryRegistrationListener.java | 4 +-
.../pinot/common/metrics/PinotMetricUtils.java | 99 ++++++++++
.../apache/pinot/common/metrics/ServerMetrics.java | 8 +-
.../pinot/common/metrics/ValidationMetrics.java | 50 ++++--
.../pinot/common/metrics/yammer/YammerCounter.java | 23 +--
.../pinot/common/metrics/yammer/YammerGauge.java | 37 ++--
.../YammerJmxReporter.java} | 22 ++-
.../yammer/YammerMeter.java} | 25 +--
.../pinot/common/metrics/yammer/YammerMetered.java | 60 +++----
.../pinot/common/metrics/yammer/YammerMetric.java | 20 ++-
.../common/metrics/yammer/YammerMetricName.java | 22 +--
.../metrics/yammer/YammerMetricsRegistry.java | 106 +++++++++++
.../yammer/YammerMetricsRegistryListener.java | 50 ++++++
.../pinot/common/metrics/yammer/YammerTimer.java | 64 +++----
.../pinot/common/metrics/MetricsHelperTest.java | 22 +--
.../pinot/common/metrics/PinotMetricUtilsTest.java | 61 +++++++
.../spark/connector/PinotServerDataFetcher.scala | 5 +-
.../apache/pinot/controller/ControllerStarter.java | 49 +++--
.../controller/LeadControllerManagerTest.java | 4 +-
.../pinot/controller/api/TableSizeReaderTest.java | 5 +-
.../controller/helix/SegmentStatusCheckerTest.java | 25 +--
.../periodictask/ControllerPeriodicTaskTest.java | 5 +-
.../helix/core/realtime/SegmentCompletionTest.java | 6 +-
.../helix/core/retention/RetentionManagerTest.java | 6 +-
.../core/retention/SegmentLineageCleanupTest.java | 4 +-
.../validation/StorageQuotaCheckerTest.java | 4 +-
.../realtime/HLRealtimeSegmentDataManager.java | 6 +-
.../realtime/LLRealtimeSegmentDataManager.java | 6 +-
.../core/io/writer/impl/DirectMemoryManager.java | 4 +-
.../core/io/writer/impl/MmapMemoryManager.java | 4 +-
.../data/manager/BaseTableDataManagerTest.java | 5 +-
.../offline/DimensionTableDataManagerTest.java | 4 +-
.../realtime/LLRealtimeSegmentDataManagerTest.java | 6 +-
.../scheduler/MultiLevelPriorityQueueTest.java | 14 +-
.../query/scheduler/PrioritySchedulerTest.java | 5 +-
.../scheduler/fcfs/FCFSSchedulerGroupTest.java | 4 +-
.../SegmentGenerationWithNullValueVectorTest.java | 5 +-
.../pinot/query/executor/QueryExecutorTest.java | 5 +-
.../tests/SegmentCompletionIntegrationTest.java | 9 +-
.../org/apache/pinot/minion/MinionStarter.java | 22 ++-
.../apache/pinot/minion/metrics/MinionMetrics.java | 6 +-
.../pinot/server/starter/ServerInstance.java | 9 +-
.../org/apache/pinot/spi/metrics/PinotCounter.java | 11 +-
.../PinotGauge.java} | 32 ++--
.../apache/pinot/spi/metrics/PinotHistogram.java | 15 +-
.../apache/pinot/spi/metrics/PinotJmxReporter.java | 11 +-
.../org/apache/pinot/spi/metrics/PinotMeter.java | 15 +-
.../org/apache/pinot/spi/metrics/PinotMetered.java | 93 ++++++++++
.../org/apache/pinot/spi/metrics/PinotMetric.java | 10 +-
.../apache/pinot/spi/metrics/PinotMetricName.java | 9 +-
.../pinot/spi/metrics/PinotMetricsRegistry.java | 111 ++++++++++++
.../PinotMetricsRegistryListener.java} | 38 ++--
.../org/apache/pinot/spi/metrics/PinotTimer.java | 24 +--
66 files changed, 999 insertions(+), 1348 deletions(-)
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/AggregatedCounter.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/AggregatedHistogram.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/AggregatedLongGauge.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/AggregatedMeter.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/AggregatedMetricsRegistry.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/LatencyMetric.java
create mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/PinotMetricUtils.java
copy pinot-core/src/main/java/org/apache/pinot/core/operator/docidsets/MatchAllDocIdSet.java => pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerCounter.java (64%)
copy pinot-core/src/main/java/org/apache/pinot/core/operator/filter/MatchAllFilterOperator.java => pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerGauge.java (57%)
copy pinot-common/src/main/java/org/apache/pinot/common/metrics/{MetricsRegistryRegistrationListener.java => yammer/YammerJmxReporter.java} (61%)
copy pinot-common/src/main/java/org/apache/pinot/common/{restlet/resources/TableSegments.java => metrics/yammer/YammerMeter.java} (67%)
copy pinot-core/src/main/java/org/apache/pinot/core/query/utils/idset/EmptyIdSet.java => pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMetered.java (51%)
copy pinot-spi/src/main/java/org/apache/pinot/spi/utils/retry/NoDelayRetryPolicy.java => pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMetric.java (71%)
copy pinot-core/src/main/java/org/apache/pinot/core/operator/docidsets/MatchAllDocIdSet.java => pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMetricName.java (63%)
create mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMetricsRegistry.java
create mode 100644 pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerMetricsRegistryListener.java
copy pinot-core/src/main/java/org/apache/pinot/core/query/utils/idset/EmptyIdSet.java => pinot-common/src/main/java/org/apache/pinot/common/metrics/yammer/YammerTimer.java (50%)
create mode 100644 pinot-common/src/test/java/org/apache/pinot/common/metrics/PinotMetricUtilsTest.java
copy pinot-tools/src/main/java/org/apache/pinot/tools/data/generator/Generator.java => pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotCounter.java (82%)
copy pinot-spi/src/main/java/org/apache/pinot/spi/{stream/StreamDataProducer.java => metrics/PinotGauge.java} (58%)
copy pinot-core/src/main/java/org/apache/pinot/core/common/BlockDocIdValueIterator.java => pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotHistogram.java (73%)
copy pinot-tools/src/main/java/org/apache/pinot/tools/data/generator/Generator.java => pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotJmxReporter.java (83%)
copy pinot-core/src/main/java/org/apache/pinot/core/common/BlockDocIdValueIterator.java => pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMeter.java (70%)
create mode 100644 pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMetered.java
copy pinot-common/src/main/java/org/apache/pinot/common/tier/TierStorage.java => pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMetric.java (81%)
copy pinot-core/src/main/java/org/apache/pinot/core/segment/virtualcolumn/package-info.java => pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMetricName.java (86%)
create mode 100644 pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMetricsRegistry.java
copy pinot-spi/src/main/java/org/apache/pinot/spi/{stream/StreamDataServerStartable.java => metrics/PinotMetricsRegistryListener.java} (56%)
copy pinot-core/src/main/java/org/apache/pinot/core/data/partition/PartitionFunction.java => pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotTimer.java (53%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org