All Classes and Interfaces

Class	Description
ArrowReadOptions	Configuration knobs for Arrow IPC sources passed to SessionContext.registerArrow(String, String, ArrowReadOptions) and SessionContext.readArrow(String, ArrowReadOptions).
AvroReadOptions	Configuration knobs for Avro sources passed to SessionContext.registerAvro(String, String, AvroReadOptions) and SessionContext.readAvro(String, AvroReadOptions).
CacheManagerOptions	Configuration for DataFusion's built-in CacheManager.
CacheManagerOptions.Builder	Builder for CacheManagerOptions.
ColumnarValue	The value of a scalar UDF argument or result: either a per-row ColumnarValue.Array of length rowCount, or a ColumnarValue.Scalar (length-1 vector) that the framework broadcasts.
ColumnarValue.Array	Per-row Arrow vector of length equal to the batch row count.
ColumnarValue.Scalar	Length-1 Arrow vector representing a single value broadcast across all rows.
ConfigurationException	Invalid or unrecognised DataFusion configuration option.
CsvReadOptions	Configuration knobs for CSV sources passed to SessionContext.registerCsv(String, String, CsvReadOptions) and SessionContext.readCsv(String, CsvReadOptions).
CsvWriteOptions	Configuration knobs for writing CSV, passed to DataFrame.writeCsv(String, CsvWriteOptions).
DataFrame	A lazy representation of a query plan, mirroring the Rust DataFusion DataFrame.
DataFusionException	Base unchecked exception for every error surfaced from the native DataFusion side.
ExecutionException	Runtime execution failure: a UDF threw, a join task panicked, an external (non-DataFusion) error propagated up, or an FFI-level failure surfaced.
FileCompressionType	Compression of a file-format source.
IoException	IO-shaped failure: a local filesystem read failed, an object store request failed, or a parquet / arrow / avro decoder reported a malformed file.
JniBridge	Internal trampoline invoked from native code on every UDF call.
JoinType	Join algorithm requested for DataFrame.join(org.apache.datafusion.DataFrame, org.apache.datafusion.JoinType, java.lang.String[], java.lang.String[]) / DataFrame.joinOn(org.apache.datafusion.DataFrame, org.apache.datafusion.JoinType, java.lang.String...).
JsonWriteOptions	Configuration knobs for writing JSON, passed to DataFrame.writeJson(String, JsonWriteOptions).
MemoryUsage	Snapshot of session-wide memory usage from SessionContext.memoryUsage().
NativeLibraryLoader	Loads the datafusion_jni native library on demand.
NdJsonReadOptions	Configuration knobs for newline-delimited JSON sources passed to SessionContext.registerJson(String, String, NdJsonReadOptions) and SessionContext.readJson(String, NdJsonReadOptions).
NotImplementedException	The requested feature is recognised by DataFusion but not implemented yet.
ObjectStoreOptions	Description of an object_store::ObjectStore backend to register on a SessionContext's RuntimeEnv.
ObjectStoreOptions.Gcs	Google Cloud Storage.
ObjectStoreOptions.Gcs.Builder
ObjectStoreOptions.Http	Listing-capable HTTP / WebDAV store.
ObjectStoreOptions.Http.Builder
ObjectStoreOptions.S3	Amazon S3 (and any S3-compatible endpoint such as MinIO, Cloudflare R2, Wasabi).
ObjectStoreOptions.S3.Builder
ParquetReadOptions	Configuration knobs for parquet sources passed to SessionContext.registerParquet(String, String, ParquetReadOptions) and SessionContext.readParquet(String, ParquetReadOptions).
ParquetWriteOptions	Configuration knobs for writing parquet, passed to DataFrame.writeParquet(String, ParquetWriteOptions).
PlanException	SQL parsing, logical planning, or schema-resolution failure.
ResourcesExhaustedException	The DataFusion runtime exhausted a configured resource budget — typically the memory pool, but applies to any guard upstream surfaces as DataFusionError::ResourcesExhausted.
RuntimeStats	Snapshot of the underlying Tokio runtime from SessionContext.runtimeStats().
ScalarFunction	A Java-implemented scalar SQL function.
ScalarFunctionArgs	Bundle of inputs passed to ScalarFunction.evaluate(org.apache.arrow.memory.BufferAllocator, org.apache.datafusion.ScalarFunctionArgs): the per-arg ColumnarValues (in declared order) and the batch row count DataFusion is driving.
ScalarUdf	A scalar UDF registration handle: pairs a ScalarFunction implementation with the metadata DataFusion needs to dispatch SQL calls to it.
SchemaConverter	Convert between Arrow Java Schema and the datafusion_common.Schema protobuf shape used by DataFusion plan messages such as ListingTableScanNode.schema.
SessionContext	A DataFusion session context.
SessionContextBuilder	Builder for a configured SessionContext.
SimpleTableProvider	A TableProvider that pairs a fixed Schema with a function that opens a fresh ArrowReader for each scan.
SortExpr	A single sort key passed to DataFrame.sort(SortExpr...), mirroring DataFusion's expr::Sort{ expr, asc, nulls_first }.
TableProvider	A Java-implemented table that can be registered with a SessionContext via SessionContext.registerTable(String, TableProvider).
UnnestOptions	Configuration knobs for DataFrame.unnestColumns(UnnestOptions, String...), mirroring DataFusion's UnnestOptions.
Volatility	Volatility classification for a UDF.