Package io.debezium.pipeline.source.snapshot.chunked

Class SnapshotChunk

java.lang.Object

io.debezium.pipeline.source.snapshot.chunked.SnapshotChunk

public class SnapshotChunk
extends Object

Represents a single chunk of a table to be snapshot in parallel with precomputed values.

Author:

Chris Cranford

Field Summary

Fields

Modifier and Type	Field	Description
private final String	baseSelectStatement
private final int	chunkIndex
private final OptionalLong	estimatedRowCount
private final Object[]	lowerBounds
private final Table	table
private final int	tableCount
private final TableId	tableId
private final int	tableOrder
private final int	totalChunks
private final Object[]	upperBounds

Constructor Summary

Constructors

Constructor	Description
SnapshotChunk(TableId tableId, Table table, Object[] lowerBounds, Object[] upperBounds, int chunkIndex, int totalChunks, int tableOrder, int tableCount, String baseSelectStatement, OptionalLong estimatedRowCount)

Method Summary

Modifier and Type	Method	Description
String	getBaseSelectStatement()
String	getChunkId()
int	getChunkIndex()
OptionalLong	getEstimatedRowCount()
Object[]	getLowerBounds()
Table	getTable()
int	getTableCount()
TableId	getTableId()
int	getTableOrder()
int	getTotalChunks()
Object[]	getUpperBounds()
boolean	hasLowerBound()
boolean	hasUpperBound()
boolean	isFirstChunk()
boolean	isFirstChunkOfSnapshot()
boolean	isLastChunk()
boolean	isLastChunkOfSnapshot()

Methods inherited from class java.lang.Object

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

Field Details

tableId

private final TableId tableId

table

private final Table table

lowerBounds

private final Object[] lowerBounds

upperBounds

private final Object[] upperBounds

chunkIndex

private final int chunkIndex

totalChunks

private final int totalChunks

tableOrder

private final int tableOrder

tableCount

private final int tableCount

baseSelectStatement

private final String baseSelectStatement

estimatedRowCount

private final OptionalLong estimatedRowCount

Constructor Details

SnapshotChunk

public SnapshotChunk(TableId tableId,
 Table table,
 Object[] lowerBounds,
 Object[] upperBounds,
 int chunkIndex,
 int totalChunks,
 int tableOrder,
 int tableCount,
 String baseSelectStatement,
 OptionalLong estimatedRowCount)

Method Details

getTableId

public TableId getTableId()

getTable

public Table getTable()

getLowerBounds

public Object[] getLowerBounds()

getUpperBounds

public Object[] getUpperBounds()

getChunkIndex

public int getChunkIndex()

getTotalChunks

public int getTotalChunks()

getTableOrder

public int getTableOrder()

getTableCount

public int getTableCount()

getBaseSelectStatement

public String getBaseSelectStatement()

getEstimatedRowCount

public OptionalLong getEstimatedRowCount()

hasLowerBound

public boolean hasLowerBound()

hasUpperBound

public boolean hasUpperBound()

isFirstChunk

public boolean isFirstChunk()

isLastChunk

public boolean isLastChunk()

isFirstChunkOfSnapshot

public boolean isFirstChunkOfSnapshot()

isLastChunkOfSnapshot

public boolean isLastChunkOfSnapshot()

getChunkId

public String getChunkId()