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

Description copied from interface: DataImportStreamContext

Get the schema service.

Specified by:

getSchemaService in interface DataImportStreamContext

Returns:

the schema service