com.neeve.rog.log

Class RogLogCdcProcessor

java.lang.Object

com.neeve.root.RootObject

com.neeve.rog.RogObject

com.neeve.rog.log.RogLogCdcProcessor

public final class RogLogCdcProcessor
extends RogObject

Performs CDC processing on a log.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RogLogCdcProcessor.Params Contains parameters for CDC processing.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROP_CONFLATE_CHECKPOINTS See RogLogCheckpointReaderParams.PROP_CONFLATE_CHECKPOINTS
static String	PROP_ENTRY_RETENTION_THRESHOLD See RogLogCheckpointReaderParams.PROP_ENTRY_RETENTION_THRESHOLD
static String	PROP_MEM_MAPPED_READ_BUFFER_LOAD See RogLogCheckpointReaderParams.PROP_MEM_MAPPED_READ_BUFFER_LOAD
static String	PROP_MEM_MAPPED_READ_BUFFER_MAX_SIZE See RogLogCheckpointReaderParams.PROP_MEM_MAPPED_READ_BUFFER_MAX_SIZE
static String	PROP_OFF_HEAP_BUFFERING See RogLogCheckpointReaderParams.PROP_OFF_HEAP_BUFFERING
static String	PROP_OFF_HEAP_BUFFERING_LOAD_STRATEGY See RogLogCheckpointReaderParams.PROP_OFF_HEAP_BUFFERING_LOAD_STRATEGY
static String	PROP_SKIP_CDC_CHECKPOINTED See RogLogCheckpointReaderParams.PROP_SKIP_CDC_CHECKPOINTED

Method Summary

Modifier and Type	Method and Description
void	close() Shut the CDC processor down
void	run() Run the CDC processor

Methods inherited from class com.neeve.root.RootObject

getChecked, getThreaded, getTracer

Methods inherited from class java.lang.Object

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

Field Detail

PROP_ENTRY_RETENTION_THRESHOLD

public static final String PROP_ENTRY_RETENTION_THRESHOLD

See RogLogCheckpointReaderParams.PROP_ENTRY_RETENTION_THRESHOLD

See Also:

Constant Field Values

PROP_CONFLATE_CHECKPOINTS

public static final String PROP_CONFLATE_CHECKPOINTS

See RogLogCheckpointReaderParams.PROP_CONFLATE_CHECKPOINTS

See Also:

Constant Field Values

PROP_SKIP_CDC_CHECKPOINTED

public static final String PROP_SKIP_CDC_CHECKPOINTED

See RogLogCheckpointReaderParams.PROP_SKIP_CDC_CHECKPOINTED

See Also:

Constant Field Values

PROP_OFF_HEAP_BUFFERING

public static final String PROP_OFF_HEAP_BUFFERING

See RogLogCheckpointReaderParams.PROP_OFF_HEAP_BUFFERING

See Also:

Constant Field Values

PROP_OFF_HEAP_BUFFERING_LOAD_STRATEGY

public static final String PROP_OFF_HEAP_BUFFERING_LOAD_STRATEGY

See RogLogCheckpointReaderParams.PROP_OFF_HEAP_BUFFERING_LOAD_STRATEGY

See Also:

Constant Field Values

PROP_MEM_MAPPED_READ_BUFFER_LOAD

public static final String PROP_MEM_MAPPED_READ_BUFFER_LOAD

See RogLogCheckpointReaderParams.PROP_MEM_MAPPED_READ_BUFFER_LOAD

See Also:

Constant Field Values

PROP_MEM_MAPPED_READ_BUFFER_MAX_SIZE

public static final String PROP_MEM_MAPPED_READ_BUFFER_MAX_SIZE

See RogLogCheckpointReaderParams.PROP_MEM_MAPPED_READ_BUFFER_MAX_SIZE

See Also:

Constant Field Values

Method Detail

run

public final void run()
               throws Exception

Run the CDC processor

Throws:

Exception

close

public final void close()

Shut the CDC processor down