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

Interface Summary

Interface	Description
DataImportChannelItem	Interface for all message types exchanged via the data import protocol.
DataImportChannelProcessorBase	Psuedo base class for channel processors (multiple inheritance would be handy here).
DataImportProcessor	Interface to abstract details of consuming remote file data.
DataImportProcessorBase	Base interface for implementations of DataImportProcessor.
DataImportProcessorFactory	A factory used to create an appropriate DataImportProcessor given a wire value of DataImportFormat and context.
DataImportProfiler.Column	Instrumentation for per-column work as a component of row processing.
DataImportStreamContext	Interface for providing context information to a DataImportProcessor for a single stream of data from a tailer.
IDataImportServer	An interface to expose methods of the DataImportServer that need to be available for mocking in unit tests.
IdDataImportChannelItem	Signalling interface for DataImportChannelItems that have a long ID.
ImportState	Interface for tracking user-specified import state.
MessagePoolAdapter	Simplifying adapter interface for message pools, to allow a message just to take a recycle method reference.
SimpleDataImportStreamProcessor.OnReject	An object defined by the caller, capable of fulfilling SimpleDataImportStreamProcessor.reject(String, Exception)
TableListenerFactory	Given an application version and binary store format, produces a TableListener for processing a binary log stream.

Class Summary

Class	Description
AckMessage	Message sent to acknowledge a DataImportChannelItem.
AckRescanMessage
AckTruncateMessage	Ack for a truncate (or delete) request.
AckTruncateMessage.LocationInfo
BinaryReaderToTableWriter
BinaryStoreImportProcessor	Processes binary store files, with the ability to store headers and resume processing.
CsvImportProcessor	A DataImportProcessor that handles streams of CSV text.
DataImportChannelImpl	Collection of static information and methods for creating DataImportProcessorBases that also are DataImportChannel.ApplicationHandlers.
DataImportChannelProcessor	Process data from at most one concurrent tailer for a given local table location.
DataImportCommandProcessor	Process commands from a client.
DataImportProcessorBaseImpl	Base class for implementations of DataImportProcessor.
DataImportProfiler	Tool to accumulate profiling statistics from a DataImportStreamProcessor.
DataImportServer	Data Import Server: Consumes row-oriented data from log tailers (or similar data sources) and persists Iris' column-oriented table format, simultaneously serving said data consistently to remote table data clients.
DataImportServerCommandChannel	Open a socket to a DataImportServer, in preparation for sending commands.
DataImportStreamProcessor	Base class for streaming connections to the data import server.
DISCommandUtil	Utilities for DIS command channel.
DISCommandUtil.ActionResult	Results of a truncate or delete operation.
DISCommandUtil.ActionResult.DisResult	Result for a single DIS (overall and for all locations)
FilePosition	Data importer protocol protocol message for specifying the a file and byte offset into a stream of log files.
FilePosition.Legacy
ImportStateRowAndSymCounter	Import state that counts rows, and unique "sym" values.
ImportStateRowAndUeCounter	Import state that counts rows, unique "usym" values, and unique "usym" + expiry pairs.
ImportStateRowCounter	Basic import state that counts appended rows.
ImportStateRowSymAndUSymCounter	Import state that counts rows, unique "sym" values, and unique "usym" values.
LogtailerDestinationManager	A LogtailerDestinationManager instance sends data for a fully-defined set of logs to a specific destination.
PayloadDataImportChannelItem	Superclass for data import protocol messages that have a body.
RescanDataItem
SimpleDataImportStreamProcessor
SimpleImportState	Simple ImportState implementation for offline and derived importers.
TableIdentifierDataItem	An DataImportChannelItem holding the information necessary to identify a table location.
TableListenerFactoryImpl	Gets a listener for a particular table and application version.
TruncatePartitionDataItem	Data importer protocol protocol message for specifying a (column) partition to be truncated (or deleted).

Enum Summary

Enum	Description
AckMessage.Result
AckTruncateMessage.LocationResult
CsvImportProcessor.TransactionMode	The mode for which the CSV processor manages transactions
DataImportChannelType	Type enumeration for messages sent over a DataImportChannel.
DataImportFormat	This enum defines all of the supported formats supported by the Data Import Server.
DISCommandUtil.ActionResult.Result
LogtailerDestinationManager.ThreadStatus

Exception Summary

Exception	Description
ChannelException	Exception thrown upon any Data Import channel issue.
ChannelException.Disconnected	Exception thrown upon disconnection.
ChannelException.Rejected	Exception thrown upon receipt of a Reject.
CsvImportProcessor.CSVImportException
LogtailerDestinationManager.FileStateException