Package com.illumon.iris.binarystore

Class RollingFileManagerBase<ExpirationType,ExtraType>

java.lang.Object
io.deephaven.enterprise.binlog.channels.RollingFileManagerBase<ExpirationType,ExtraType>
com.illumon.iris.binarystore.RollingFileManagerBase<ExpirationType,ExtraType>
All Implemented Interfaces:
io.deephaven.enterprise.binlog.channels.ChannelManager, io.deephaven.enterprise.binlog.channels.ChannelManagerStandard
Direct Known Subclasses:
RollingFileManager, RollingFileManagerWithDateColumnPartition, RollingFileManagerWithSpecifiedColumnPartition
public abstract class RollingFileManagerBase<ExpirationType,ExtraType> extends io.deephaven.enterprise.binlog.channels.RollingFileManagerBase<ExpirationType,ExtraType> implements io.deephaven.enterprise.binlog.channels.ChannelManagerStandard
Base class for rolling files on a time interval. Extending classes will supply logic for naming files using the expiration managers.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static enum 
    RollingFileManagerBase.ExistingFilePolicy
    Allow different behaviors when an existing output file is seen.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected static final boolean
    FORCE_BEFORE_CLOSE
     
    protected final com.fishlib.io.logger.Logger
    log
     

    Fields inherited from class io.deephaven.enterprise.binlog.channels.RollingFileManagerBase

    baseDir, expiration, headerBuffer, writeChannel

  • Method Summary

    Methods inherited from class io.deephaven.enterprise.binlog.channels.RollingFileManagerBase

    close, flush, getChannelNow, initChannel, isChannelValid, makeFilename, reopenChannel, writeHeader

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.deephaven.enterprise.binlog.channels.ChannelManager

    close, flush

    Methods inherited from interface io.deephaven.enterprise.binlog.channels.ChannelManagerStandard

    getChannel

  • Field Details

    • FORCE_BEFORE_CLOSE

      protected static final boolean FORCE_BEFORE_CLOSE

    • log

      protected final com.fishlib.io.logger.Logger log