remove more unused methods

Author: andygrove

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

@@ -25,62 +25,11 @@
 
 public final class Native extends NativeBase {
 
-  ///////////// Arrow Native Parquet Reader APIs
-
   /**
    * Verify that object store options are valid. An exception will be thrown if the provided options
    * are not valid.
    */
   public static native void validateObjectStoreConfig(
       String filePath, Map<String, String> objectStoreOptions);
 
-  /**
-   * Initialize a record batch reader for a PartitionedFile
-   *
-   * @param filePath
-   * @param starts
-   * @param lengths
-   * @return a handle to the record batch reader, used in subsequent calls.
-   */
-  public static native long initRecordBatchReader(
-      String filePath,
-      long fileSize,
-      long[] starts,
-      long[] lengths,
-      byte[] filter,
-      byte[] requiredSchema,
-      byte[] dataSchema,
-      String sessionTimezone,
-      int batchSize,
-      boolean caseSensitive,
-      boolean returnNullStructIfAllFieldsMissing,
-      Map<String, String> objectStoreOptions,
-      CometFileKeyUnwrapper keyUnwrapper,
-      Object metricsNode);
-
-  /**
-   * Read the next batch of data into memory on native side
-   *
-   * @param handle
-   * @return the number of rows read
-   */
-  public static native int readNextRecordBatch(long handle);
-
-  /**
-   * Load the column corresponding to columnNum in the currently loaded record batch into JVM
-   *
-   * @param handle
-   * @param columnNum
-   * @param arrayAddr
-   * @param schemaAddr
-   */
-  public static native void currentColumnBatch(
-      long handle, int columnNum, long arrayAddr, long schemaAddr);
-
-  /**
-   * Close the record batch reader. Free the resources
-   *
-   * @param handle
-   */
-  public static native void closeRecordBatchReader(long handle);
 }

spark/src/test/scala/org/apache/comet/CometNativeSuite.scala

@@ -54,14 +54,6 @@ class CometNativeSuite extends CometTestBase {
     assert(exception.getMessage contains "java.lang.NullPointerException")
   }
 
-  test("handling NPE when closing null handle of parquet reader") {
-    assert(NativeBase.isLoaded)
-    val exception1 = intercept[NullPointerException] {
-      parquet.Native.closeRecordBatchReader(0)
-    }
-    assert(exception1.getMessage contains "null batch context handle")
-  }
-
   test("Comet native should use spark local dir as temp dir") {
     withParquetTable((0 until 100000).map(i => (i, i + 1)), "table") {
       val dirs = SparkEnv.get.blockManager.getLocalDiskDirs