jolshan commented on code in PR #13247:
URL: https://github.com/apache/kafka/pull/13247#discussion_r1366159733
##########
tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsIntegrationTest.java:
##########
@@ -857,68 +864,13 @@ public void close() {
}
}
- private ReassignPartitionsCommand.VerifyAssignmentResult
asScala(VerifyAssignmentResult res) {
- Map<TopicPartition,
ReassignPartitionsCommand.PartitionReassignmentState> partStates = new
HashMap<>();
- res.partStates.forEach((tp, state) -> partStates.put(tp,
asScala(state)));
-
- Map<TopicPartitionReplica, ReassignPartitionsCommand.LogDirMoveState>
moveStates = new HashMap<>();
- res.moveStates.forEach((tpr, state) -> moveStates.put(tpr,
asScala(state)));
-
- return new
ReassignPartitionsCommand.VerifyAssignmentResult(asScala(partStates),
res.partsOngoing, asScala(moveStates), res.movesOngoing);
- }
-
- @SuppressWarnings({"unchecked"})
- private ReassignPartitionsCommand.PartitionReassignmentState
asScala(PartitionReassignmentState state) {
- return new ReassignPartitionsCommand.PartitionReassignmentState(
- seq((List) state.currentReplicas),
- seq((List) state.targetReplicas),
- state.done
- );
- }
-
- private ReassignPartitionsCommand.LogDirMoveState asScala(LogDirMoveState
state) {
- if (state instanceof ActiveMoveState) {
- ActiveMoveState s = (ActiveMoveState) state;
- return new
ReassignPartitionsCommand.ActiveMoveState(s.currentLogDir, s.targetLogDir,
s.futureLogDir);
- } else if (state instanceof CancelledMoveState) {
- CancelledMoveState s = (CancelledMoveState) state;
- return new
ReassignPartitionsCommand.CancelledMoveState(s.currentLogDir, s.targetLogDir);
- } else if (state instanceof CompletedMoveState) {
- CompletedMoveState s = (CompletedMoveState) state;
- return new
ReassignPartitionsCommand.CompletedMoveState(s.targetLogDir);
- } else if (state instanceof MissingLogDirMoveState) {
- MissingLogDirMoveState s = (MissingLogDirMoveState) state;
- return new
ReassignPartitionsCommand.MissingLogDirMoveState(s.targetLogDir);
- } else if (state instanceof MissingReplicaMoveState) {
- MissingReplicaMoveState s = (MissingReplicaMoveState) state;
- return new
ReassignPartitionsCommand.MissingReplicaMoveState(s.targetLogDir);
- }
-
- throw new IllegalArgumentException("Unknown state " + state);
- }
-
- @SuppressWarnings("unchecked")
- static <T> scala.collection.immutable.Set<T> set(final T... set) {
- return mutableSet(set).toSet();
- }
-
@SuppressWarnings({"deprecation", "unchecked"})
private static <T> scala.collection.mutable.Set<T> mutableSet(final
T...set) {
- return JavaConverters.asScalaSet(new HashSet<>(Arrays.asList(set)));
- }
-
- @SuppressWarnings({"unchecked"})
- private static <T> Seq<T> seq(T... seq) {
- return seq(Arrays.asList(seq));
+ return JavaConverters.asScalaSet(new HashSet<>(asList(set)));
Review Comment:
Got it -- so we just have these two methods with deprecated methods? And we
need to do more to get these removed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
