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

Class ColumnFileState

java.lang.Object

com.illumon.iris.db.v2.locations.local.ColumnFileState

@InternalUseOnly
public abstract class ColumnFileState
extends Object

A class for tracking the state of individual column files within a Deephaven format table.

Field Summary

Fields

Modifier and Type	Field	Description
static io.deephaven.hash.KeyedObjectKey<ColumnFileTypeDetails,ColumnFileState>	STATE_KEY

Method Summary

Modifier and Type	Method	Description
protected FileAccessor	getBaseAccessor()
ByteOrder	getByteOrder(CheckpointRecord readerCheckpointRecord)
long	getCachedHeaderPrefix()
protected FileAccessor	getDataAccessor()
abstract FileDataBufferStore	getDataBufferStore(CheckpointRecord checkpointRecord)
protected int	getDataStartPosition()
File	getFile()
ColumnFileTypeDetails	getTypeDetails()
protected abstract FileAccessor	makeBaseAccessor()
long	readHeaderPrefix()
static ColumnFileState	readOnly(ColumnFileTypeDetails typeDetails, File directory, String name, boolean hasHeader, Function<ColumnFileType,ColumnFileState> stateLookup)	Get a new ColumnFileState suitable for reading data.
String	toString()
static ColumnFileState	writable(ColumnFileTypeDetails typeDetails, File directory, String name, boolean hasHeader, Function<ColumnFileType,ColumnFileState> stateLookup, WritableLocalTableLocation tableLocation)	Get a new ColumnFileState suitable for writing data.

Methods inherited from class java.lang.Object

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

Field Details

STATE_KEY

public static io.deephaven.hash.KeyedObjectKey<ColumnFileTypeDetails,ColumnFileState> STATE_KEY

Method Details

writable

public static ColumnFileState writable(@NotNull
 ColumnFileTypeDetails typeDetails,
 @NotNull
 File directory,
 @NotNull
 String name,
 boolean hasHeader,
 @NotNull
 Function<ColumnFileType,ColumnFileState> stateLookup,
 @NotNull
 WritableLocalTableLocation tableLocation)

Get a new ColumnFileState suitable for writing data.

Parameters:

typeDetails - the type details

directory - the directory of the data

name - the name of the file

hasHeader - if the file has headers

stateLookup - a function to retrieve ColumnFileStates based on the type

tableLocation - the WritableLocalTableLocation for writing.

Returns:

a new Writable column file state.

readOnly

public static ColumnFileState readOnly(@NotNull
 ColumnFileTypeDetails typeDetails,
 @NotNull
 File directory,
 @NotNull
 String name,
 boolean hasHeader,
 @NotNull
 Function<ColumnFileType,ColumnFileState> stateLookup)

Get a new ColumnFileState suitable for reading data.

Parameters:

typeDetails - the type details

directory - the directory of the data

name - the name of the file

hasHeader - if the file has headers

stateLookup - a function to retrieve ColumnFileStates based on the type

Returns:

a new read-only column file state.

toString

public String toString()

Overrides:

toString in class Object

getBaseAccessor

protected FileAccessor getBaseAccessor()

getTypeDetails

public ColumnFileTypeDetails getTypeDetails()

getFile

public File getFile()

makeBaseAccessor

protected abstract FileAccessor makeBaseAccessor()

getDataAccessor

protected FileAccessor getDataAccessor()

getDataBufferStore

public abstract FileDataBufferStore getDataBufferStore(@NotNull
 CheckpointRecord checkpointRecord)

getByteOrder

public ByteOrder getByteOrder(@NotNull
 CheckpointRecord readerCheckpointRecord)

readHeaderPrefix

public long readHeaderPrefix()

getCachedHeaderPrefix

public long getCachedHeaderPrefix()

getDataStartPosition

protected int getDataStartPosition()