Package com.illumon.iris.db.v2.locations

Class CheckpointDrivenFileDataBufferStore

java.lang.Object

com.illumon.iris.db.v2.locations.FileDataBufferStore

com.illumon.iris.db.v2.locations.CheckpointDrivenFileDataBufferStore

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, CheckpointRecord.DataFileSizeRecord, CheckpointRecord.MutableFileSizeRecord, CheckpointRecord.SourceFileSizeRecord

public class CheckpointDrivenFileDataBufferStore
extends FileDataBufferStore
implements CheckpointRecord.MutableFileSizeRecord

A FileDataBufferStore that gets file sizes from a checkpoint record, and never directly from disk.

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.locations.FileDataBufferStore

FileDataBufferStore.StoredBufferMessage

Field Summary

Fields inherited from class com.illumon.iris.db.v2.locations.FileDataBufferStore

NULL_PENDING_POSITION, size

Constructor Summary

Constructors

Constructor	Description
CheckpointDrivenFileDataBufferStore(FileAccessor fileAccessor, ByteOrder byteOrder, long initialSize, String fileName)	Construct a CheckpointDrivenFileDataBufferStore.

Method Summary

Modifier and Type	Method	Description
default com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
void	ensureFileExists()	Ensure the underlying file exists.
void	ensureSize(long requiredSize)	Make sure size is large enough to accommodate a request.
protected void	extend(long newSize)	Inform this store of an observed change in the file data size.
String	getName()
long	getSize()
void	setSize(long newSize)

Methods inherited from class com.illumon.iris.db.v2.locations.FileDataBufferStore

acceptBufferByIndex, disableReleaseTracking, enableReleaseTracking, force, getMessageViewByOffset, getUpdatedSize, promotePending, provideBufferReferenceByIndex, releaseCachedResources, revertPending, size, toString

Methods inherited from class java.lang.Object

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

Constructor Details

CheckpointDrivenFileDataBufferStore

public CheckpointDrivenFileDataBufferStore(@NotNull
 FileAccessor fileAccessor,
 @NotNull
 ByteOrder byteOrder,
 long initialSize,
 @NotNull
 String fileName)

Construct a CheckpointDrivenFileDataBufferStore.

Parameters:

fileAccessor - An accessor for the file (or file region) that we're presenting a buffered view of

byteOrder - The byte order that should be used for all buffers in this store

initialSize - Initially known visible size of the underlying file (or file region)

fileName - name of the file (for DataFileSizeRecord lookup in the checkpointRecord)

Method Details

getName

public String getName()

getSize

public long getSize()

setSize

public void setSize(long newSize)

Specified by:

setSize in interface CheckpointRecord.MutableFileSizeRecord

extend

protected void extend(long newSize)

Description copied from class: FileDataBufferStore

Inform this store of an observed change in the file data size.

Overrides:

extend in class FileDataBufferStore

Parameters:

newSize - The new size

ensureSize

public void ensureSize(long requiredSize)

Description copied from class: FileDataBufferStore

Make sure size is large enough to accommodate a request. Call before proceeding with any request.

Overrides:

ensureSize in class FileDataBufferStore

Parameters:

requiredSize - The size required by the caller in order to make progress

ensureFileExists

public void ensureFileExists()

Description copied from class: FileDataBufferStore

Ensure the underlying file exists.

Overrides:

ensureFileExists in class FileDataBufferStore

append

default com.fishlib.base.log.LogOutput append(@NotNull
 com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface com.fishlib.base.log.LogOutputAppendable