Package org.apache.druid.frame.write.columnar

Class StringFrameColumnWriter<T extends ColumnValueSelector>

java.lang.Object

org.apache.druid.frame.write.columnar.StringFrameColumnWriter<T>

All Implemented Interfaces:

Closeable, AutoCloseable, FrameColumnWriter

public abstract class StringFrameColumnWriter<T extends ColumnValueSelector>
extends Object
implements FrameColumnWriter

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DATA_OFFSET
protected boolean	encounteredMultiValueRow
static final byte	MULTI_VALUE_BYTE
static final long	MULTI_VALUE_POSITION
protected final ColumnCapabilities.Capable	multiValue

Method Summary

Modifier and Type	Method	Description
boolean	addSelection()	Adds the current value to the writer
void	close()
abstract List<ByteBuffer>	getUtf8ByteBuffersFromSelector(T selector)	Extracts a list of ByteBuffers from the selector.
long	size()	Size (in bytes) of the column data that will get written when FrameColumnWriter.writeTo(org.apache.datasketches.memory.WritableMemory, long) will be called
void	undo()	Reverts the last added value.
long	writeTo(org.apache.datasketches.memory.WritableMemory memory, long startPosition)	Writes the value of the column to the provided memory at the given position

Methods inherited from class java.lang.Object

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

Field Details

DATA_OFFSET

public static final long DATA_OFFSET

See Also:

• Constant Field Values

MULTI_VALUE_BYTE

public static final byte MULTI_VALUE_BYTE

See Also:

• Constant Field Values

MULTI_VALUE_POSITION

public static final long MULTI_VALUE_POSITION

See Also:

• Constant Field Values

multiValue

protected final ColumnCapabilities.Capable multiValue

encounteredMultiValueRow

protected boolean encounteredMultiValueRow

Method Details

addSelection

public boolean addSelection()

Description copied from interface: FrameColumnWriter

Adds the current value to the writer

Specified by:

addSelection in interface FrameColumnWriter

undo

public void undo()

Description copied from interface: FrameColumnWriter

Reverts the last added value. Undo calls cannot be called in successsion

Specified by:

undo in interface FrameColumnWriter

size

public long size()

Description copied from interface: FrameColumnWriter

Size (in bytes) of the column data that will get written when FrameColumnWriter.writeTo(org.apache.datasketches.memory.WritableMemory, long) will be called

Specified by:

size in interface FrameColumnWriter

writeTo

public long writeTo(org.apache.datasketches.memory.WritableMemory memory,
 long startPosition)

Description copied from interface: FrameColumnWriter

Writes the value of the column to the provided memory at the given position

Specified by:

writeTo in interface FrameColumnWriter

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface FrameColumnWriter

getUtf8ByteBuffersFromSelector

@Nullable
public abstract List<ByteBuffer> getUtf8ByteBuffersFromSelector(T selector)

Extracts a list of ByteBuffers from the selector. Null values are returned as FrameWriterUtils.NULL_STRING_MARKER_ARRAY.