Class CdcManagerRecord
- java.lang.Object
-
- org.apache.ignite.internal.pagemem.wal.record.WALRecord
-
- org.apache.ignite.internal.pagemem.wal.record.CdcManagerRecord
-
public class CdcManagerRecord extends WALRecord
This record notifiesCdcMainabout committed WAL state. It's assumed that WAL state will be inferred fromCdcConsumercommitted WALPointer.- See Also:
CdcConsumer.onEvents(Iterator)
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.ignite.internal.pagemem.wal.record.WALRecord
WALRecord.RecordPurpose, WALRecord.RecordType
-
-
Constructor Summary
Constructors Constructor Description CdcManagerRecord(T2<WALPointer,Integer> state)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description WALRecord.RecordTypetype()T2<WALPointer,Integer>walState()
-
-
-
Constructor Detail
-
CdcManagerRecord
public CdcManagerRecord(T2<WALPointer,Integer> state)
-
-
Method Detail
-
walState
public T2<WALPointer,Integer> walState()
- Returns:
- CDC consumer WAL state.
-
type
public WALRecord.RecordType type()
-
-