Package com.illumon.iris.binarystore

Class RollingFileManagerWithSpecifiedColumnPartition

java.lang.Object

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

com.illumon.iris.binarystore.RollingFileManagerBase<String,Void>

com.illumon.iris.binarystore.RollingFileManagerWithSpecifiedColumnPartition

All Implemented Interfaces:

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

public class RollingFileManagerWithSpecifiedColumnPartition
extends RollingFileManagerBase<String,Void>

Implementation of RollingFileManagerBase which takes one unchanging value for the column partition. It will start a new file at the start of every hour, but the column partition value will never change from the value passed in to the constructor.

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
RollingFileManagerWithSpecifiedColumnPartition(com.fishlib.io.logger.Logger log, String baseDirName, String namespace, String tableName, TableIdentifier.NamespaceSet namespaceSet, String internalPartition, String columnPartition, ByteBuffer headerBuffer, RollingFileManagerBase.ExistingFilePolicy existingFilePolicy, ZoneId zoneId)	Create the file manager with the specified values.

Method Summary

Modifier and Type	Method	Description
GatheringByteChannel	getChannel()
protected String	makeFilename(String 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

RollingFileManagerWithSpecifiedColumnPartition

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

Create the file manager with the specified values.

Parameters:

log - the Logger instance

baseDirName - the directory in which the logs will be written

namespace - the namespace (used to construct the file name)

tableName - the table name (used to construct the file name)

namespaceSet - the namespaceSet (used to construct the file name)

internalPartition - the internal partition value (used to construct the file name)

columnPartition - the column partition value (used to construct the file name)

headerBuffer - the header buffer written to the start of each binary log

existingFilePolicy - the action to take if a file already exists with the determined name

zoneId - the time zone, used to generate the date-time stamp at the end of the file name

Method Details

makeFilename

protected String makeFilename(String value,
 Void ignored)

Specified by:

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

getChannel

public GatheringByteChannel getChannel()
                                throws IOException

Throws:

IOException