Class SymbolLocalAppendableColumn<SYMBOL_TYPE extends CharSequence,DATA_TYPE extends CharSequence>
java.lang.Object
com.illumon.iris.db.tables.appendable.BaseAppendableColumn<DATA_TYPE>
com.illumon.iris.db.tables.appendable.local.LocalAppendableColumn<DATA_TYPE>
com.illumon.iris.db.tables.appendable.local.SymbolManagerLocalAppendableColumn<SYMBOL_TYPE,DATA_TYPE>
com.illumon.iris.db.tables.appendable.local.SymbolLocalAppendableColumn<SYMBOL_TYPE,DATA_TYPE>
- All Implemented Interfaces:
AppendableColumn<DATA_TYPE>
,BufferedAppendable
,BufferedAppendableColumn<DATA_TYPE>
,TableTransactionProcessor
public class SymbolLocalAppendableColumn<SYMBOL_TYPE extends CharSequence,DATA_TYPE extends CharSequence> extends SymbolManagerLocalAppendableColumn<SYMBOL_TYPE,DATA_TYPE>
AppendableColumn for outputting symbol-mapped CharSequences to a local column location.
-
Nested Class Summary
Nested classes/interfaces inherited from class com.illumon.iris.db.tables.appendable.local.LocalAppendableColumn
LocalAppendableColumn.ValueSupplier<DATA_TYPE>
-
Field Summary
Fields inherited from interface com.illumon.iris.db.tables.appendable.AppendableColumn
DEFAULT_CHUNK_CAPACITY
-
Method Summary
Modifier and Type Method Description void
add(DATA_TYPE value)
Append a DATA_TYPE to this column.void
addComputed(int count, LocalAppendableColumn.ValueSupplier<DATA_TYPE> valueSupplier)
Add values computed on demand from a function over an int value index.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
release()
Release any resources held.Methods inherited from class com.illumon.iris.db.tables.appendable.local.SymbolManagerLocalAppendableColumn
doneAppending, flush, force
Methods inherited from class com.illumon.iris.db.tables.appendable.local.LocalAppendableColumn
abortTransaction, addByte, addByte, addBytes, addBytes, addChar, addChar, addChars, addDouble, addDouble, addDoubles, addEncoded, addFloat, addFloat, addFloats, addFromBooleanChunk, addFromByteChunk, addFromCharChunk, addFromDoubleChunk, addFromFloatChunk, addFromIntChunk, addFromLongChunk, addFromObjectChunk, addFromShortChunk, addInt, addInt, addInts, addLong, addLong, addLongs, addShort, addShort, addShorts, finishTransaction, inTransaction, startTransaction, toString
Methods inherited from class com.illumon.iris.db.tables.appendable.BaseAppendableColumn
add, add, addBoolean, addBoolean, addBooleans, checkArrayAddBounds, encodeExternalizable, encodeSerializable, getAddHelper, getName, getType
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.AppendableColumn
add, add, addBoolean, addBoolean, addBooleans, addFromArray, addFromBoxedValue, addFromBoxedValue, addFromChunk, addFromChunkSource, addFromChunkSource, addFromChunkSource, addFromColumnSource, addFromColumnSource, addFromColumnSource, addFromColumnSource, addFromDataColumn, getAddHelper, getName, getType
Methods inherited from interface com.illumon.iris.db.tables.appendable.BufferedAppendable
maybeForce, prepareCheckpoint
-
Method Details
-
add
Description copied from interface:AppendableColumn
Append a DATA_TYPE to this column.- Specified by:
add
in interfaceAppendableColumn<SYMBOL_TYPE extends CharSequence>
- Overrides:
add
in classBaseAppendableColumn<DATA_TYPE extends CharSequence>
- Parameters:
value
- The value to append
-
addComputed
public final void addComputed(int count, @NotNull LocalAppendableColumn.ValueSupplier<DATA_TYPE> valueSupplier) throws IOExceptionDescription copied from class:LocalAppendableColumn
Add values computed on demand from a function over an int value index. Note that this is generally sub-optimal for columns of primitive types.- Overrides:
addComputed
in classLocalAppendableColumn<DATA_TYPE extends CharSequence>
- Parameters:
count
- The number of values to addvalueSupplier
- The value supplier, over domain[0, length)
- Throws:
IOException
-
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 asynchronousBufferedAppendable.force()
operations. ABufferedAppendable.release()
is appropriate afterwards, especially on error.- Specified by:
close
in interfaceAppendableColumn<SYMBOL_TYPE extends CharSequence>
- Specified by:
close
in interfaceBufferedAppendable
- Overrides:
close
in classSymbolManagerLocalAppendableColumn<SYMBOL_TYPE extends CharSequence,DATA_TYPE extends CharSequence>
-
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 asynchronousBufferedAppendable.force()
operations.- Specified by:
release
in interfaceBufferedAppendable
- Overrides:
release
in classSymbolManagerLocalAppendableColumn<SYMBOL_TYPE extends CharSequence,DATA_TYPE extends CharSequence>
-