Package io.delta.kernel.internal.checksum

Class CRCInfo

Object

io.delta.kernel.internal.checksum.CRCInfo

public class CRCInfo
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final StructType	CRC_FILE_READ_SCHEMA
static final StructType	CRC_FILE_SCHEMA

Constructor Summary

Constructors

Constructor	Description
CRCInfo(long version, Metadata metadata, Protocol protocol, long tableSizeBytes, long numFiles, Optional<String> txnId, Optional<Set<DomainMetadata>> domainMetadata, Optional<FileSizeHistogram> fileSizeHistogram)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static Optional<CRCInfo>	fromColumnarBatch(long version, ColumnarBatch batch, int rowId, String crcFilePath)
Optional<Set<DomainMetadata>>	getDomainMetadata()
Optional<FileSizeHistogram>	getFileSizeHistogram()	The FileSizeHistogram stored in this CRCInfo.
Metadata	getMetadata()	The Metadata stored in this CRCInfo.
long	getNumFiles()
Protocol	getProtocol()	The Protocol stored in this CRCInfo.
long	getTableSizeBytes()
Optional<String>	getTxnId()
long	getVersion()	The version of the Delta table that this CRCInfo represents.
int	hashCode()
Row	toRow()	Encode as a Row object with the schema CRC_FILE_SCHEMA.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

CRC_FILE_SCHEMA

public static final StructType CRC_FILE_SCHEMA

CRC_FILE_READ_SCHEMA

public static final StructType CRC_FILE_READ_SCHEMA

Constructor Details

CRCInfo

public CRCInfo(long version,
 Metadata metadata,
 Protocol protocol,
 long tableSizeBytes,
 long numFiles,
 Optional<String> txnId,
 Optional<Set<DomainMetadata>> domainMetadata,
 Optional<FileSizeHistogram> fileSizeHistogram)

Method Details

fromColumnarBatch

public static Optional<CRCInfo> fromColumnarBatch(long version,
 ColumnarBatch batch,
 int rowId,
 String crcFilePath)

getVersion

public long getVersion()

The version of the Delta table that this CRCInfo represents.

getMetadata

public Metadata getMetadata()

The Metadata stored in this CRCInfo.

getProtocol

public Protocol getProtocol()

The Protocol stored in this CRCInfo.

getNumFiles

public long getNumFiles()

getTableSizeBytes

public long getTableSizeBytes()

getTxnId

public Optional<String> getTxnId()

getDomainMetadata

public Optional<Set<DomainMetadata>> getDomainMetadata()

getFileSizeHistogram

public Optional<FileSizeHistogram> getFileSizeHistogram()

The FileSizeHistogram stored in this CRCInfo.

toRow

public Row toRow()

Encode as a Row object with the schema CRC_FILE_SCHEMA.

Returns:

Row object with the schema CRC_FILE_SCHEMA

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object