Package com.illumon.iris.db.tables.dataimport.logtailer

Class DataImportProcessorBaseImpl

java.lang.Object

com.illumon.iris.db.tables.dataimport.logtailer.DataImportProcessorBaseImpl

All Implemented Interfaces:

DataImportProcessorBase

Direct Known Subclasses:

DataImportCommandProcessor, DataImportStreamProcessor

public abstract class DataImportProcessorBaseImpl
extends Object
implements DataImportProcessorBase

Base class for implementations of DataImportProcessor. This includes Streaming and Command variants.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	CHECKPOINT_INTERVAL_MILLIS_SUFFIX
protected final com.illumon.iris.db.tables.dataimport.logtailer.DataImportStreamProcessor.Directory	dataStreamProcessorDirectory	Tracked to allow more efficient generation of connection details
protected static final String	DISP_DEFAULT_PREFIX
protected static final String	DISP_PREFIX	Prefix for all the DataImportProcessorBase default properties
protected static final String	FLUSH_INTERVAL_SUFFIX
protected final com.fishlib.io.logger.Logger	log	A place to log informational messages.
protected final String	logPrefix	A prefix for informational messages.
protected static final String	MAX_SHUTDOWN_DELAY_MILLIS_SUFFIX
protected static final String	PROFILING_LEVEL_SUFFIX
protected final SchemaService	schemaService	Schema service for listener lookup.

Method Summary

Modifier and Type	Method	Description
com.fishlib.io.logger.Logger	getLog()	Get the log: A place to log informational messages.
String	getLogPrefix()	Get the logPrefix: A prefix for informational messages.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.tables.dataimport.logtailer.DataImportProcessorBase

shutdown

Field Details

DISP_PREFIX

protected static final String DISP_PREFIX

Prefix for all the DataImportProcessorBase default properties

See Also:

• Constant Field Values

DISP_DEFAULT_PREFIX

protected static final String DISP_DEFAULT_PREFIX

See Also:

• Constant Field Values

FLUSH_INTERVAL_SUFFIX

protected static final String FLUSH_INTERVAL_SUFFIX

See Also:

• Constant Field Values

CHECKPOINT_INTERVAL_MILLIS_SUFFIX

protected static final String CHECKPOINT_INTERVAL_MILLIS_SUFFIX

See Also:

• Constant Field Values

MAX_SHUTDOWN_DELAY_MILLIS_SUFFIX

protected static final String MAX_SHUTDOWN_DELAY_MILLIS_SUFFIX

See Also:

• Constant Field Values

PROFILING_LEVEL_SUFFIX

protected static final String PROFILING_LEVEL_SUFFIX

See Also:

• Constant Field Values

log

protected final com.fishlib.io.logger.Logger log

A place to log informational messages.

logPrefix

protected final String logPrefix

A prefix for informational messages.

schemaService

protected final SchemaService schemaService

Schema service for listener lookup.

dataStreamProcessorDirectory

protected final com.illumon.iris.db.tables.dataimport.logtailer.DataImportStreamProcessor.Directory dataStreamProcessorDirectory

Tracked to allow more efficient generation of connection details

Method Details

getLog

public com.fishlib.io.logger.Logger getLog()

Get the log: A place to log informational messages.

Specified by:

getLog in interface DataImportProcessorBase

getLogPrefix

public String getLogPrefix()

Get the logPrefix: A prefix for informational messages.

Specified by:

getLogPrefix in interface DataImportProcessorBase