Index

A B C D E F G H I J L M N O P Q R S T U V W X Z
All Classes and Interfaces|All Packages

A

accessKeyId(String) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

allowHttp(boolean) - Method in class org.apache.datafusion.ObjectStoreOptions.Http.Builder

allowHttp(boolean) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

Allow plain http:// endpoints (e.g. local MinIO).

applicationCredentials(String) - Method in class org.apache.datafusion.ObjectStoreOptions.Gcs.Builder

Filesystem path to the application-default-credentials JSON.

argFields() - Method in interface org.apache.datafusion.ScalarFunction

Declared argument fields, in positional order.

argFields() - Method in class org.apache.datafusion.ScalarUdf

Declared argument fields; cached from ScalarFunction.argFields().

args() - Method in record class org.apache.datafusion.ScalarFunctionArgs

Returns the value of the args record component.

array(FieldVector) - Static method in interface org.apache.datafusion.ColumnarValue

Wrap an arbitrary-length vector as an ColumnarValue.Array.

Array(FieldVector) - Constructor for record class org.apache.datafusion.ColumnarValue.Array

Creates an instance of a Array record class.

ArrowReadOptions - Class in org.apache.datafusion

Configuration knobs for Arrow IPC sources passed to SessionContext.registerArrow(String, String, ArrowReadOptions) and SessionContext.readArrow(String, ArrowReadOptions).

ArrowReadOptions() - Constructor for class org.apache.datafusion.ArrowReadOptions

AvroReadOptions - Class in org.apache.datafusion

Configuration knobs for Avro sources passed to SessionContext.registerAvro(String, String, AvroReadOptions) and SessionContext.readAvro(String, AvroReadOptions).

AvroReadOptions() - Constructor for class org.apache.datafusion.AvroReadOptions

B

batchSize(int) - Method in class org.apache.datafusion.SessionContextBuilder

bucket(String) - Method in class org.apache.datafusion.ObjectStoreOptions.Gcs.Builder

Bucket name.

bucket(String) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

Bucket name.

build() - Method in class org.apache.datafusion.ObjectStoreOptions.Gcs.Builder

build() - Method in class org.apache.datafusion.ObjectStoreOptions.Http.Builder

build() - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

build() - Method in class org.apache.datafusion.SessionContextBuilder

Construct a SessionContext with the configured options.

builder() - Static method in class org.apache.datafusion.SessionContext

Start configuring a SessionContext.

BZIP2 - Enum constant in enum class org.apache.datafusion.FileCompressionType

C

cache() - Method in class org.apache.datafusion.DataFrame

Materialise this DataFrame into an in-memory table and return a new DataFrame that scans it.

close() - Method in class org.apache.datafusion.DataFrame

close() - Method in class org.apache.datafusion.SessionContext

code() - Method in enum class org.apache.datafusion.JoinType

Stable byte code for FFI.

code() - Method in enum class org.apache.datafusion.Volatility

Stable byte code for FFI.

collect(BufferAllocator) - Method in class org.apache.datafusion.DataFrame

Execute the plan and return its record batches as an ArrowReader.

collectStatistics(boolean) - Method in class org.apache.datafusion.SessionContextBuilder

ColumnarValue - Interface in org.apache.datafusion

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 - Record Class in org.apache.datafusion

Per-row Arrow vector of length equal to the batch row count.

ColumnarValue.Scalar - Record Class in org.apache.datafusion

Length-1 Arrow vector representing a single value broadcast across all rows.

comment(byte) - Method in class org.apache.datafusion.CsvReadOptions

compression(String) - Method in class org.apache.datafusion.ParquetWriteOptions

Compression codec spec, passed verbatim to DataFusion.

count() - Method in class org.apache.datafusion.DataFrame

Execute the plan and return the number of rows.

CsvReadOptions - Class in org.apache.datafusion

Configuration knobs for CSV sources passed to SessionContext.registerCsv(String, String, CsvReadOptions) and SessionContext.readCsv(String, CsvReadOptions).

CsvReadOptions() - Constructor for class org.apache.datafusion.CsvReadOptions

CsvWriteOptions - Class in org.apache.datafusion

Configuration knobs for writing CSV, passed to DataFrame.writeCsv(String, CsvWriteOptions).

CsvWriteOptions() - Constructor for class org.apache.datafusion.CsvWriteOptions

D

DataFrame - Class in org.apache.datafusion

A lazy representation of a query plan, mirroring the Rust DataFusion DataFrame.

dataType() - Method in interface org.apache.datafusion.ColumnarValue

Convenience: the vector's declared Arrow type.

delimiter(byte) - Method in class org.apache.datafusion.CsvReadOptions

delimiter(byte) - Method in class org.apache.datafusion.CsvWriteOptions

Field delimiter byte.

describe() - Method in class org.apache.datafusion.DataFrame

Compute summary statistics (count, null_count, mean, std, min, max, median) over this DataFrame's columns and return them as a new DataFrame.

distinct() - Method in class org.apache.datafusion.DataFrame

Deduplicate rows across all columns.

dropColumns(String...) - Method in class org.apache.datafusion.DataFrame

Drop the named columns.

E

endpoint(String) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

Override the endpoint URL (e.g.

equals(Object) - Method in record class org.apache.datafusion.ColumnarValue.Array

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.apache.datafusion.ColumnarValue.Scalar

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.apache.datafusion.ScalarFunctionArgs

Indicates whether some other object is "equal to" this one.

escape(byte) - Method in class org.apache.datafusion.CsvReadOptions

escape(byte) - Method in class org.apache.datafusion.CsvWriteOptions

Escape character byte.

evaluate(BufferAllocator, ScalarFunctionArgs) - Method in interface org.apache.datafusion.ScalarFunction

Compute the function result for one input batch.

executeStream(BufferAllocator) - Method in class org.apache.datafusion.DataFrame

Execute the plan and return its record batches as a streaming ArrowReader.

explain(boolean, boolean) - Method in class org.apache.datafusion.DataFrame

Return a new DataFrame whose rows describe the plan that would execute this DataFrame.

F

fileCompressionType(FileCompressionType) - Method in class org.apache.datafusion.CsvReadOptions

fileCompressionType(FileCompressionType) - Method in class org.apache.datafusion.CsvWriteOptions

Output compression codec.

fileCompressionType(FileCompressionType) - Method in class org.apache.datafusion.JsonWriteOptions

Output compression codec.

fileCompressionType(FileCompressionType) - Method in class org.apache.datafusion.NdJsonReadOptions

FileCompressionType - Enum Class in org.apache.datafusion

Compression of a file-format source.

fileExtension(String) - Method in class org.apache.datafusion.ArrowReadOptions

fileExtension(String) - Method in class org.apache.datafusion.AvroReadOptions

fileExtension(String) - Method in class org.apache.datafusion.CsvReadOptions

fileExtension(String) - Method in class org.apache.datafusion.NdJsonReadOptions

fileExtension(String) - Method in class org.apache.datafusion.ParquetReadOptions

filter(String) - Method in class org.apache.datafusion.DataFrame

Apply a SQL predicate to produce a filtered DataFrame.

fromImpl(ScalarFunction) - Static method in class org.apache.datafusion.ScalarUdf

Equivalent to new ScalarUdf(impl); mirrors Rust's ScalarUDF::new_from_impl.

fromProto(byte[]) - Method in class org.apache.datafusion.SessionContext

Decode a DataFusion-Proto LogicalPlanNode and return a lazy DataFrame.

fromProto(DatafusionCommon.Schema) - Static method in class org.apache.datafusion.proto.SchemaConverter

FULL - Enum constant in enum class org.apache.datafusion.JoinType

G

gcs() - Static method in class org.apache.datafusion.ObjectStoreOptions

Begin building a ObjectStoreOptions.Gcs (Google Cloud Storage) registration.

getOption(String) - Method in class org.apache.datafusion.SessionContext

Read the current value of a datafusion.* config key.

GZIP - Enum constant in enum class org.apache.datafusion.FileCompressionType

H

hashCode() - Method in record class org.apache.datafusion.ColumnarValue.Array

Returns a hash code value for this object.

hashCode() - Method in record class org.apache.datafusion.ColumnarValue.Scalar

Returns a hash code value for this object.

hashCode() - Method in record class org.apache.datafusion.ScalarFunctionArgs

Returns a hash code value for this object.

hasHeader(boolean) - Method in class org.apache.datafusion.CsvReadOptions

hasHeader(boolean) - Method in class org.apache.datafusion.CsvWriteOptions

Whether to write a header row.

http(String) - Static method in class org.apache.datafusion.ObjectStoreOptions

Begin building an ObjectStoreOptions.Http (listing-capable HTTP/WebDAV) registration.

I

imdsv1Fallback(boolean) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

Allow falling back to IMDSv1 for credential discovery on EC2.

IMMUTABLE - Enum constant in enum class org.apache.datafusion.Volatility

impl() - Method in class org.apache.datafusion.ScalarUdf

The wrapped implementation.

informationSchema(boolean) - Method in class org.apache.datafusion.SessionContextBuilder

INNER - Enum constant in enum class org.apache.datafusion.JoinType

invokeScalarUdf(ScalarFunction, long, long, long, long, byte[], long, long, int) - Static method in class org.apache.datafusion.internal.JniBridge

Invoke a scalar UDF for one batch.

invokeTableScan(TableProvider, long) - Static method in class org.apache.datafusion.internal.JniBridge

Open a fresh batch stream from a Java TableProvider and export it through the supplied Arrow C Data Interface address.

J

JniBridge - Class in org.apache.datafusion.internal

Internal trampoline invoked from native code on every UDF call.

join(DataFrame, JoinType, String[], String[]) - Method in class org.apache.datafusion.DataFrame

Equi-join this DataFrame with right on the named columns, using the given JoinType.

join(DataFrame, JoinType, String[], String[], String) - Method in class org.apache.datafusion.DataFrame

Equi-join this DataFrame with right, restricting the result with a residual SQL filter parsed against the combined schema (left columns followed by right columns; columns may be qualified with the relation alias when ambiguous).

joinOn(DataFrame, JoinType, String...) - Method in class org.apache.datafusion.DataFrame

Join this DataFrame with right using arbitrary SQL predicates parsed against the combined schema.

JoinType - Enum Class in org.apache.datafusion

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 - Class in org.apache.datafusion

Configuration knobs for writing JSON, passed to DataFrame.writeJson(String, JsonWriteOptions).

JsonWriteOptions() - Constructor for class org.apache.datafusion.JsonWriteOptions

L

LEFT - Enum constant in enum class org.apache.datafusion.JoinType

LEFT_ANTI - Enum constant in enum class org.apache.datafusion.JoinType

LEFT_MARK - Enum constant in enum class org.apache.datafusion.JoinType

LEFT_SEMI - Enum constant in enum class org.apache.datafusion.JoinType

limit(int) - Method in class org.apache.datafusion.DataFrame

Take the first fetch rows.

limit(int, int) - Method in class org.apache.datafusion.DataFrame

Skip skip rows, then take the next fetch rows.

loadLibrary() - Static method in class org.apache.datafusion.NativeLibraryLoader

M

memoryLimit(long, double) - Method in class org.apache.datafusion.SessionContextBuilder

Cap the memory pool at maxMemoryBytes, reserving fraction of it for queries.

metadataSizeHint(long) - Method in class org.apache.datafusion.ParquetReadOptions

N

name() - Method in interface org.apache.datafusion.ScalarFunction

SQL name under which this function is invoked (e.g., "add_one").

name() - Method in class org.apache.datafusion.ScalarUdf

SQL name; cached from ScalarFunction.name().

NativeLibraryLoader - Class in org.apache.datafusion

NdJsonReadOptions - Class in org.apache.datafusion

Configuration knobs for newline-delimited JSON sources passed to SessionContext.registerJson(String, String, NdJsonReadOptions) and SessionContext.readJson(String, NdJsonReadOptions).

NdJsonReadOptions() - Constructor for class org.apache.datafusion.NdJsonReadOptions

newlinesInValues(boolean) - Method in class org.apache.datafusion.CsvReadOptions

nullValue(String) - Method in class org.apache.datafusion.CsvWriteOptions

String to write for SQL NULL values.

O

ObjectStoreOptions - Class in org.apache.datafusion

Description of an object_store::ObjectStore backend to register on a SessionContext's RuntimeEnv.

ObjectStoreOptions.Gcs - Class in org.apache.datafusion

Google Cloud Storage.

ObjectStoreOptions.Gcs.Builder - Class in org.apache.datafusion

ObjectStoreOptions.Http - Class in org.apache.datafusion

Listing-capable HTTP / WebDAV store.

ObjectStoreOptions.Http.Builder - Class in org.apache.datafusion

ObjectStoreOptions.S3 - Class in org.apache.datafusion

Amazon S3 (and any S3-compatible endpoint such as MinIO, Cloudflare R2, Wasabi).

ObjectStoreOptions.S3.Builder - Class in org.apache.datafusion

org.apache.datafusion - package org.apache.datafusion

org.apache.datafusion.internal - package org.apache.datafusion.internal

org.apache.datafusion.proto - package org.apache.datafusion.proto

P

parquetPruning(boolean) - Method in class org.apache.datafusion.ParquetReadOptions

ParquetReadOptions - Class in org.apache.datafusion

Configuration knobs for parquet sources passed to SessionContext.registerParquet(String, String, ParquetReadOptions) and SessionContext.readParquet(String, ParquetReadOptions).

ParquetReadOptions() - Constructor for class org.apache.datafusion.ParquetReadOptions

ParquetWriteOptions - Class in org.apache.datafusion

Configuration knobs for writing parquet, passed to DataFrame.writeParquet(String, ParquetWriteOptions).

ParquetWriteOptions() - Constructor for class org.apache.datafusion.ParquetWriteOptions

partitionCols(String...) - Method in class org.apache.datafusion.CsvWriteOptions

Hive-style partition columns.

partitionCols(String...) - Method in class org.apache.datafusion.JsonWriteOptions

Hive-style partition columns.

preserveNulls() - Method in class org.apache.datafusion.UnnestOptions

The current preserveNulls setting.

preserveNulls(boolean) - Method in class org.apache.datafusion.UnnestOptions

When true (the default), nulls in the input column are preserved as null rows in the output.

Q

quote(byte) - Method in class org.apache.datafusion.CsvReadOptions

quote(byte) - Method in class org.apache.datafusion.CsvWriteOptions

Quote character byte.

R

readArrow(String) - Method in class org.apache.datafusion.SessionContext

Read an Arrow IPC file as a DataFrame without registering it.

readArrow(String, ArrowReadOptions) - Method in class org.apache.datafusion.SessionContext

Read an Arrow IPC file as a DataFrame with the supplied ArrowReadOptions.

readAvro(String) - Method in class org.apache.datafusion.SessionContext

Read an Avro file as a DataFrame without registering it.

readAvro(String, AvroReadOptions) - Method in class org.apache.datafusion.SessionContext

Read an Avro file as a DataFrame with the supplied AvroReadOptions.

readCsv(String) - Method in class org.apache.datafusion.SessionContext

Read a CSV file as a DataFrame without registering it.

readCsv(String, CsvReadOptions) - Method in class org.apache.datafusion.SessionContext

Read a CSV file as a DataFrame with the supplied CsvReadOptions.

readJson(String) - Method in class org.apache.datafusion.SessionContext

Read a newline-delimited JSON file as a DataFrame without registering it.

readJson(String, NdJsonReadOptions) - Method in class org.apache.datafusion.SessionContext

Read a newline-delimited JSON file as a DataFrame with the supplied NdJsonReadOptions.

readParquet(String) - Method in class org.apache.datafusion.SessionContext

Read a parquet file as a DataFrame without registering it.

readParquet(String, ParquetReadOptions) - Method in class org.apache.datafusion.SessionContext

Read a parquet file as a DataFrame with the supplied ParquetReadOptions.

region(String) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

registerArrow(String, String) - Method in class org.apache.datafusion.SessionContext

Register an Arrow IPC file (or directory of Arrow IPC files) as a table.

registerArrow(String, String, ArrowReadOptions) - Method in class org.apache.datafusion.SessionContext

Register an Arrow IPC file (or directory of Arrow IPC files) as a table with the supplied ArrowReadOptions.

registerAvro(String, String) - Method in class org.apache.datafusion.SessionContext

Register an Avro file (or directory of Avro files) as a table.

registerAvro(String, String, AvroReadOptions) - Method in class org.apache.datafusion.SessionContext

Register an Avro file (or directory of Avro files) as a table with the supplied AvroReadOptions.

registerCsv(String, String) - Method in class org.apache.datafusion.SessionContext

registerCsv(String, String, CsvReadOptions) - Method in class org.apache.datafusion.SessionContext

Register a CSV file (or directory of CSV files) as a table with the supplied CsvReadOptions.

registerJson(String, String) - Method in class org.apache.datafusion.SessionContext

registerJson(String, String, NdJsonReadOptions) - Method in class org.apache.datafusion.SessionContext

Register a newline-delimited JSON file (or directory of NDJSON files) as a table with the supplied NdJsonReadOptions.

registerObjectStore(ObjectStoreOptions) - Method in class org.apache.datafusion.SessionContextBuilder

Register an object_store::ObjectStore backend on the new context's RuntimeEnv.

registerParquet(String, String) - Method in class org.apache.datafusion.SessionContext

registerParquet(String, String, ParquetReadOptions) - Method in class org.apache.datafusion.SessionContext

Register a parquet file as a table with the supplied ParquetReadOptions.

registerTable(String, TableProvider) - Method in class org.apache.datafusion.SessionContext

Register a Java-implemented TableProvider under name.

registerUdf(ScalarUdf) - Method in class org.apache.datafusion.SessionContext

Register a Java-implemented scalar UDF.

returnField() - Method in interface org.apache.datafusion.ScalarFunction

Declared return field.

returnField() - Method in class org.apache.datafusion.ScalarUdf

Declared return field; cached from ScalarFunction.returnField().

RIGHT - Enum constant in enum class org.apache.datafusion.JoinType

RIGHT_ANTI - Enum constant in enum class org.apache.datafusion.JoinType

RIGHT_MARK - Enum constant in enum class org.apache.datafusion.JoinType

RIGHT_SEMI - Enum constant in enum class org.apache.datafusion.JoinType

rowCount() - Method in record class org.apache.datafusion.ScalarFunctionArgs

Returns the value of the rowCount record component.

S

s3() - Static method in class org.apache.datafusion.ObjectStoreOptions

Begin building an ObjectStoreOptions.S3 (also covers MinIO, R2, any S3-compatible) registration.

scalar(FieldVector) - Static method in interface org.apache.datafusion.ColumnarValue

Wrap a length-1 vector as a ColumnarValue.Scalar.

Scalar(FieldVector) - Constructor for record class org.apache.datafusion.ColumnarValue.Scalar

Creates an instance of a Scalar record class.

ScalarFunction - Interface in org.apache.datafusion

A Java-implemented scalar SQL function.

ScalarFunctionArgs - Record Class in org.apache.datafusion

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.

ScalarFunctionArgs(List<ColumnarValue>, int) - Constructor for record class org.apache.datafusion.ScalarFunctionArgs

Creates an instance of a ScalarFunctionArgs record class.

ScalarUdf - Class in org.apache.datafusion

A scalar UDF registration handle: pairs a ScalarFunction implementation with the metadata DataFusion needs to dispatch SQL calls to it.

ScalarUdf(ScalarFunction) - Constructor for class org.apache.datafusion.ScalarUdf

Wrap a ScalarFunction for registration.

scan(BufferAllocator) - Method in class org.apache.datafusion.SimpleTableProvider

scan(BufferAllocator) - Method in interface org.apache.datafusion.TableProvider

Open a fresh batch stream for this table.

schema() - Method in class org.apache.datafusion.DataFrame

Return the Arrow Schema of this DataFrame's output.

schema() - Method in class org.apache.datafusion.SimpleTableProvider

schema() - Method in interface org.apache.datafusion.TableProvider

The fixed schema of this table.

schema(Schema) - Method in class org.apache.datafusion.ArrowReadOptions

schema(Schema) - Method in class org.apache.datafusion.AvroReadOptions

schema(Schema) - Method in class org.apache.datafusion.CsvReadOptions

schema(Schema) - Method in class org.apache.datafusion.NdJsonReadOptions

schema(Schema) - Method in class org.apache.datafusion.ParquetReadOptions

SchemaConverter - Class in org.apache.datafusion.proto

Convert between Arrow Java Schema and the datafusion_common.Schema protobuf shape used by DataFusion plan messages such as ListingTableScanNode.schema.

schemaInferMaxRecords(long) - Method in class org.apache.datafusion.CsvReadOptions

schemaInferMaxRecords(long) - Method in class org.apache.datafusion.NdJsonReadOptions

secretAccessKey(String) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

select(String...) - Method in class org.apache.datafusion.DataFrame

Project the listed columns into a new DataFrame.

serviceAccountKey(String) - Method in class org.apache.datafusion.ObjectStoreOptions.Gcs.Builder

Inline service-account JSON.

serviceAccountPath(String) - Method in class org.apache.datafusion.ObjectStoreOptions.Gcs.Builder

Filesystem path to service-account JSON.

SessionContext - Class in org.apache.datafusion

A DataFusion session context.

SessionContext() - Constructor for class org.apache.datafusion.SessionContext

SessionContextBuilder - Class in org.apache.datafusion

Builder for a configured SessionContext.

sessionToken(String) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

setOption(String, String) - Method in class org.apache.datafusion.SessionContextBuilder

Set an arbitrary datafusion.* config option by string key.

setOptions(LinkedHashMap<String, String>) - Method in class org.apache.datafusion.SessionContextBuilder

Apply every entry of entries via SessionContextBuilder.setOption(String, String), in LinkedHashMap insertion order.

setOptions(Map<String, String>) - Method in class org.apache.datafusion.SessionContextBuilder

Apply every entry of entries via SessionContextBuilder.setOption(String, String).

show() - Method in class org.apache.datafusion.DataFrame

Execute the plan and print formatted batches to native stdout.

show(int) - Method in class org.apache.datafusion.DataFrame

Execute the plan and print the first limit rows to native stdout.

SimpleTableProvider - Class in org.apache.datafusion

A TableProvider that pairs a fixed Schema with a function that opens a fresh ArrowReader for each scan.

SimpleTableProvider(Schema, Function<BufferAllocator, ArrowReader>) - Constructor for class org.apache.datafusion.SimpleTableProvider

singleFileOutput(boolean) - Method in class org.apache.datafusion.CsvWriteOptions

When true, write to a single file at the supplied path.

singleFileOutput(boolean) - Method in class org.apache.datafusion.JsonWriteOptions

When true, write to a single file at the supplied path.

singleFileOutput(boolean) - Method in class org.apache.datafusion.ParquetWriteOptions

When true, write to a single file at the supplied path.

skipMetadata(boolean) - Method in class org.apache.datafusion.ParquetReadOptions

skipSignature(boolean) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

Skip request signing (anonymous / public-bucket reads).

sql(String) - Method in class org.apache.datafusion.SessionContext

Parse and plan query, returning a lazy DataFrame.

STABLE - Enum constant in enum class org.apache.datafusion.Volatility

T

TableProvider - Interface in org.apache.datafusion

A Java-implemented table that can be registered with a SessionContext via SessionContext.registerTable(String, TableProvider).

tableSchema(String) - Method in class org.apache.datafusion.SessionContext

Return the Arrow Schema of a registered table.

targetPartitions(int) - Method in class org.apache.datafusion.SessionContextBuilder

tempDirectory(String) - Method in class org.apache.datafusion.SessionContextBuilder

Directory the DiskManager uses for spill files.

terminator(byte) - Method in class org.apache.datafusion.CsvReadOptions

toProto(Schema) - Static method in class org.apache.datafusion.proto.SchemaConverter

toString() - Method in record class org.apache.datafusion.ColumnarValue.Array

Returns a string representation of this record class.

toString() - Method in record class org.apache.datafusion.ColumnarValue.Scalar

Returns a string representation of this record class.

toString() - Method in record class org.apache.datafusion.ScalarFunctionArgs

Returns a string representation of this record class.

U

UNCOMPRESSED - Enum constant in enum class org.apache.datafusion.FileCompressionType

unnestColumns(String...) - Method in class org.apache.datafusion.DataFrame

Expand list or struct columns into rows or fields, with default UnnestOptions (i.e.

unnestColumns(UnnestOptions, String...) - Method in class org.apache.datafusion.DataFrame

Expand list or struct columns into rows or fields with the supplied UnnestOptions.

UnnestOptions - Class in org.apache.datafusion

Configuration knobs for DataFrame.unnestColumns(UnnestOptions, String...), mirroring DataFusion's UnnestOptions.

UnnestOptions() - Constructor for class org.apache.datafusion.UnnestOptions

url(String) - Method in class org.apache.datafusion.ObjectStoreOptions.Gcs.Builder

Override the registration URL.

url(String) - Method in class org.apache.datafusion.ObjectStoreOptions.S3.Builder

Override the registration URL.

V

valueOf(String) - Static method in enum class org.apache.datafusion.FileCompressionType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class org.apache.datafusion.JoinType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class org.apache.datafusion.Volatility

Returns the enum constant of this class with the specified name.

values() - Static method in enum class org.apache.datafusion.FileCompressionType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class org.apache.datafusion.JoinType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class org.apache.datafusion.Volatility

Returns an array containing the constants of this enum class, in the order they are declared.

vector() - Method in record class org.apache.datafusion.ColumnarValue.Array

Returns the value of the vector record component.

vector() - Method in record class org.apache.datafusion.ColumnarValue.Scalar

Returns the value of the vector record component.

vector() - Method in interface org.apache.datafusion.ColumnarValue

The underlying Arrow vector.

VOLATILE - Enum constant in enum class org.apache.datafusion.Volatility

volatility() - Method in interface org.apache.datafusion.ScalarFunction

Volatility classification.

volatility() - Method in class org.apache.datafusion.ScalarUdf

Volatility classification; cached from ScalarFunction.volatility().

Volatility - Enum Class in org.apache.datafusion

Volatility classification for a UDF.

W

withColumn(String, String) - Method in class org.apache.datafusion.DataFrame

Add a column to this DataFrame computed from a SQL expression.

withColumnRenamed(String, String) - Method in class org.apache.datafusion.DataFrame

Rename a column.

writeCsv(String) - Method in class org.apache.datafusion.DataFrame

Materialize this DataFrame as CSV at path.

writeCsv(String, CsvWriteOptions) - Method in class org.apache.datafusion.DataFrame

Materialize this DataFrame as CSV at path with the supplied CsvWriteOptions.

writeJson(String) - Method in class org.apache.datafusion.DataFrame

Materialize this DataFrame as newline-delimited JSON at path.

writeJson(String, JsonWriteOptions) - Method in class org.apache.datafusion.DataFrame

Materialize this DataFrame as newline-delimited JSON at path with the supplied JsonWriteOptions.

writeParquet(String) - Method in class org.apache.datafusion.DataFrame

Materialize this DataFrame as Parquet at path.

writeParquet(String, ParquetWriteOptions) - Method in class org.apache.datafusion.DataFrame

Materialize this DataFrame as Parquet at path with the supplied ParquetWriteOptions.

X

XZ - Enum constant in enum class org.apache.datafusion.FileCompressionType

Z

ZSTD - Enum constant in enum class org.apache.datafusion.FileCompressionType

A B C D E F G H I J L M N O P Q R S T U V W X Z
All Classes and Interfaces|All Packages