spotless

Author: ahmedabu98

sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/TableCache.java

@@ -31,7 +31,6 @@
 import org.apache.iceberg.Table;
 import org.apache.iceberg.catalog.Catalog;
 import org.apache.iceberg.catalog.TableIdentifier;
-import org.jetbrains.annotations.NotNull;
 
 /** Utility to fetch and cache Iceberg {@link Table}s. */
 class TableCache {
@@ -43,14 +42,13 @@ class TableCache {
           .build(
               new CacheLoader<String, Table>() {
                 @Override
-                public @NotNull Table load(@NotNull String identifier) {
+                public Table load(String identifier) {
                   return checkStateNotNull(CATALOG_CACHE.get(identifier))
                       .loadTable(TableIdentifier.parse(identifier));
                 }
 
                 @Override
-                public @NotNull ListenableFuture<Table> reload(
-                    @NotNull String unusedIdentifier, @NotNull Table table) {
+                public ListenableFuture<Table> reload(String unusedIdentifier, Table table) {
                   table.refresh();
                   return Futures.immediateFuture(table);
                 }

sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/WatchForSnapshots.java

@@ -19,7 +19,6 @@
 
 import static org.apache.beam.sdk.transforms.Watch.Growth.PollResult;
 
-import com.google.common.collect.ImmutableList;
 import java.util.List;
 import java.util.stream.Collectors;
 import org.apache.beam.sdk.coders.ListCoder;
@@ -40,6 +39,7 @@
 import org.apache.beam.sdk.values.TimestampedValue;
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.MoreObjects;
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Objects;
+import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableList;
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.Iterables;
 import org.apache.iceberg.Snapshot;
 import org.apache.iceberg.Table;