You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by sn...@apache.org on 2022/09/30 03:41:32 UTC

[pinot] branch master updated (0171f99ee1 -> 19cec5b195)

This is an automated email from the ASF dual-hosted git repository.

snlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


    from 0171f99ee1 [multistage] restructure runner test (#9489)
     add 19cec5b195 Introduce segment assignment strategy interface #9047 (#9309)

No new revisions were added by this update.

Summary of changes:
 .../common/utils/config/TableConfigUtils.java      |  19 ++-
 .../common/utils/config/TableConfigSerDeTest.java  |   2 +
 .../assignment/segment/BaseSegmentAssignment.java  | 125 +++--------------
 .../segment/OfflineSegmentAssignment.java          |  87 ++++--------
 .../segment/RealtimeSegmentAssignment.java         |  93 +++++++------
 .../core/assignment/segment/SegmentAssignment.java |   5 -
 .../segment/SegmentAssignmentFactory.java          |   3 +-
 .../assignment/segment/SegmentAssignmentUtils.java | 113 +++++++++++++--
 .../AllServersSegmentAssignmentStrategy.java}      |  21 +--
 .../BalancedNumSegmentAssignmentStrategy.java      |  86 ++++++++++++
 .../ReplicaGroupSegmentAssignmentStrategy.java     | 152 +++++++++++++++++++++
 .../SegmentAssignmentStrategy.java}                |  40 +++---
 .../strategy/SegmentAssignmentStrategyFactory.java | 105 ++++++++++++++
 .../AllServersSegmentAssignmentStrategyTest.java}  |  37 ++++-
 .../BalancedNumSegmentAssignmentStrategyTest.java} |  27 ++--
 ...ReplicaGroupSegmentAssignmentStrategyTest.java} | 107 ++++++++-------
 .../SegmentAssignmentStrategyFactoryTest.java      | 146 ++++++++++++++++++++
 .../apache/pinot/spi/config/table/TableConfig.java |  18 ++-
 ...intConfig.java => SegmentAssignmentConfig.java} |  17 +--
 .../apache/pinot/spi/utils/CommonConstants.java    |   5 +-
 .../spi/utils/builder/TableConfigBuilder.java      |  12 +-
 21 files changed, 873 insertions(+), 347 deletions(-)
 rename pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/{OfflineDimTableSegmentAssignment.java => strategy/AllServersSegmentAssignmentStrategy.java} (81%)
 create mode 100644 pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/BalancedNumSegmentAssignmentStrategy.java
 create mode 100644 pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/ReplicaGroupSegmentAssignmentStrategy.java
 copy pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/{SegmentAssignment.java => strategy/SegmentAssignmentStrategy.java} (54%)
 create mode 100644 pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/SegmentAssignmentStrategyFactory.java
 rename pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/{OfflineDimTableSegmentAssignmentTest.java => strategy/AllServersSegmentAssignmentStrategyTest.java} (73%)
 rename pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/{OfflineNonReplicaGroupSegmentAssignmentTest.java => strategy/BalancedNumSegmentAssignmentStrategyTest.java} (85%)
 rename pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/{OfflineReplicaGroupSegmentAssignmentTest.java => strategy/ReplicaGroupSegmentAssignmentStrategyTest.java} (85%)
 create mode 100644 pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/SegmentAssignmentStrategyFactoryTest.java
 copy pinot-spi/src/main/java/org/apache/pinot/spi/config/table/assignment/{InstanceConstraintConfig.java => SegmentAssignmentConfig.java} (66%)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org