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
 ...
}