All Classes and Interfaces
Class
Description
Predicate which always evaluates to
false
.Predicate which always evaluates to
true
.AND
expressionRepresent
array
data typeAbstraction to represent a single array value in a
ColumnVector
.Base class for all primitive types
DataType
.The data type representing
byte[]
values.Data type representing
boolean
type values.The data type representing
byte
type values.Thrown when trying to create a checkpoint at version
v
, but there already exists a
checkpoint at version v
.Extend the Java
Iterable
interface to provide a way to close the iterator.Closeable extension of
Iterator
Represents the result of applying the filter condition in the
CloseableIterator.breakableFilter(Function)
method of a CloseableIterator
.Identifies collation for string type.
An expression type that refers to a column (case-sensitive) in the input.
Represents zero or more rows of records with same schema type.
Represents zero or more values of a single column.
Thrown when concurrent transaction both attempt to update the table with same transaction
identifier set through
TransactionBuilder.withTransactionId(Engine, String, long)
(String)}.Thrown when a concurrent transaction has written data after the current transaction has started.
Encapsulates statistics for a data file in a Delta Lake table and provides methods to serialize
those stats to JSON with basic physical-type validation.
Extends
FileStatus
to include additional details such as column level statistics of the
data file in the Delta Lake table.Base class for all data types.
Contains the context for writing data to Delta table.
A date type, supporting "0001-01-01" through "9999-12-31".
The data type representing
java.math.BigDecimal
values.Default implementation of
Engine
based on Hadoop APIs.Default implementation of
ExpressionHandler
Default implementation of
FileSystemClient
based on Hadoop APIs.Default implementation of
JsonHandler
based on Hadoop APIs.Default implementation of
ParquetHandler
based on Hadoop APIs.Defines the common fields that are shared by reports for Delta operations
Thrown when attempting to remove a domain metadata that does not exist in the read snapshot.
The data type representing
double
type values.Interface encapsulating all clients needed by the Delta Kernel in order to read the Delta table.
APIs that are meant to evolve towards becoming stable APIs, but are not stable APIs yet.
Base interface for all Kernel expressions.
Interface for implementing an
Expression
evaluator.Provides expression evaluation capability to Delta Kernel.
The metadata for a given
StructField
.Builder class for
FieldMetadata
.Interface for file IO operations.
Represents a request to read a range of bytes from a given file.
Stores the file size histogram information to track file size distribution and their counts.
Class for encapsulating metadata about a file in Delta Lake table.
Provides file system related functionalities to Delta Kernel.
Represents a filtered version of
ColumnarBatch
.The data type representing
float
type values.Implementation of
FileIO
based on Hadoop APIs.Interface for reading a file and getting metadata about it.
The data type representing
integer
type values.Thrown when an illegal value is specified for a table property.
Thrown when an invalid table is encountered; the table's log and/or checkpoint files are in an
invalid state.
Provides JSON handling functionality to Delta Kernel.
Throws when the
Engine
encountered an error while executing an operation.Thrown when Kernel cannot execute the requested operation due to the operation being invalid or
unsupported.
A literal value.
An implementation of
MetricsReporter
that logs the reports (as JSON) to Log4J at the info
level.The data type representing
long
type values.Data type representing a
map
type.Abstraction to represent a single map value in a
ColumnVector
.Thrown when the metadata of the Delta table has changed between the time of transaction start and
the time of commit.
Interface containing the metrics for a given operation
Interface for reporting metrics for operations to a Delta table
An operation that can be performed on a Delta table.
OR
expressionInterface for writing to a file and getting metadata about it.
Provides Parquet file related functionalities to Delta Kernel.
Expression to decode the serialized partition value into partition type value according the
Delta Protocol spec.
Extends
OutputStream
to provide the current position in the stream.A hook for executing operation after a transaction commit.
Defines predicate scalar expression which is an extension of
ScalarExpression
that
evaluates to true, false, or null for each input row.Special interface for evaluating
Predicate
on input batch and return a selection vector
containing one value for each row in input batch indicating whether the row has passed the
predicate or not.Thrown when the protocol of the Delta table has changed between the time of transaction start and
the time of commit.
Represent a single record
Scalar SQL expressions which take zero or more inputs and for each input row generate one output
value.
Represents a scan of a Delta table.
Builder to construct
Scan
object.Stores the metrics results for a
ScanReport
Defines the metadata and metrics for a Scan
MetricsReport
Extends
InputStream
to provide the current position in the stream and seek to a new
position.The data type representing
short
type values.Represents the snapshot of a Delta table.
Stores the metrics results for a
SnapshotReport
Defines the metadata and metrics for a snapshot construction
MetricsReport
The data type representing
string
type values.Represents a subfield of
StructType
with additional properties and metadata.Struct type which contains one or more columns.
Represents the Delta Lake table for a given path.
Thrown when trying to create a Delta table at a location where a Delta table already exists.
Thrown when there is no Delta table at the given location.
The timestamp without time zone type represents a local time in microsecond precision, which is
independent of time zone.
A timestamp type, supporting [0001-01-01T00:00:00.000000Z, 9999-12-31T23:59:59.999999Z] where the
left/right-bound is a date and time of the proleptic Gregorian calendar in UTC+00:00.
Represents a transaction to mutate a Delta table.
Builder for creating a
Transaction
to mutate a Delta table.Contains the result of a successful transaction commit.
Stores the metrics results for a
TransactionReport
Defines the metadata and metrics for a transaction
MetricsReport
Thrown when an unknown configuration key is specified.
A logical variant type.