Package io.delta.kernel.internal.replay

Class PaginationContext

Object

io.delta.kernel.internal.replay.PaginationContext

public class PaginationContext
extends Object

PaginationContext carries pagination-related information.

Method Summary

Modifier and Type	Method	Description
static PaginationContext	forFirstPage(String tablePath, long tableVersion, int logSegmentHash, int predicateHash, long pageSize)
static PaginationContext	forPageWithPageToken(String tablePath, long tableVersion, int logSegmentHash, int predicateHash, long pageSize, PageToken pageToken)
Optional<String>	getLastReadLogFilePath()
Optional<Long>	getLastReadSidecarFileIdx()
Optional<Long>	getLastReturnedRowIndex()
int	getLogSegmentHash()
long	getPageSize()
int	getPredicateHash()
String	getTablePath()
long	getTableVersion()

Methods inherited from class java.lang.Object

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

Method Details

forPageWithPageToken

public static PaginationContext forPageWithPageToken(String tablePath,
 long tableVersion,
 int logSegmentHash,
 int predicateHash,
 long pageSize,
 PageToken pageToken)

forFirstPage

public static PaginationContext forFirstPage(String tablePath,
 long tableVersion,
 int logSegmentHash,
 int predicateHash,
 long pageSize)

getTablePath

public String getTablePath()

getTableVersion

public long getTableVersion()

getPredicateHash

public int getPredicateHash()

getLogSegmentHash

public int getLogSegmentHash()

getPageSize

public long getPageSize()

getLastReadLogFilePath

public Optional<String> getLastReadLogFilePath()

getLastReturnedRowIndex

public Optional<Long> getLastReturnedRowIndex()

getLastReadSidecarFileIdx

public Optional<Long> getLastReadSidecarFileIdx()