Package org.apache.datafusion

package org.apache.datafusion

Related Packages

Package	Description
org.apache.datafusion.internal
org.apache.datafusion.proto

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).
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.
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.
FileCompressionType	Compression of a file-format source.
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).
NativeLibraryLoader
NdJsonReadOptions	Configuration knobs for newline-delimited JSON sources passed to SessionContext.registerJson(String, String, NdJsonReadOptions) and SessionContext.readJson(String, NdJsonReadOptions).
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).
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.
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.
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.