alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1346 Fixing description for state of snapshot

Browse Source
This commit is contained in:
Cheng Pan 2019-06-24 03:52:16 -05:00 committed by Gunnar Morling
parent c88e454809
commit 186babeabf
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
debezium-core/src/main/java/io/debezium/connector/SnapshotRecord.java
View File

@ -14,9 +14,18 @@
*
*/
public enum SnapshotRecord {
TRUE, // record is from snapshot is not the last one
FALSE, // record is from snapshot is the last record generated in snapshot phase
LAST; // record is from streaming phase
/**
* Record is from snapshot is not the last one.
*/
TRUE,
/**
* Record is from snapshot is the last record generated in snapshot phase.
*/
LAST,
/**
* Record is from streaming phase.
*/
FALSE;
public static SnapshotRecord fromSource(Struct source) {
if (source.schema().field(AbstractSourceInfo.SNAPSHOT_KEY) != null && io.debezium.data.Enum.LOGICAL_NAME.equals(source.schema().field(AbstractSourceInfo.SNAPSHOT_KEY).schema().name())) {