Package com.illumon.iris.binarystore
package com.illumon.iris.binarystore
-
ClassDescriptionThis is the common class for the V1 and V2 binary store readers.Deprecated.Base for V2 binary store readers.AbstractBinaryStoreWriter<R extends Row>This class provides a common ancestor for V1 and V2 binary store writer to manage output channels.A base class for other ExpirationManagers that holds a value and the millis since the epoch until it expires.This class implements binary record entry writing for the V2 binary log format.This class implements row writing for the V2 binary log format.Interface for BinaryStoreImportProcessor to access both V1 and V2 BinaryStores.The BinaryStoreBufferProcessors do not actually read any data, they only consume data passed into them using the setDataBuffer method.Deprecated.V2 Binary Store.Interface for functionality common between BinaryStoreBufferProcessor and the Binary Store Readers.Deprecated.Table reader for Version 2 of the binary store.Extend AbstractBinaryStoreReaderV2 implementation to add a socket channel source.Container class for utility functions related to binary stores.Constant fields written to the V2 binary store.Information extracted from a binary store header.Per-column information extracted from a binary store header.Tool for parsing V2 (and higher) of the binary store header format.Interface for row buffer processors, which are usually generated code to fill and write a row batch data structure.Row buffer processor to use when a real one has not yet been set, and hence rows are unexpected.This class implements the writer for a self-descriptive binary table in the V2 binary log format.A container for binning
WritableRowContainers by column partition in order to enable write batching.Manage writable channels.Interface derived fromChannelManagerfor implementations that determine channels based on supplied column partition values.Interface derived fromChannelManagerfor implementations that determine channels based on internal pre-determined criteria.CloseableStringCache<STRING_LIKE_TYPE extends CharSequence>AStringCachethat isSafeCloseable.Read and write RecordData that are commands.This class represents a command to delete the identified partition.This class represents a command to delete the "current" partition.Wrap a LAS command (as defined in com.illumon.iris.db.v2.logaggregator.CommandHelper.LasInnerCommandId) in a record entry.Returns the current date.Expires on the hour, returning a datetime format of "yyyy-MM-dd.HHmmss.SSSZ" after rolling on the hour.The value contained in this object contains both the date and the hour.Buffer processor for version 2 of the binary store protocol which delegates row buffer consumption to aBinaryStoreV2RowBufferProcessorrather than support the legacyRowGetterapproach.Record handler to use when a real one has not yet been set, and hence records are unexpected.Binary stores consist of Entries, which may be Rows or Records.Implementors of this interface provide Row and Record callbacks.Marker exception when the AbstractBinaryStoreReader encounters an EOF.Manage a value that changes after a certain period of time.Static value - does not expire.Expires on the hour with a datetime format of "yyyy-MM-dd.HHmmss.SSSZ".Utility to print out the contents of a binary store file.Utility to prints out the end of a Binary Store file, optionally following the file as it grows.ChannelManager implementation for binary log files, using dynamic column partition selection.Interface for writing out a binary store v2 record entry.Record.RecordSetter<T extends RecordData>Setter specialization for RecordData.Holds the data payload of a record entry.Deprecated.RollingFileManagerBase<ExpirationType,ExtraType> Base class for rolling files on a time interval.Allow different behaviors when an existing output file is seen.Rolls on the hour, changes the filename base when the column partition changes.Implementation ofRollingFileManagerBasewhich takes one unchanging value for the column partition.RollingFileWriterBase<ExpirationType,ExtraType> Base class for rolling files on a time interval.Interface for writing out values in a row.Per-row transaction flags.RowGetter<T>RowSetter<T>Type-safe interface for setting cell values in individual columns of a row to allow a row to be written.A common error is to update a logger/listener schema without changing the logFormat (Application Version).A table reader that can advance to a given record, return its size, and block instead of returning an EOF.Provider interface forCloseableStringCaches to use in ingestion and data access.StringCacheProviderimplementations to provide a framework for data ingestion.Enumeration of supported types in Iris binary log files.Reads the magic number and selects either a V1 or V2 binary store reader as appropriate.Row-oriented table reading interface.TableWriter<R extends Row>Interface for writing table data out.WritableRowContainer<R extends Row>A container for a Row that supports the concept of release, as well as access to the row itself.