- generateAppendActions(Engine, Row, CloseableIterator<DataFileStatus>, DataWriteContext) - Static method in interface io.delta.kernel.Transaction
-
For given data files, generate Delta actions that can be committed in a transaction.
- get(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- get(String) - Method in class io.delta.kernel.types.StructType
-
- getAllPrimitiveTypes() - Static method in class io.delta.kernel.types.BasePrimitiveType
-
For testing only
- getArray(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Return the array value located at rowId
.
- getArray(int) - Method in interface io.delta.kernel.data.Row
-
Return array value of the column located at the given ordinal.
- getBinary(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the binary type value for rowId
.
- getBinary(int) - Method in interface io.delta.kernel.data.Row
-
Return binary value of the column located at the given ordinal.
- getBoolean(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the boolean type value for rowId
.
- getBoolean(int) - Method in interface io.delta.kernel.data.Row
-
Return boolean value of the column located at the given ordinal.
- getBoolean(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getBooleanArray(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getByte(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the byte type value for rowId
.
- getByte(int) - Method in interface io.delta.kernel.data.Row
-
Return byte value of the column located at the given ordinal.
- getChild(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Get the child vector associated with the given ordinal.
- getChildren() - Method in class io.delta.kernel.expressions.Column
-
- getChildren() - Method in interface io.delta.kernel.expressions.Expression
-
- getChildren() - Method in class io.delta.kernel.expressions.Literal
-
- getChildren() - Method in class io.delta.kernel.expressions.PartitionValueExpression
-
- getChildren() - Method in class io.delta.kernel.expressions.ScalarExpression
-
- getColumnVector(int) - Method in interface io.delta.kernel.data.ColumnarBatch
-
Return the
ColumnVector
for the given ordinal in the columnar batch.
- getCommit() - Method in class io.delta.kernel.engine.coordinatedcommits.CommitResponse
-
Get the commit object.
- getCommitCoordinatorClientHandler(String, Map<String, String>) - Method in class io.delta.kernel.defaults.engine.DefaultEngine
-
- getCommitCoordinatorClientHandler(String, Map<String, String>) - Method in interface io.delta.kernel.engine.Engine
-
- getCommitInfo() - Method in class io.delta.kernel.engine.coordinatedcommits.UpdatedActions
-
Get the commit info for this commit attempt.
- getCommits(String, Map<String, String>, Long, Long) - Method in class io.delta.kernel.defaults.engine.DefaultCommitCoordinatorClientHandler
-
- getCommits(String, Map<String, String>, Long, Long) - Method in interface io.delta.kernel.engine.CommitCoordinatorClientHandler
-
Retrieves unbackfilled commits for a specified table within a given version range.
- getCommits() - Method in class io.delta.kernel.engine.coordinatedcommits.GetCommitsResponse
-
Get the list of commits that have not been backfilled as per the commit coordinator.
- GetCommitsResponse - Class in io.delta.kernel.engine.coordinatedcommits
-
- GetCommitsResponse(List<Commit>, long) - Constructor for class io.delta.kernel.engine.coordinatedcommits.GetCommitsResponse
-
- getCommitTimestamp() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractCommitInfo
-
Get the timestamp of the commit as millis after the epoch.
- getCommitTimestamp() - Method in class io.delta.kernel.engine.coordinatedcommits.Commit
-
Get the timestamp that represents the time since epoch in milliseconds when the commit write
was started.
- getConfiguration() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
The table properties defined on the table.
- getConflict() - Method in exception io.delta.kernel.engine.coordinatedcommits.CommitFailedException
-
Returns whether the commit failed due to a conflict.
- getCreatedTime() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
Timestamp for the creation of this metadata.
- getData() - Method in class io.delta.kernel.data.FilteredColumnarBatch
-
- getDataType() - Method in interface io.delta.kernel.data.ColumnVector
-
- getDataType() - Method in class io.delta.kernel.expressions.Literal
-
Get the datatype of the literal object.
- getDataType() - Method in class io.delta.kernel.expressions.PartitionValueExpression
-
Get the data type of the partition value.
- getDataType() - Method in class io.delta.kernel.types.StructField
-
- getDecimal(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the decimal type value for rowId
.
- getDecimal(int) - Method in interface io.delta.kernel.data.Row
-
Return decimal value of the column located at the given ordinal.
- getDescription() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
User-specified table description.
- getDescription() - Method in enum io.delta.kernel.Operation
-
Returns the string that will be recorded in the transaction log.
- getDouble(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the double type value for rowId
.
- getDouble(int) - Method in interface io.delta.kernel.data.Row
-
Return double value of the column located at the given ordinal.
- getDouble(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getDoubleArray(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getElementField() - Method in class io.delta.kernel.types.ArrayType
-
- getElements() - Method in interface io.delta.kernel.data.ArrayValue
-
- getElementType() - Method in class io.delta.kernel.types.ArrayType
-
- getEntries() - Method in class io.delta.kernel.types.FieldMetadata
-
- getEvaluator(StructType, Expression, DataType) - Method in class io.delta.kernel.defaults.engine.DefaultExpressionHandler
-
- getEvaluator(StructType, Expression, DataType) - Method in interface io.delta.kernel.engine.ExpressionHandler
-
- getExpressionHandler() - Method in class io.delta.kernel.defaults.engine.DefaultEngine
-
- getExpressionHandler() - Method in interface io.delta.kernel.engine.Engine
-
- getFileStatus() - Method in class io.delta.kernel.engine.coordinatedcommits.Commit
-
Get the file status of the commit.
- getFileSystemClient() - Method in class io.delta.kernel.defaults.engine.DefaultEngine
-
- getFileSystemClient() - Method in interface io.delta.kernel.engine.Engine
-
- getFloat(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the float type value for rowId
.
- getFloat(int) - Method in interface io.delta.kernel.data.Row
-
Return float value of the column located at the given ordinal.
- getFormatOptions() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
The format options
- getId() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
A unique table identifier.
- getInput() - Method in class io.delta.kernel.expressions.PartitionValueExpression
-
Get the expression reference to the serialized partition value.
- getInt(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the int type value for rowId
.
- getInt(int) - Method in interface io.delta.kernel.data.Row
-
Return integer value of the column located at the given ordinal.
- getJsonHandler() - Method in class io.delta.kernel.defaults.engine.DefaultEngine
-
- getJsonHandler() - Method in interface io.delta.kernel.engine.Engine
-
- getKeyField() - Method in class io.delta.kernel.types.MapType
-
- getKeys() - Method in interface io.delta.kernel.data.MapValue
-
- getKeyType() - Method in class io.delta.kernel.types.MapType
-
- getLatestSnapshot(Engine) - Method in interface io.delta.kernel.Table
-
Get the latest snapshot of the table.
- getLatestTableVersion() - Method in class io.delta.kernel.engine.coordinatedcommits.GetCommitsResponse
-
Get the latest table version as per the coordinator.
- getLeft() - Method in class io.delta.kernel.expressions.And
-
- getLeft() - Method in class io.delta.kernel.expressions.Or
-
- getLong(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the long type value for rowId
.
- getLong(int) - Method in interface io.delta.kernel.data.Row
-
Return long value of the column located at the given ordinal.
- getLong(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getLongArray(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getMap(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Return the map value located at rowId
.
- getMap(int) - Method in interface io.delta.kernel.data.Row
-
Return map value of the column located at the given ordinal.
- getMaxValues() - Method in class io.delta.kernel.utils.DataFileStatistics
-
Get the maximum values of the columns in the data file.
- getMessage() - Method in exception io.delta.kernel.exceptions.TableAlreadyExistsException
-
- getMetadata(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getMetadata() - Method in class io.delta.kernel.types.StructField
-
- getMetadataArray(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getMinReaderVersion() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractProtocol
-
The minimum reader version required to read the table.
- getMinValues() - Method in class io.delta.kernel.utils.DataFileStatistics
-
Get the minimum values of the columns in the data file.
- getMinWriterVersion() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractProtocol
-
The minimum writer version required to read the table.
- getModificationTime() - Method in class io.delta.kernel.utils.FileStatus
-
Get the modification time of the file in epoch millis.
- getName() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
User-specified table identifier.
- getName() - Method in class io.delta.kernel.expressions.ScalarExpression
-
- getName() - Method in class io.delta.kernel.types.StructField
-
- getNames() - Method in class io.delta.kernel.expressions.Column
-
- getNewMetadata() - Method in class io.delta.kernel.engine.coordinatedcommits.UpdatedActions
-
Get the new metadata which needs to be committed.
- getNewProtocol() - Method in class io.delta.kernel.engine.coordinatedcommits.UpdatedActions
-
Get the new protocol which needs to be committed.
- getNullCounts() - Method in class io.delta.kernel.utils.DataFileStatistics
-
Get the number of nulls of columns in the data file.
- getNumRecords() - Method in class io.delta.kernel.utils.DataFileStatistics
-
Get the number of records in the data file.
- getOldMetadata() - Method in class io.delta.kernel.engine.coordinatedcommits.UpdatedActions
-
Get the metadata from the read snapshot of this transaction.
- getOldProtocol() - Method in class io.delta.kernel.engine.coordinatedcommits.UpdatedActions
-
Get the protocol from the read snapshot of this transaction.
- getParquetHandler() - Method in class io.delta.kernel.defaults.engine.DefaultEngine
-
- getParquetHandler() - Method in interface io.delta.kernel.engine.Engine
-
- getPartitionColumns() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
List of partition columns.
- getPartitionColumns(Engine) - Method in interface io.delta.kernel.Transaction
-
Get the list of logical names of the partition columns.
- getPath() - Method in interface io.delta.kernel.engine.FileReadRequest
-
Get the fully qualified path of the file from which to read the data.
- getPath(Engine) - Method in interface io.delta.kernel.Table
-
The fully qualified path of this
Table
instance.
- getPath() - Method in class io.delta.kernel.utils.FileStatus
-
Get the path to the file.
- getPrecision() - Method in class io.delta.kernel.types.DecimalType
-
- getPredicateEvaluator(StructType, Predicate) - Method in class io.delta.kernel.defaults.engine.DefaultExpressionHandler
-
- getPredicateEvaluator(StructType, Predicate) - Method in interface io.delta.kernel.engine.ExpressionHandler
-
- getProvider() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
The table provider format.
- getReaderFeatures() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractProtocol
-
The reader features that need to be supported to read the table.
- getReadLength() - Method in interface io.delta.kernel.engine.FileReadRequest
-
Get the length of the data to read from the file starting at the startOffset.
- getRemainingFilter() - Method in interface io.delta.kernel.Scan
-
Get the remaining filter that is not guaranteed to be satisfied for the data Delta Kernel
returns.
- getRetryable() - Method in exception io.delta.kernel.engine.coordinatedcommits.CommitFailedException
-
Returns whether the commit attempt can be retried.
- getRight() - Method in class io.delta.kernel.expressions.And
-
- getRight() - Method in class io.delta.kernel.expressions.Or
-
- getRows() - Method in interface io.delta.kernel.data.ColumnarBatch
-
- getRows() - Method in class io.delta.kernel.data.FilteredColumnarBatch
-
Iterator of rows that survived the filter.
- getScale() - Method in class io.delta.kernel.types.DecimalType
-
- getScanBuilder(Engine) - Method in interface io.delta.kernel.Snapshot
-
Create a scan builder to construct a
Scan
to read data from this snapshot.
- getScanFiles(Engine) - Method in interface io.delta.kernel.Scan
-
Get an iterator of data files to scan.
- getScanState(Engine) - Method in interface io.delta.kernel.Scan
-
Get the scan state associated with the current scan.
- getSchema() - Method in interface io.delta.kernel.data.ColumnarBatch
-
- getSchema() - Method in interface io.delta.kernel.data.Row
-
- getSchema(Engine) - Method in interface io.delta.kernel.Snapshot
-
Get the schema of the table at this snapshot.
- getSchema(Engine) - Method in interface io.delta.kernel.Transaction
-
Get the schema of the table.
- getSchemaString() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractMetadata
-
The table schema in string representation.
- getSelectionVector() - Method in class io.delta.kernel.data.FilteredColumnarBatch
-
Optional selection vector containing one entry for each row in data indicating whether a
row is selected or not selected.
- getShort(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the short type value for rowId
.
- getShort(int) - Method in interface io.delta.kernel.data.Row
-
Return short value of the column located at the given ordinal.
- getSize() - Method in interface io.delta.kernel.data.ArrayValue
-
The number of elements in the array
- getSize() - Method in interface io.delta.kernel.data.ColumnarBatch
-
- getSize() - Method in interface io.delta.kernel.data.ColumnVector
-
- getSize() - Method in interface io.delta.kernel.data.MapValue
-
The number of elements in the map
- getSize() - Method in class io.delta.kernel.utils.FileStatus
-
Get the size of the file in bytes.
- getSnapshotAsOfTimestamp(Engine, long) - Method in interface io.delta.kernel.Table
-
Get the snapshot of the table at the given timestamp
.
- getSnapshotAsOfVersion(Engine, long) - Method in interface io.delta.kernel.Table
-
Get the snapshot at the given versionId
.
- getStartOffset() - Method in interface io.delta.kernel.engine.FileReadRequest
-
Get the start offset in the file from where to start reading the data.
- getStatistics() - Method in class io.delta.kernel.utils.DataFileStatus
-
Get the statistics of the data file encapsulated in this object.
- getStatisticsColumns() - Method in interface io.delta.kernel.DataWriteContext
-
Returns the list of
Column
that the connector can optionally collect statistics.
- getString(int) - Method in interface io.delta.kernel.data.ColumnVector
-
Returns the string type value for rowId
.
- getString(int) - Method in interface io.delta.kernel.data.Row
-
Return string value of the column located at the given ordinal.
- getString(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getStringArray(String) - Method in class io.delta.kernel.types.FieldMetadata
-
- getStruct(int) - Method in interface io.delta.kernel.data.Row
-
Return struct value of the column located at the given ordinal.
- getTablePath() - Method in exception io.delta.kernel.exceptions.TableNotFoundException
-
- getTargetDirectory() - Method in interface io.delta.kernel.DataWriteContext
-
Returns the target directory where the data should be written.
- getTransactionState(Engine) - Method in interface io.delta.kernel.Transaction
-
Get the state of the transaction.
- getValue() - Method in class io.delta.kernel.expressions.Literal
-
Get the literal value.
- getValueField() - Method in class io.delta.kernel.types.MapType
-
- getValues() - Method in interface io.delta.kernel.data.MapValue
-
- getValueType() - Method in class io.delta.kernel.types.MapType
-
- getVersion() - Method in class io.delta.kernel.engine.coordinatedcommits.Commit
-
Get the version of the commit.
- getVersion(Engine) - Method in interface io.delta.kernel.Snapshot
-
Get the version of this snapshot in the table.
- getVersion() - Method in class io.delta.kernel.TransactionCommitResult
-
Contains the version of the transaction committed as.
- getWriteContext(Engine, Row, Map<String, Literal>) - Static method in interface io.delta.kernel.Transaction
-
Get the context for writing data into a table.
- getWriterFeatures() - Method in interface io.delta.kernel.engine.coordinatedcommits.actions.AbstractProtocol
-
The writer features that need to be supported to write the table.