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

Class DataImportStreamProcessor.Context

java.lang.Object

com.illumon.iris.db.tables.dataimport.logtailer.DataImportStreamProcessor.Context

All Implemented Interfaces:

DataImportStreamContext

Enclosing class:

DataImportStreamProcessor

public class DataImportStreamProcessor.Context
extends Object
implements DataImportStreamContext

A context object to pass commonly used information down to individual processors

Method Summary

Modifier and Type	Method	Description
Map<String,String>	getImportMetadata()	Get the metadata for the stream.
IWritableLocalTableLocation	getLocation()	Get the table location for the stream.
String	getLogPrefix()	Get the prefix to append to log lines.
Object	getProcessingLock()	Get the object to use for synchronization during processing.
DataImportProfiler	getProfiler()	Get the DataImportProfiler for the stream.
SchemaService	getSchemaService()	Get the schema service.
FullTableLocationKey	getStreamKey()	Get the FullTableLocationKey for the stream.
TableDefinition	getTableDefinition()	Get the Table definition to use for the stream.
LocalTableWriter	getTableWriter()	Get the LocalTableWriter for the stream using the default TableDefinition (equivalent to the one provided by DataImportStreamContext.getTableDefinition()).
LocalTableWriter	getTableWriter(boolean forceRowSupport, TableDefinition listenerOutputDefinition)	Get the LocalTableWriter for the stream using the provided TableDefinition.
LocalTableWriter	getTableWriter(TableDefinition listenerOutputDefinition)	Get the LocalTableWriter for the stream using the provided TableDefinition.

Methods inherited from class java.lang.Object

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

Method Details

getLocation

@NotNull
public IWritableLocalTableLocation getLocation()

Description copied from interface: DataImportStreamContext

Get the table location for the stream.

Specified by:

getLocation in interface DataImportStreamContext

Returns:

The table location for the stream

getTableWriter

@NotNull
public LocalTableWriter getTableWriter()

Description copied from interface: DataImportStreamContext

Get the LocalTableWriter for the stream using the default TableDefinition (equivalent to the one provided by DataImportStreamContext.getTableDefinition()).

Callers must hold the processing lock (see DataImportStreamContext.getProcessingLock()).

Specified by:

getTableWriter in interface DataImportStreamContext

Returns:

The LocalTableWriter for the stream

getTableWriter

@NotNull
public LocalTableWriter getTableWriter(@NotNull
 TableDefinition listenerOutputDefinition)

Description copied from interface: DataImportStreamContext

Get the LocalTableWriter for the stream using the provided TableDefinition.

Callers must hold the processing lock (see DataImportStreamContext.getProcessingLock()).

Specified by:

getTableWriter in interface DataImportStreamContext

Parameters:

listenerOutputDefinition - A definition specifying the columns to be written

Returns:

The LocalTableWriter for the stream

getTableWriter

@NotNull
public LocalTableWriter getTableWriter(boolean forceRowSupport,
 @NotNull
 TableDefinition listenerOutputDefinition)

Description copied from interface: DataImportStreamContext

Get the LocalTableWriter for the stream using the provided TableDefinition. Allows ability to force row support.

Callers must hold the processing lock (see DataImportStreamContext.getProcessingLock()).

Specified by:

getTableWriter in interface DataImportStreamContext

Parameters:

forceRowSupport - Should be true for binary format V1 loggers to force single row support in returned LocalTableWriter

listenerOutputDefinition - A definition specifying the columns to be written

Returns:

The LocalTableWriter for the stream

getStreamKey

@NotNull
public FullTableLocationKey getStreamKey()

Description copied from interface: DataImportStreamContext

Get the FullTableLocationKey for the stream.

Specified by:

getStreamKey in interface DataImportStreamContext

Returns:

The table location key for the stream

getProfiler

public DataImportProfiler getProfiler()

Description copied from interface: DataImportStreamContext

Get the DataImportProfiler for the stream.

Specified by:

getProfiler in interface DataImportStreamContext

Returns:

The data import profiler for the stream

getProcessingLock

@NotNull
public Object getProcessingLock()

Description copied from interface: DataImportStreamContext

Get the object to use for synchronization during processing.

Specified by:

getProcessingLock in interface DataImportStreamContext

Returns:

The object to synchronize during data processing

getLogPrefix

@NotNull
public String getLogPrefix()

Description copied from interface: DataImportStreamContext

Get the prefix to append to log lines.

Specified by:

getLogPrefix in interface DataImportStreamContext

Returns:

The prefix to prepend to log lines

getTableDefinition

@NotNull
public TableDefinition getTableDefinition()

Description copied from interface: DataImportStreamContext

Get the Table definition to use for the stream.

Specified by:

getTableDefinition in interface DataImportStreamContext

Returns:

The table definition for the stream

getImportMetadata

@NotNull
public Map<String,String> getImportMetadata()

Description copied from interface: DataImportStreamContext

Get the metadata for the stream.

Specified by:

getImportMetadata in interface DataImportStreamContext

Returns:

The map of metadata for processor use

getSchemaService

@NotNull
public SchemaService getSchemaService()

Description copied from interface: DataImportStreamContext

Get the schema service.

Specified by:

getSchemaService in interface DataImportStreamContext

Returns:

the schema service