org.apache.ignite.internal.cdc

Class WalRecordsConsumer<K,V>

java.lang.Object

org.apache.ignite.internal.cdc.WalRecordsConsumer<K,V>

public class WalRecordsConsumer<K,V>
extends Object

Transform DataEntry to CdcEvent and sends it to CdcConsumer.

See Also:

CdcMain, CdcConsumer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WalRecordsConsumer.DataEntryIterator Iterator over DataEntry.

Field Summary

Fields

Modifier and Type	Field and Description
static String	EVTS_CNT Events count metric name.
static String	LAST_EVT_TIME Last event time metric name.

Constructor Summary

Constructors

Constructor and Description
WalRecordsConsumer(CdcConsumer consumer, IgniteLogger log)

Method Summary

Modifier and Type	Method and Description
CdcConsumer	consumer()
boolean	onRecords(Iterator<DataEntry> entries) Handles data entries.
void	start(MetricRegistry cdcReg, MetricRegistry cdcConsumerReg) Starts the consumer.
void	stop() Stops the consumer.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

EVTS_CNT

public static final String EVTS_CNT

Events count metric name.

See Also:

Constant Field Values

LAST_EVT_TIME

public static final String LAST_EVT_TIME

Last event time metric name.

See Also:

Constant Field Values

Constructor Detail

WalRecordsConsumer

public WalRecordsConsumer(CdcConsumer consumer,
                          IgniteLogger log)

Parameters:

consumer - User provided CDC consumer.

log - Logger.

Method Detail

onRecords

public boolean onRecords(Iterator<DataEntry> entries)

Handles data entries. If this method return true then current offset in WAL and DataEntry index inside DataRecord will be stored and WAL iteration will be started from it on CDC application fail/restart.

Parameters:

entries - Data entries iterator.

Returns:

True if current offset in WAL should be commited.

start

public void start(MetricRegistry cdcReg,
                  MetricRegistry cdcConsumerReg)
           throws IgniteCheckedException

Starts the consumer.

Parameters:

cdcReg - CDC metric registry.

cdcConsumerReg - CDC consumer metric registry.

Throws:

IgniteCheckedException - If failed.

stop

public void stop()

Stops the consumer. This methods can be invoked only after start(MetricRegistry, MetricRegistry).

consumer

public CdcConsumer consumer()

Returns:

Change Data Capture Consumer.

toString

public String toString()

Overrides:

toString in class Object