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.

  • 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