Package com.illumon.iris.db.tables.dataimport.logtailer
package com.illumon.iris.db.tables.dataimport.logtailer
-
ClassDescriptionMessage sent to acknowledge a DataImportChannelItem.Ack for a truncate (or delete) request.Processes binary store files, with the ability to store headers and resume processing.Exception thrown upon any Data Import channel issue.Exception thrown upon disconnection.Exception thrown upon receipt of a Reject.A
DataImportProcessorthat handles streams of CSV text.The mode for which the CSV processor manages transactionsCollection of static information and methods for creatingDataImportProcessorBases that also areDataImportChannel.ApplicationHandlers.Interface for all message types exchanged via the data import protocol.Process data from at most one concurrent tailer for a given local table location.Psuedo base class for channel processors (multiple inheritance would be handy here).Type enumeration for messages sent over aDataImportChannel.Process commands from a client.This enum defines all of the supported formats supported by the Data Import Server.Interface to abstract details of consuming remote file data.Base interface for implementations of DataImportProcessor.Base class for implementations of DataImportProcessor.A factory used to create an appropriateDataImportProcessorgiven a wire value ofDataImportFormatandcontext.Tool to accumulate profiling statistics from aDataImportStreamProcessor.Instrumentation for per-column work as a component of row processing.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.Open a socket to a DataImportServer, in preparation for sending commands.Interface for providing context information to aDataImportProcessorfor a single stream of data from a tailer.Base class for streaming connections to the data import server.Utilities for DIS command channel.Results of a truncate or delete operation.Result for a single DIS (overall and for all locations)Result of a single DISData importer protocol message for specifying a file and byte offset into a stream of log files.An interface to expose methods of the DataImportServer that need to be available for mocking in unit tests.Signalling interface for DataImportChannelItems that have a long ID.Interface for tracking user-specified import state.ImportStatePartitionIndex<KEY_TYPE>Import state that counts rows, and unique "sym" values.Import state that counts rows, unique "usym" values, and unique "usym" + expiry pairs.Basic import state that counts appended rows.Import state that counts rows, unique "sym" values, and unique "usym" values.Static class providing access to settings that control the tailer and the DIS, primarily buffer sizes and pooling behavior.A LogtailerDestinationManager instance sends data for a fully-defined set of logs to a specific destination.Utility to passively collect binlog files, and delete them after a specified period of inactivity.Simplifying adapter interface for message pools, to allow a message just to take a recycle method reference.Superclass for data import protocol messages that have a body.An object defined by the caller, capable of fulfillingSimpleDataImportStreamProcessor.reject(String, Exception)Simple ImportState implementation for offline and derived importers.AnDataImportChannelItemholding the information necessary to identify a table location.Given an application version and binary store format, produces aTableListenerfor processing a binary log stream.Gets a listener for a particular table and application version.Data importer protocol protocol message for specifying a (column) partition to be truncated (or deleted).