Module org.elasticsearch.nativeaccess
Package org.elasticsearch.nativeaccess.lib

Interface ParquetRsLibrary

All Known Implementing Classes:
JdkParquetRsLibrary
public interface ParquetRsLibrary
Low-level FFI interface to the Rust es_parquet_rs shared library for Parquet operations.

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    getSchemaFFI(String path, String configJson, long schemaAddr)
    Exports the Parquet file's Arrow schema via the Arrow C Data Interface.
    long[]
    getStatistics(String path, String configJson)
    Reads Parquet file statistics.
    String
    lastError()
    Returns the last error message from the native library, or null if none.

  • Method Details

    • lastError

      String lastError()
      Returns the last error message from the native library, or null if none.

    • getStatistics

      long[] getStatistics(String path, String configJson)
      Reads Parquet file statistics.
      Parameters:
      path - the path to the Parquet file
      configJson - optional JSON storage configuration, or null
      Returns:
      a two-element array: [totalRows, totalBytes], or null on error

    • getSchemaFFI

      int getSchemaFFI(String path, String configJson, long schemaAddr)
      Exports the Parquet file's Arrow schema via the Arrow C Data Interface. Writes an FFI_ArrowSchema to the given memory address.
      Parameters:
      path - the path to the Parquet file
      configJson - optional JSON storage configuration, or null
      schemaAddr - memory address of a pre-allocated ArrowSchema FFI struct
      Returns:
      0 on success, -1 on error (check lastError())