Package io.debezium.relational

Class RelationalSnapshotChangeEventSource.SnapshotMarkerResolver

java.lang.Object

io.debezium.relational.RelationalSnapshotChangeEventSource.SnapshotMarkerResolver

Enclosing class:

RelationalSnapshotChangeEventSource<P extends Partition,O extends OffsetContext>

private static class RelationalSnapshotChangeEventSource.SnapshotMarkerResolver
extends Object

Determines the appropriate SnapshotRecord marker based on record position.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SnapshotMarkerResolver()

Method Summary

Modifier and Type	Method	Description
(package private) static SnapshotRecord	resolve(boolean isFirstInSnapshot, boolean isLastInSnapshot, boolean isFirstInDataCollection, boolean isLastInDataCollection)	Resolves the snapshot marker for a record based on its position within the snapshot.

Methods inherited from class java.lang.Object

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

Constructor Details

SnapshotMarkerResolver

private SnapshotMarkerResolver()

Method Details

resolve

static SnapshotRecord resolve(boolean isFirstInSnapshot,
 boolean isLastInSnapshot,
 boolean isFirstInDataCollection,
 boolean isLastInDataCollection)

Resolves the snapshot marker for a record based on its position within the snapshot.

Parameters:

isFirstInSnapshot - true if this is the first record of the entire snapshot

isLastInSnapshot - true if this is the last record of the entire snapshot

isFirstInDataCollection - true if this is the first record of the current table/data collection

isLastInDataCollection - true if this is the last record of the current table/data collection

Returns:

the appropriate SnapshotRecord marker