Package com.illumon.iris.binarystore

Class RollingFileManagerWithDateColumnPartition

java.lang.Object

io.deephaven.enterprise.binlog.channels.RollingFileManagerBase<ExpirationType,ExtraType>

com.illumon.iris.binarystore.RollingFileManagerBase<io.deephaven.enterprise.binlog.channels.DayAndHourExpiration.DateAndHour,Void>

com.illumon.iris.binarystore.RollingFileManagerWithDateColumnPartition

All Implemented Interfaces:

io.deephaven.enterprise.binlog.channels.ChannelManager, io.deephaven.enterprise.binlog.channels.ChannelManagerStandard

public class RollingFileManagerWithDateColumnPartition
extends RollingFileManagerBase<io.deephaven.enterprise.binlog.channels.DayAndHourExpiration.DateAndHour,Void>

Rolls on the hour, changes the filename base when the column partition changes.

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.binarystore.RollingFileManagerBase

RollingFileManagerBase.ExistingFilePolicy

Field Summary

Fields inherited from class com.illumon.iris.binarystore.RollingFileManagerBase

FORCE_BEFORE_CLOSE, log

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

baseDir, expiration, headerBuffer, writeChannel

Constructor Summary

Constructors

Constructor	Description
RollingFileManagerWithDateColumnPartition(com.fishlib.io.logger.Logger log, String baseDirName, String namespace, String tableName, TableIdentifier.NamespaceSet namespaceSet, String internalPartition, ByteBuffer headerBuffer, RollingFileManagerBase.ExistingFilePolicy existingFilePolicy, ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
GatheringByteChannel	getChannel()
protected String	makeFilename(io.deephaven.enterprise.binlog.channels.DayAndHourExpiration.DateAndHour value, Void ignored)

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

close, flush, getChannelNow, initChannel, isChannelValid, 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

Constructor Details

RollingFileManagerWithDateColumnPartition

public RollingFileManagerWithDateColumnPartition(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 String baseDirName,
 @NotNull
 String namespace,
 @NotNull
 String tableName,
 @NotNull
 TableIdentifier.NamespaceSet namespaceSet,
 @NotNull
 String internalPartition,
 @NotNull
 ByteBuffer headerBuffer,
 @NotNull
 RollingFileManagerBase.ExistingFilePolicy existingFilePolicy,
 @NotNull
 ZoneId zoneId)

Method Details

makeFilename

protected String makeFilename(io.deephaven.enterprise.binlog.channels.DayAndHourExpiration.DateAndHour value,
 Void ignored)

Specified by:

makeFilename in class io.deephaven.enterprise.binlog.channels.RollingFileManagerBase<io.deephaven.enterprise.binlog.channels.DayAndHourExpiration.DateAndHour,Void>

getChannel

public GatheringByteChannel getChannel()
                                throws IOException

Throws:

IOException