This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from 7f6afdf [TE] detection health - generate task status in monitoring
task (#5065)
add 344bade Re-design the broker routing (#5046)
No new revisions were added by this update.
Summary of changes:
.../pinot/broker/routing/v2/RoutingManager.java | 502 +++++++++++++++++++++
.../instanceselector/BalancedInstanceSelector.java | 55 +++
.../v2/instanceselector/BaseInstanceSelector.java | 179 ++++++++
.../v2/instanceselector/InstanceSelector.java | 60 +++
.../instanceselector/InstanceSelectorFactory.java | 49 ++
.../ReplicaGroupInstanceSelector.java | 65 +++
.../v2/segmentpruner/PartitionSegmentPruner.java | 191 ++++++++
.../routing/v2/segmentpruner/SegmentPruner.java | 57 +++
.../v2/segmentpruner/SegmentPrunerFactory.java | 100 ++++
.../v2/segmentselector/OfflineSegmentSelector.java | 36 +-
.../segmentselector/RealtimeSegmentSelector.java | 165 +++++++
.../v2/segmentselector/SegmentSelector.java | 62 +++
.../v2/segmentselector/SegmentSelectorFactory.java | 17 +-
.../routing/v2/timeboundary/TimeBoundaryInfo.java | 23 +-
.../v2/timeboundary/TimeBoundaryManager.java | 193 ++++++++
.../BalancedRandomRoutingTableBuilderTest.java | 4 +-
...rtitionAwareOfflineRoutingTableBuilderTest.java | 2 +-
...titionAwareRealtimeRoutingTableBuilderTest.java | 2 +-
.../v2/instanceselector/InstanceSelectorTest.java | 402 +++++++++++++++++
.../v2/segmentpruner/SegmentPrunerTest.java | 222 +++++++++
.../v2/segmentselector/SegmentSelectorTest.java | 126 ++++++
.../v2/timeboundary/TimeBoundaryManagerTest.java | 169 +++++++
.../apache/pinot/common/config/RoutingConfig.java | 23 +-
.../apache/pinot/common/metrics/BrokerMeter.java | 3 +
24 files changed, 2668 insertions(+), 39 deletions(-)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/RoutingManager.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/instanceselector/BalancedInstanceSelector.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/instanceselector/BaseInstanceSelector.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/instanceselector/InstanceSelector.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/instanceselector/InstanceSelectorFactory.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/instanceselector/ReplicaGroupInstanceSelector.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/segmentpruner/PartitionSegmentPruner.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/segmentpruner/SegmentPruner.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/segmentpruner/SegmentPrunerFactory.java
copy
pinot-common/src/main/java/org/apache/pinot/pql/parsers/pql2/ast/StarColumnListAstNode.java
=>
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/segmentselector/OfflineSegmentSelector.java
(53%)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/segmentselector/RealtimeSegmentSelector.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/segmentselector/SegmentSelector.java
copy
pinot-tools/src/main/java/org/apache/pinot/tools/config/validator/TableConfigValidator.java
=>
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/segmentselector/SegmentSelectorFactory.java
(66%)
copy
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientException.java
=>
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/timeboundary/TimeBoundaryInfo.java
(67%)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/v2/timeboundary/TimeBoundaryManager.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/v2/instanceselector/InstanceSelectorTest.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/v2/segmentpruner/SegmentPrunerTest.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/v2/segmentselector/SegmentSelectorTest.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/v2/timeboundary/TimeBoundaryManagerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]