format

Author: andygrove

common/src/main/java/org/apache/arrow/c/AbstractCometSchemaImporter.java

@@ -19,12 +19,12 @@
 
 package org.apache.arrow.c;
 
-import org.apache.comet.IcebergApi;
-
 import org.apache.arrow.memory.BufferAllocator;
 import org.apache.arrow.vector.FieldVector;
 import org.apache.arrow.vector.types.pojo.Field;
 
+import org.apache.comet.IcebergApi;
+
 /** This is a simple wrapper around SchemaImporter to make it accessible from Java Arrow. */
 public abstract class AbstractCometSchemaImporter {
   private final BufferAllocator allocator;

common/src/main/java/org/apache/comet/IcebergApi.java

@@ -29,9 +29,9 @@
  * Indicates that the annotated element is part of the public API used by Apache Iceberg.
  *
  * <p>This annotation marks classes, methods, constructors, and fields that form the contract
- * between Comet and Iceberg. Changes to these APIs may break Iceberg's Comet integration,
- * so contributors should exercise caution and consider backward compatibility when modifying
- * annotated elements.
+ * between Comet and Iceberg. Changes to these APIs may break Iceberg's Comet integration, so
+ * contributors should exercise caution and consider backward compatibility when modifying annotated
+ * elements.
  *
  * <p>The Iceberg integration uses Comet's native Parquet reader for accelerated vectorized reads.
  * See the contributor guide documentation for details on how Iceberg uses these APIs.

common/src/main/java/org/apache/comet/parquet/AbstractColumnReader.java

@@ -19,8 +19,6 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -30,6 +28,7 @@
 import org.apache.spark.sql.types.TimestampNTZType$;
 
 import org.apache.comet.CometConf;
+import org.apache.comet.IcebergApi;
 import org.apache.comet.vector.CometVector;
 
 /** Base class for Comet Parquet column reader implementations. */
@@ -64,8 +63,7 @@ public abstract class AbstractColumnReader implements AutoCloseable {
   protected int batchSize;
 
   /** A pointer to the native implementation of ColumnReader. */
-  @IcebergApi
-  protected long nativeHandle;
+  @IcebergApi protected long nativeHandle;
 
   AbstractColumnReader(
       DataType type,

common/src/main/java/org/apache/comet/parquet/BatchReader.java

@@ -19,8 +19,6 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import java.io.Closeable;
 import java.io.IOException;
 import java.net.URI;
@@ -67,6 +65,7 @@
 
 import org.apache.comet.CometConf;
 import org.apache.comet.CometSchemaImporter;
+import org.apache.comet.IcebergApi;
 import org.apache.comet.shims.ShimBatchReader;
 import org.apache.comet.shims.ShimFileFormat;
 import org.apache.comet.vector.CometVector;

common/src/main/java/org/apache/comet/parquet/ColumnReader.java

@@ -19,8 +19,6 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import java.io.IOException;
 import java.nio.ByteBuffer;
 
@@ -46,6 +44,7 @@
 
 import org.apache.comet.CometConf;
 import org.apache.comet.CometSchemaImporter;
+import org.apache.comet.IcebergApi;
 import org.apache.comet.vector.CometDecodedVector;
 import org.apache.comet.vector.CometDictionary;
 import org.apache.comet.vector.CometDictionaryVector;

common/src/main/java/org/apache/comet/parquet/ConstantColumnReader.java

@@ -19,8 +19,6 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import java.math.BigInteger;
 
 import org.apache.parquet.column.ColumnDescriptor;
@@ -29,6 +27,8 @@
 import org.apache.spark.sql.types.*;
 import org.apache.spark.unsafe.types.UTF8String;
 
+import org.apache.comet.IcebergApi;
+
 /**
  * A column reader that always return constant vectors. Used for reading partition columns, for
  * instance.

common/src/main/java/org/apache/comet/parquet/FileReader.java

@@ -19,8 +19,6 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import java.io.Closeable;
 import java.io.IOException;
 import java.io.InputStream;
@@ -92,6 +90,8 @@
 import org.apache.parquet.schema.PrimitiveType;
 import org.apache.spark.sql.execution.metric.SQLMetric;
 
+import org.apache.comet.IcebergApi;
+
 import static org.apache.parquet.hadoop.ParquetFileWriter.EFMAGIC;
 import static org.apache.parquet.hadoop.ParquetFileWriter.MAGIC;
 

common/src/main/java/org/apache/comet/parquet/MetadataColumnReader.java

@@ -19,8 +19,6 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import org.apache.arrow.c.ArrowArray;
 import org.apache.arrow.c.ArrowSchema;
 import org.apache.arrow.c.Data;
@@ -30,6 +28,7 @@
 import org.apache.parquet.column.ColumnDescriptor;
 import org.apache.spark.sql.types.DataType;
 
+import org.apache.comet.IcebergApi;
 import org.apache.comet.vector.CometPlainVector;
 import org.apache.comet.vector.CometVector;
 

common/src/main/java/org/apache/comet/parquet/Native.java

@@ -19,11 +19,10 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import java.nio.ByteBuffer;
 import java.util.Map;
 
+import org.apache.comet.IcebergApi;
 import org.apache.comet.NativeBase;
 
 public final class Native extends NativeBase {

common/src/main/java/org/apache/comet/parquet/ParquetColumnSpec.java

@@ -19,10 +19,10 @@
 
 package org.apache.comet.parquet;
 
-import org.apache.comet.IcebergApi;
-
 import java.util.Map;
 
+import org.apache.comet.IcebergApi;
+
 /**
  * Parquet ColumnSpec encapsulates the information withing a Parquet ColumnDescriptor. Utility
  * methods can convert from and to a ColumnDescriptor The only purpose of this class is to allow