com.neeve.rog.log

Class RogLogCdcProcessor.Params

java.lang.Object

com.neeve.rog.log.RogLogCheckpointReaderParams

com.neeve.rog.log.RogLogCdcProcessor.Params

Enclosing class:

RogLogCdcProcessor

public static final class RogLogCdcProcessor.Params
extends RogLogCheckpointReaderParams

Contains parameters for CDC processing.

CDC parameters are set as properties in the StorePersisterDescriptor prefixed with 'cdc.' The paramateres may be set with StorePersisterDescriptor.setCdcProperty(String, String).

Nested Class Summary

Nested classes/interfaces inherited from class com.neeve.rog.log.RogLogCheckpointReaderParams

RogLogCheckpointReaderParams.OffheapBufferingLoadStrategy

Field Summary

Fields inherited from class com.neeve.rog.log.RogLogCheckpointReaderParams

PROP_CONFLATE_CHECKPOINTS, PROP_CONFLATE_CHECKPOINTS_DEFAULT, PROP_ENTRY_RETENTION_THRESHOLD, PROP_ENTRY_RETENTION_THRESHOLD_DEFAULT, PROP_MEM_MAPPED_READ_BUFFER_LOAD, PROP_MEM_MAPPED_READ_BUFFER_LOAD_DEFAULT, PROP_MEM_MAPPED_READ_BUFFER_MAX_SIZE, PROP_MEM_MAPPED_READ_BUFFER_MAX_SIZE_DEFAULT, PROP_OFF_HEAP_BUFFERING, PROP_OFF_HEAP_BUFFERING_DEFAULT, PROP_OFF_HEAP_BUFFERING_LOAD_STRATEGY, PROP_OFF_HEAP_BUFFERING_LOAD_STRATEGY_DEFAULT, PROP_OFF_HEAP_BUFFERING_MAX_PAGE_SIZE, PROP_OFF_HEAP_BUFFERING_MAX_PAGE_SIZE_DEFAULT, PROP_SKIP_CDC_CHECKPOINTED, PROP_SKIP_CDC_CHECKPOINTED_DEFAULT

Method Summary

Methods

Modifier and Type	Method and Description
static RogLogCdcProcessor.Params	create(Properties props) Loads cdc parameters from the give set of log descriptor properties.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static final RogLogCdcProcessor.Params create(Properties props)

Loads cdc parameters from the give set of log descriptor properties.

This method looks for cdc properties identifed with with the "cdc." prefix.

Parameters:

props - The properties to load from

Returns:

The parsed properties.