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

Class StreamAppendableColumn<DATA_TYPE>

java.lang.Object

com.illumon.iris.db.tables.appendable.BaseAppendableColumn<DATA_TYPE>

com.illumon.iris.db.tables.appendable.stream.StreamAppendableColumn<DATA_TYPE>

All Implemented Interfaces:

AppendableColumn<DATA_TYPE>

Direct Known Subclasses:

BlobStreamAppendableColumn, DateTimeStreamAppendableColumn

public class StreamAppendableColumn<DATA_TYPE>
extends BaseAppendableColumn<DATA_TYPE>

AppendableColumn for streaming output to a CurrentByteBufferSink.

Field Summary

Fields inherited from class com.illumon.iris.db.tables.appendable.BaseAppendableColumn

name, type

Fields inherited from interface com.illumon.iris.db.tables.appendable.AppendableColumn

DEFAULT_CHUNK_CAPACITY

Method Summary

Modifier and Type	Method	Description
final void	addByte(byte value)	Append a byte to this column.
final void	addByte(byte value, long count)	Append a byte to this column count times.
final void	addBytes(byte[] values, int startIndex, int length)	Add byte values from an array.
final void	addBytes(ByteBuffer buffer)	Add byte values from a ByteBuffer, starting at buffer.position() and continuing to buffer.limit().
final void	addChar(char value)	Append a char to this column.
final void	addChar(char value, long count)	Append a char to this column count times.
final void	addChars(char[] values, int startIndex, int length)	Add char values from an array.
final void	addDouble(double value)	Append a double to this column.
final void	addDouble(double value, long count)	Append a double to this column count times.
final void	addDoubles(double[] values, int startIndex, int length)	Add double values from an array.
final void	addFloat(float value)	Append a float to this column.
final void	addFloat(float value, long count)	Append a float to this column count times.
final void	addFloats(float[] values, int startIndex, int length)	Add float values from an array.
final void	addFromBooleanChunk(ObjectChunk<Boolean,? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromByteChunk(ByteChunk<? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromCharChunk(CharChunk<? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromDoubleChunk(DoubleChunk<? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromFloatChunk(FloatChunk<? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromIntChunk(IntChunk<? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromLongChunk(LongChunk<? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromObjectChunk(ObjectChunk<DATA_TYPE,? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addFromShortChunk(ShortChunk<? extends Attributes.Values> source)	Add all values from source in the range [0, source.size()).
final void	addInt(int value)	Append a int to this column.
final void	addInt(int value, long count)	Append a int to this column count times.
final void	addInts(int[] values, int startIndex, int length)	Add int values from an array.
final void	addLong(long value)	Append a long to this column.
final void	addLong(long value, long count)	Append a long to this column count times.
final void	addLongs(long[] values, int startIndex, int length)	Add long values from an array.
final void	addShort(short value)	Append a short to this column.
final void	addShort(short value, long count)	Append a short to this column count times.
final void	addShorts(short[] values, int startIndex, int length)	Add short values from an array.
final void	close()	Persist all added data and release any system resources consumed by this column.
final void	force()	Persist all added data.

Methods inherited from class com.illumon.iris.db.tables.appendable.BaseAppendableColumn

add, 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, toString, wait, wait, wait

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

addFromArray, addFromBoxedValue, addFromBoxedValue, addFromChunk, addFromChunkSource, addFromChunkSource, addFromChunkSource, addFromColumnSource, addFromColumnSource, addFromColumnSource, addFromColumnSource, addFromDataColumn

Method Details

force

public final void force()

Description copied from interface: AppendableColumn

Persist all added data.

close

public final void close()

Description copied from interface: AppendableColumn

Persist all added data and release any system resources consumed by this column.

addByte

public final void addByte(byte value)

Description copied from interface: AppendableColumn

Append a byte to this column.

Parameters:

value - The value to append

addChar

public final void addChar(char value)

Description copied from interface: AppendableColumn

Append a char to this column.

Parameters:

value - The value to append

addDouble

public final void addDouble(double value)

Description copied from interface: AppendableColumn

Append a double to this column.

Parameters:

value - The value to append

addFloat

public final void addFloat(float value)

Description copied from interface: AppendableColumn

Append a float to this column.

Parameters:

value - The value to append

addInt

public final void addInt(int value)

Description copied from interface: AppendableColumn

Append a int to this column.

Parameters:

value - The value to append

addLong

public final void addLong(long value)

Description copied from interface: AppendableColumn

Append a long to this column.

Parameters:

value - The value to append

addShort

public final void addShort(short value)

Description copied from interface: AppendableColumn

Append a short to this column.

Parameters:

value - The value to append

addByte

public final void addByte(byte value,
 long count)

Description copied from interface: AppendableColumn

Append a byte to this column count times.

Parameters:

value - The value to append

count - The number of times to append the value

addChar

public final void addChar(char value,
 long count)

Description copied from interface: AppendableColumn

Append a char to this column count times.

Parameters:

value - The value to append

count - The number of times to append the value

addDouble

public final void addDouble(double value,
 long count)

Description copied from interface: AppendableColumn

Append a double to this column count times.

Parameters:

value - The value to append

count - The number of times to append the value

addFloat

public final void addFloat(float value,
 long count)

Description copied from interface: AppendableColumn

Append a float to this column count times.

Parameters:

value - The value to append

count - The number of times to append the value

addInt

public final void addInt(int value,
 long count)

Description copied from interface: AppendableColumn

Append a int to this column count times.

Parameters:

value - The value to append

count - The number of times to append the value

addLong

public final void addLong(long value,
 long count)

Description copied from interface: AppendableColumn

Append a long to this column count times.

Parameters:

value - The value to append

count - The number of times to append the value

addShort

public final void addShort(short value,
 long count)

Description copied from interface: AppendableColumn

Append a short to this column count times.

Parameters:

value - The value to append

count - The number of times to append the value

addBytes

public final void addBytes(@NotNull
 byte[] values,
 int startIndex,
 int length)

Description copied from interface: AppendableColumn

Add byte values from an array.

Parameters:

values - The array of values

startIndex - The index of the first value to add

length - The total number of values to add

addBytes

public final void addBytes(@NotNull
 ByteBuffer buffer)

Description copied from interface: AppendableColumn

Add byte values from a ByteBuffer, starting at buffer.position() and continuing to buffer.limit().

Parameters:

buffer - The buffer

addChars

public final void addChars(@NotNull
 char[] values,
 int startIndex,
 int length)

Description copied from interface: AppendableColumn

Add char values from an array.

Parameters:

values - The array of values

startIndex - The index of the first value to add

length - The total number of values to add

addDoubles

public final void addDoubles(@NotNull
 double[] values,
 int startIndex,
 int length)

Description copied from interface: AppendableColumn

Add double values from an array.

Parameters:

values - The array of values

startIndex - The index of the first value to add

length - The total number of values to add

addFloats

public final void addFloats(@NotNull
 float[] values,
 int startIndex,
 int length)

Description copied from interface: AppendableColumn

Add float values from an array.

Parameters:

values - The array of values

startIndex - The index of the first value to add

length - The total number of values to add

addInts

public final void addInts(@NotNull
 int[] values,
 int startIndex,
 int length)

Description copied from interface: AppendableColumn

Add int values from an array.

Parameters:

values - The array of values

startIndex - The index of the first value to add

length - The total number of values to add

addLongs

public final void addLongs(@NotNull
 long[] values,
 int startIndex,
 int length)

Description copied from interface: AppendableColumn

Add long values from an array.

Parameters:

values - The array of values

startIndex - The index of the first value to add

length - The total number of values to add

addShorts

public final void addShorts(@NotNull
 short[] values,
 int startIndex,
 int length)

Description copied from interface: AppendableColumn

Add short values from an array.

Parameters:

values - The array of values

startIndex - The index of the first value to add

length - The total number of values to add

addFromBooleanChunk

public final void addFromBooleanChunk(@NotNull
 ObjectChunk<Boolean,? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source ObjectChunk

addFromByteChunk

public final void addFromByteChunk(@NotNull
 ByteChunk<? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source ByteChunk

addFromCharChunk

public final void addFromCharChunk(@NotNull
 CharChunk<? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source CharChunk

addFromDoubleChunk

public final void addFromDoubleChunk(@NotNull
 DoubleChunk<? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source DoubleChunk

addFromFloatChunk

public final void addFromFloatChunk(@NotNull
 FloatChunk<? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source FloatChunk

addFromIntChunk

public final void addFromIntChunk(@NotNull
 IntChunk<? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source IntChunk

addFromLongChunk

public final void addFromLongChunk(@NotNull
 LongChunk<? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source LongChunk

addFromShortChunk

public final void addFromShortChunk(@NotNull
 ShortChunk<? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source ShortChunk

addFromObjectChunk

public final void addFromObjectChunk(@NotNull
 ObjectChunk<DATA_TYPE,? extends Attributes.Values> source)

Description copied from interface: AppendableColumn

Add all values from source in the range [0, source.size()).

Parameters:

source - The source ObjectChunk