Package com.illumon.iris.db.tables.appendable.symbolmanagers

Class AppendableSymbolManager<STRING_LIKE_TYPE>

java.lang.Object

com.illumon.iris.db.tables.appendable.symbolmanagers.AppendableSymbolManager<STRING_LIKE_TYPE>

All Implemented Interfaces:

BufferedAppendable, SymbolManager<STRING_LIKE_TYPE>

Direct Known Subclasses:

BoundedAppendableSymbolManager, StrictAppendableSymbolManager

public abstract class AppendableSymbolManager<STRING_LIKE_TYPE>
extends Object
implements SymbolManager<STRING_LIKE_TYPE>, BufferedAppendable

Abstract parent for symbol managers that grow their mapping tables by appending to a column.

Method Summary

Modifier and Type	Method	Description
void	close()	Flush all appended data to the underlying store, release any resources held, and force all appended data to be persisted to permanent storage.
void	doneAppending()	See BufferedAppendableColumn.doneAppending() for reference.
void	ensureFileExists()	Ensure the file for this column exists.
void	flush()	Write all appended data to the underlying store and prepare for subsequent writes.
void	force()	Force all flushed data to be persisted to permanent storage.
void	release()	Release any resources held.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.tables.appendable.BufferedAppendable

maybeForce, prepareCheckpoint

Methods inherited from interface com.illumon.iris.db.tables.utils.SymbolManager

getSymbolId

Method Details

toString

public String toString()

Overrides:

toString in class Object

flush

public void flush()

Description copied from interface: BufferedAppendable

Write all appended data to the underlying store and prepare for subsequent writes. Does not imply BufferedAppendable.force().

Specified by:

flush in interface BufferedAppendable

force

public void force()

Description copied from interface: BufferedAppendable

Force all flushed data to be persisted to permanent storage. Will consistently and atomically persist the last prepared checkpoint in implementations that implement BufferedAppendable.prepareCheckpoint(). Does not imply BufferedAppendable.flush(), as this is a distinct operation in all implementations. May be called concurrently by threads other than the "writing thread".

Specified by:

force in interface BufferedAppendable

doneAppending

public void doneAppending()

See BufferedAppendableColumn.doneAppending() for reference.

close

public void close()

Description copied from interface: BufferedAppendable

Flush all appended data to the underlying store, release any resources held, and force all appended data to be persisted to permanent storage. This should be the final access to this appendable (if successful) with the exception of any asynchronous BufferedAppendable.force() operations. A BufferedAppendable.release() is appropriate afterwards, especially on error.

Specified by:

close in interface BufferedAppendable

release

public void release()

Description copied from interface: BufferedAppendable

Release any resources held. Called after an error in preparation for termination. For external callers, this should be done as the final access to this column with the exception of any asynchronous BufferedAppendable.force() operations.

Specified by:

release in interface BufferedAppendable

ensureFileExists

public void ensureFileExists()

Ensure the file for this column exists.