Skip to content

Commit

Permalink
Spotless changes
Browse files Browse the repository at this point in the history
Signed-off-by: Shivansh Arora <shivansh.arora@protonmail.com>
  • Loading branch information
shiv0408 committed Sep 29, 2023
1 parent 7aa8135 commit ba1e746
Showing 1 changed file with 9 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,6 @@
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.TreeMap;
import java.util.stream.Collectors;
import java.util.stream.Stream;

Expand Down Expand Up @@ -143,14 +142,14 @@ private static List<NodeShardState> adaptToNodeShardStates(FetchResult<NodeGatew
List<NodeShardState> nodeShardStates = new ArrayList();
shardsState.getData().forEach((node, nodeGatewayStartedShard) -> {
nodeShardStates.add(
new NodeShardState(
node,
nodeGatewayStartedShard.allocationId(),
nodeGatewayStartedShard.primary(),
nodeGatewayStartedShard.replicationCheckpoint(),
nodeGatewayStartedShard.storeException()
)
);
new NodeShardState(
node,
nodeGatewayStartedShard.allocationId(),
nodeGatewayStartedShard.primary(),
nodeGatewayStartedShard.replicationCheckpoint(),
nodeGatewayStartedShard.storeException()
)
);
});
return nodeShardStates;
}
Expand Down Expand Up @@ -516,11 +515,7 @@ protected static class NodesToAllocate {
final List<DecidedNode> throttleNodeShards;
final List<DecidedNode> noNodeShards;

NodesToAllocate(
List<DecidedNode> yesNodeShards,
List<DecidedNode> throttleNodeShards,
List<DecidedNode> noNodeShards
) {
NodesToAllocate(List<DecidedNode> yesNodeShards, List<DecidedNode> throttleNodeShards, List<DecidedNode> noNodeShards) {
this.yesNodeShards = yesNodeShards;
this.throttleNodeShards = throttleNodeShards;
this.noNodeShards = noNodeShards;
Expand Down

0 comments on commit ba1e746

Please sign in to comment.