org.apache.ignite.internal.cdc

Class CdcConsumerState

java.lang.Object

org.apache.ignite.internal.cdc.CdcConsumerState

public class CdcConsumerState
extends Object

Change Data Capture Consumer state. Each time CdcConsumer.onEvents(Iterator) returns true current offset in WAL segment and DataEntry index inside DataRecord saved to file. This allows to the CdcConsumer to continue consumption of the CdcEvent from the last saved offset in case of fail or restart.

See Also:

CdcConsumer.onEvents(Iterator), CdcMain

Field Summary

Fields

Modifier and Type	Field and Description
static String	STATE_FILE_NAME

Constructor Summary

Constructors

Constructor and Description
CdcConsumerState(Path stateDir)

Method Summary

Modifier and Type	Method and Description
T2<WALPointer,Integer>	load() Loads CDC state from file.
void	save(T2<WALPointer,Integer> state) Saves state to file.

Methods inherited from class java.lang.Object

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

Field Detail

STATE_FILE_NAME

public static final String STATE_FILE_NAME

See Also:

Constant Field Values

Constructor Detail

CdcConsumerState

public CdcConsumerState(Path stateDir)

Parameters:

stateDir - State directory.

Method Detail

save

public void save(T2<WALPointer,Integer> state)
          throws IOException

Saves state to file.

Parameters:

state - WAL pointer and index of DataEntry inside DataRecord.

Throws:

IOException

load

public T2<WALPointer,Integer> load()

Loads CDC state from file.

Returns:

Saved state.