Package io.delta.kernel.internal.data

Class TransactionStateRow

Object

io.delta.kernel.internal.data.GenericRow

io.delta.kernel.internal.data.TransactionStateRow

All Implemented Interfaces:

Row

public class TransactionStateRow
extends GenericRow

Field Summary

Fields

Modifier and Type	Field	Description
static final StructType	SCHEMA

Method Summary

Modifier and Type	Method	Description
static ColumnMapping.ColumnMappingMode	getColumnMappingMode(Row transactionState)	Get the column mapping mode from the transaction state Row returned by Transaction.getTransactionState(Engine)
static Map<String,String>	getConfiguration(Row transactionState)	Get the configuration from the transaction state Row returned by Transaction.getTransactionState(Engine)
static StructType	getLogicalSchema(Row transactionState)	Get the logical schema of the table from the transaction state Row returned by Transaction.getTransactionState(Engine)}
static int	getMaxRetries(Row transactionState)	Get the maxRetries from transaction state Row returned by Transaction.getTransactionState(Engine)
static List<String>	getPartitionColumnsList(Row transactionState)	Get the list of partition column names from the transaction state Row returned by Transaction.getTransactionState(Engine)
static StructType	getPhysicalSchema(Row transactionState)	Get the physical schema of the table from the transaction state Row returned by Transaction.getTransactionState(Engine)}
static Protocol	getProtocol(Row transactionState)	Get the Protocol from transaction state Row returned by Transaction.getTransactionState(Engine)
static String	getTablePath(Row transactionState)	Get the table path from transaction state Row returned by Transaction.getTransactionState(Engine)
static boolean	isIcebergCompatV2Enabled(Row transactionState)	Get the iceberg compatibility enabled or not from the transaction state Row returned by Transaction.getTransactionState(Engine)
static boolean	isIcebergCompatV3Enabled(Row transactionState)	Get the iceberg compatibility enabled or not from the transaction state Row returned by Transaction.getTransactionState(Engine)
static TransactionStateRow	of(Metadata metadata, Protocol protocol, String tablePath, int maxRetries)

Methods inherited from class io.delta.kernel.internal.data.GenericRow

getArray, getBinary, getBoolean, getByte, getDecimal, getDouble, getFloat, getInt, getLong, getMap, getSchema, getShort, getString, getStruct, isNullAt

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

SCHEMA

public static final StructType SCHEMA

Method Details

of

public static TransactionStateRow of(Metadata metadata,
 Protocol protocol,
 String tablePath,
 int maxRetries)

getLogicalSchema

public static StructType getLogicalSchema(Row transactionState)

Get the logical schema of the table from the transaction state Row returned by Transaction.getTransactionState(Engine)}

Parameters:

transactionState - Transaction state state Row

Returns:

Logical schema of the table as StructType

getPhysicalSchema

public static StructType getPhysicalSchema(Row transactionState)

Get the physical schema of the table from the transaction state Row returned by Transaction.getTransactionState(Engine)}

Parameters:

transactionState - Transaction state state Row

Returns:

Logical schema of the table as StructType

getConfiguration

public static Map<String,String> getConfiguration(Row transactionState)

Get the configuration from the transaction state Row returned by Transaction.getTransactionState(Engine)

Parameters:

transactionState -

Returns:

Configuration as a map of key-value pairs.

isIcebergCompatV2Enabled

public static boolean isIcebergCompatV2Enabled(Row transactionState)

Get the iceberg compatibility enabled or not from the transaction state Row returned by Transaction.getTransactionState(Engine)

Parameters:

transactionState - Transaction state state Row

Returns:

True if iceberg compatibility is enabled, false otherwise.

isIcebergCompatV3Enabled

public static boolean isIcebergCompatV3Enabled(Row transactionState)

Get the iceberg compatibility enabled or not from the transaction state Row returned by Transaction.getTransactionState(Engine)

Parameters:

transactionState - Transaction state state Row

Returns:

True if iceberg compatibility is enabled, false otherwise.

getColumnMappingMode

public static ColumnMapping.ColumnMappingMode getColumnMappingMode(Row transactionState)

Get the column mapping mode from the transaction state Row returned by Transaction.getTransactionState(Engine)

Parameters:

transactionState -

Returns:

ColumnMapping mode as ColumnMapping.ColumnMappingMode

getPartitionColumnsList

public static List<String> getPartitionColumnsList(Row transactionState)

Get the list of partition column names from the transaction state Row returned by Transaction.getTransactionState(Engine)

Parameters:

transactionState - Transaction state state Row

Returns:

List of partition column names according to the scan state.

getTablePath

public static String getTablePath(Row transactionState)

Get the table path from transaction state Row returned by Transaction.getTransactionState(Engine)

Parameters:

transactionState - Transaction state state Row

Returns:

Fully qualified path to the location of the table.

getMaxRetries

public static int getMaxRetries(Row transactionState)

Get the maxRetries from transaction state Row returned by Transaction.getTransactionState(Engine)

getProtocol

public static Protocol getProtocol(Row transactionState)

Get the Protocol from transaction state Row returned by Transaction.getTransactionState(Engine)

Parameters:

transactionState - Transaction state state Row

Returns:

Protocol object