Fix checkstyle

Author: Daniil Zulin

topic/src/main/java/tech/ydb/topic/description/Consumer.java

@@ -144,7 +144,9 @@ public Consumer build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         Consumer consumer = (Consumer) o;
         return important == consumer.important &&
                 Objects.equals(name, consumer.name) &&

topic/src/main/java/tech/ydb/topic/description/ConsumerDescription.java

@@ -32,7 +32,9 @@ public List<ConsumerPartitionInfo> getPartitions() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         ConsumerDescription that = (ConsumerDescription) o;
         return Objects.equals(consumer, that.consumer) && Objects.equals(partitions, that.partitions);
     }

topic/src/main/java/tech/ydb/topic/description/ConsumerPartitionInfo.java

@@ -182,7 +182,9 @@ public int getConnectionNodeId() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         ConsumerPartitionInfo that = (ConsumerPartitionInfo) o;
         return partitionId == that.partitionId &&
                 active == that.active &&
@@ -195,6 +197,14 @@ public boolean equals(Object o) {
 
     @Override
     public int hashCode() {
-        return Objects.hash(partitionId, active, childPartitionIds, parentPartitionIds, partitionStats, consumerStats, location);
+        return Objects.hash(
+                partitionId,
+                active,
+                childPartitionIds,
+                parentPartitionIds,
+                partitionStats,
+                consumerStats,
+                location
+        );
     }
 }

topic/src/main/java/tech/ydb/topic/description/MultipleWindowsStat.java

@@ -1,9 +1,9 @@
 package tech.ydb.topic.description;
 
-import tech.ydb.proto.topic.YdbTopic;
-
 import java.util.Objects;
 
+import tech.ydb.proto.topic.YdbTopic;
+
 /**
  * @author Nikolay Perfilov
  */
@@ -38,7 +38,9 @@ public long getPerDay() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         MultipleWindowsStat that = (MultipleWindowsStat) o;
         return perMinute == that.perMinute && perHour == that.perHour && perDay == that.perDay;
     }

topic/src/main/java/tech/ydb/topic/description/PartitionInfo.java

@@ -90,7 +90,9 @@ public PartitionInfo build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         PartitionInfo that = (PartitionInfo) o;
         return partitionId == that.partitionId &&
                 active == that.active &&

topic/src/main/java/tech/ydb/topic/description/PartitionStats.java

@@ -130,7 +130,9 @@ public PartitionStats build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         PartitionStats that = (PartitionStats) o;
         return storeSizeBytes == that.storeSizeBytes &&
                 partitionNodeId == that.partitionNodeId &&
@@ -142,6 +144,13 @@ public boolean equals(Object o) {
 
     @Override
     public int hashCode() {
-        return Objects.hash(partitionOffsets, storeSizeBytes, lastWriteTime, maxWriteTimeLag, bytesWritten, partitionNodeId);
+        return Objects.hash(
+                partitionOffsets,
+                storeSizeBytes,
+                lastWriteTime,
+                maxWriteTimeLag,
+                bytesWritten,
+                partitionNodeId
+        );
     }
 }

topic/src/main/java/tech/ydb/topic/description/SupportedCodecs.java

@@ -51,7 +51,9 @@ public SupportedCodecs build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         SupportedCodecs that = (SupportedCodecs) o;
         return Objects.equals(codecs, that.codecs);
     }

topic/src/main/java/tech/ydb/topic/description/TopicDescription.java

@@ -183,7 +183,9 @@ public TopicDescription build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         TopicDescription that = (TopicDescription) o;
         return retentionStorageMb == that.retentionStorageMb &&
                 partitionWriteSpeedBytesPerSecond == that.partitionWriteSpeedBytesPerSecond &&
@@ -200,6 +202,18 @@ public boolean equals(Object o) {
 
     @Override
     public int hashCode() {
-        return Objects.hash(partitioningSettings, partitions, retentionPeriod, retentionStorageMb, supportedCodecs, partitionWriteSpeedBytesPerSecond, partitionWriteBurstBytes, attributes, consumers, meteringMode, topicStats);
+        return Objects.hash(
+                partitioningSettings,
+                partitions,
+                retentionPeriod,
+                retentionStorageMb,
+                supportedCodecs,
+                partitionWriteSpeedBytesPerSecond,
+                partitionWriteBurstBytes,
+                attributes,
+                consumers,
+                meteringMode,
+                topicStats
+        );
     }
 }

topic/src/main/java/tech/ydb/topic/description/TopicStats.java

@@ -80,7 +80,9 @@ public TopicStats build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         TopicStats that = (TopicStats) o;
         return storeSizeBytes == that.storeSizeBytes &&
                 Objects.equals(minLastWriteTime, that.minLastWriteTime) &&

topic/src/main/java/tech/ydb/topic/impl/TopicClientImpl.java

@@ -111,11 +111,15 @@ public CompletableFuture<Status> createTopic(String path, CreateTopicSettings se
                     .setAutoPartitioningSettings(YdbTopic.AutoPartitioningSettings.newBuilder()
                             .setStrategy(partitioningSettings.getAutoPartitioningStrategy().getProtoReference())));
 
-            AutoPartitioningWriteStrategySettings writeStrategySettings = partitioningSettings.getWriteStrategySettings();
+            AutoPartitioningWriteStrategySettings writeStrategySettings = partitioningSettings
+                    .getWriteStrategySettings();
+
             if (writeStrategySettings != null) {
                 requestBuilder.getPartitioningSettingsBuilder().getAutoPartitioningSettingsBuilder()
                         .setPartitionWriteSpeed(YdbTopic.AutoPartitioningWriteSpeedStrategy.newBuilder()
-                                .setStabilizationWindow(ProtobufUtils.durationToProto(writeStrategySettings.getStabilizationWindow()))
+                                .setStabilizationWindow(ProtobufUtils.durationToProto(
+                                        writeStrategySettings.getStabilizationWindow()
+                                ))
                                 .setDownUtilizationPercent(writeStrategySettings.getDownUtilizationPercent())
                                 .setUpUtilizationPercent(writeStrategySettings.getUpUtilizationPercent())
                         );
@@ -162,9 +166,11 @@ public CompletableFuture<Status> alterTopic(String path, AlterTopicSettings sett
             }
             AutoPartitioningStrategy autoPartitioningStrategy = partitioningSettings.getAutoPartitioningStrategy();
             if (autoPartitioningStrategy != null) {
-                builder.getAlterAutoPartitioningSettingsBuilder().setSetStrategy(autoPartitioningStrategy.getProtoReference());
+                YdbTopic.AutoPartitioningStrategy protoReference = autoPartitioningStrategy.getProtoReference();
+                builder.getAlterAutoPartitioningSettingsBuilder().setSetStrategy(protoReference);
             }
-            AlterAutoPartitioningWriteStrategySettings writeStrategySettings = partitioningSettings.getWriteStrategySettings();
+            AlterAutoPartitioningWriteStrategySettings writeStrategySettings = partitioningSettings
+                    .getWriteStrategySettings();
             if (writeStrategySettings != null) {
                 Duration stabilizationWindow = writeStrategySettings.getStabilizationWindow();
                 if (stabilizationWindow != null) {
@@ -310,14 +316,20 @@ private TopicDescription mapDescribeTopic(YdbTopic.DescribeTopicResult result) {
                 .setMeteringMode(fromProto(result.getMeteringMode()));
 
         YdbTopic.PartitioningSettings partitioningSettings = result.getPartitioningSettings();
+        YdbTopic.AutoPartitioningSettings autoPartitioningSettings = partitioningSettings.getAutoPartitioningSettings();
+        YdbTopic.AutoPartitioningStrategy autoPartitioningStrategy = autoPartitioningSettings.getStrategy();
+
         PartitioningSettings.Builder partitioningDescription = PartitioningSettings.newBuilder()
                 .setMinActivePartitions(partitioningSettings.getMinActivePartitions())
                 .setPartitionCountLimit(partitioningSettings.getPartitionCountLimit())
-                .setAutoPartitioningStrategy(AutoPartitioningStrategy.fromProto(partitioningSettings.getAutoPartitioningSettings().getStrategy()));
+                .setAutoPartitioningStrategy(AutoPartitioningStrategy.fromProto(autoPartitioningStrategy));
 
-        YdbTopic.AutoPartitioningWriteSpeedStrategy partitionWriteSpeed = partitioningSettings.getAutoPartitioningSettings().getPartitionWriteSpeed();
+        YdbTopic.AutoPartitioningWriteSpeedStrategy partitionWriteSpeed = autoPartitioningSettings
+                .getPartitionWriteSpeed();
         partitioningDescription.setWriteStrategySettings(AutoPartitioningWriteStrategySettings.newBuilder()
-                .setStabilizationWindow(ProtobufUtils.protoToDuration(partitionWriteSpeed.getStabilizationWindow()))
+                .setStabilizationWindow(ProtobufUtils.protoToDuration(
+                        partitionWriteSpeed.getStabilizationWindow()
+                ))
                 .setUpUtilizationPercent(partitionWriteSpeed.getUpUtilizationPercent())
                 .setDownUtilizationPercent(partitionWriteSpeed.getDownUtilizationPercent())
                 .build());

topic/src/main/java/tech/ydb/topic/read/impl/OffsetsRangeImpl.java

@@ -1,9 +1,9 @@
 package tech.ydb.topic.read.impl;
 
-import tech.ydb.topic.description.OffsetsRange;
-
 import java.util.Objects;
 
+import tech.ydb.topic.description.OffsetsRange;
+
 /**
  * @author Nikolay Perfilov
  */
@@ -41,7 +41,9 @@ public void setEnd(long end) {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         OffsetsRangeImpl that = (OffsetsRangeImpl) o;
         return start == that.start && end == that.end;
     }

topic/src/main/java/tech/ydb/topic/settings/AlterAutoPartitioningWriteStrategySettings.java

@@ -1,9 +1,9 @@
 package tech.ydb.topic.settings;
 
-import javax.annotation.Nullable;
-
 import java.time.Duration;
 
+import javax.annotation.Nullable;
+
 public class AlterAutoPartitioningWriteStrategySettings {
     @Nullable
     private final Duration stabilizationWindow;

topic/src/main/java/tech/ydb/topic/settings/AutoPartitioningStrategy.java

@@ -1,9 +1,9 @@
 package tech.ydb.topic.settings;
 
-import tech.ydb.proto.topic.YdbTopic;
-
 import javax.annotation.Nullable;
 
+import tech.ydb.proto.topic.YdbTopic;
+
 public enum AutoPartitioningStrategy {
     /**
      * The auto partitioning is disabled.

topic/src/main/java/tech/ydb/topic/settings/AutoPartitioningWriteStrategySettings.java

@@ -73,7 +73,9 @@ public AutoPartitioningWriteStrategySettings build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         AutoPartitioningWriteStrategySettings that = (AutoPartitioningWriteStrategySettings) o;
         return upUtilizationPercent == that.upUtilizationPercent &&
                 downUtilizationPercent == that.downUtilizationPercent &&

topic/src/main/java/tech/ydb/topic/settings/PartitioningSettings.java

@@ -112,7 +112,9 @@ public PartitioningSettings build() {
 
     @Override
     public boolean equals(Object o) {
-        if (o == null || getClass() != o.getClass()) return false;
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
         PartitioningSettings that = (PartitioningSettings) o;
         return minActivePartitions == that.minActivePartitions &&
                 partitionCountLimit == that.partitionCountLimit &&