Package com.illumon.iris.binarystore

Class BinaryRowV2

java.lang.Object

com.illumon.iris.binarystore.BinaryRowV2

All Implemented Interfaces:

Row

public class BinaryRowV2
extends Object
implements Row

This class implements row writing for the V2 binary log format.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	BinaryRowV2.BinaryStoreRowSetter<T>
class	BinaryRowV2.FlagSetter

Nested classes/interfaces inherited from interface com.illumon.iris.binarystore.Row

Row.Flags

Field Summary

Fields

Modifier and Type	Field	Description
protected ByteBuffer	dataBuffer
protected Map<String,BinaryRowV2.BinaryStoreRowSetter>	setters
protected BinaryStoreWriterV2	writer

Constructor Summary

Constructors

Constructor	Description
BinaryRowV2(BinaryStoreWriterV2 writer, String[] columnNames, SupportedType[] columnTypes, Object[] typeMetadata)

Method Summary

Modifier and Type	Method	Description
String	getColumnPartitionValue()	For rows that are to be used with file managers that allow dynamic column partition selection, retrieve the column partition value.
BinaryRowV2.FlagSetter	getFlagSetter()
RowSetter	getSetter(String name)	Gets a setter for a column.
ByteBuffer	populateBuffer()	Populate the internal data buffer with column values.
void	reset()	Reset the internal buffer.
void	setColumnPartitionValue(String columnPartitionValue)	For rows that are to be used with file managers that allow dynamic column partition selection, set the column partition value.
void	setFlags(Row.Flags flags)
protected void	writeAndReset()	Write a row to the underlying stream and reset the internal buffer.
void	writeRow()	Writes out a new row (values set using setters).

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.binarystore.Row

getSetter

Field Details

writer

protected final BinaryStoreWriterV2 writer

dataBuffer

protected ByteBuffer dataBuffer

setters

protected final Map<String,BinaryRowV2.BinaryStoreRowSetter> setters

Constructor Details

BinaryRowV2

public BinaryRowV2(BinaryStoreWriterV2 writer, String[] columnNames, SupportedType[] columnTypes, Object[] typeMetadata)

Method Details

getSetter

public RowSetter getSetter(String name)

Description copied from interface: Row

Gets a setter for a column.

Specified by:

getSetter in interface Row

Parameters:

name - column name

Returns:

setter for the column.

populateBuffer

public ByteBuffer populateBuffer() throws IOException

Populate the internal data buffer with column values. This assumes that all appropriate row setters have been called.

Returns:

the data buffer just populated

Throws:

IOException

writeRow

public void writeRow() throws IOException

Description copied from interface: Row

Writes out a new row (values set using setters).

Specified by:

writeRow in interface Row

Throws:

IOException - problem writing the row

writeAndReset

protected void writeAndReset() throws IOException

Write a row to the underlying stream and reset the internal buffer. populateBuffer() must have been previously called.

Throws:

IOException - if an error occurred during write.

reset

public void reset()

Reset the internal buffer. Note that unless the buffer has been populated and written, the data is lost.

setFlags

public void setFlags(Row.Flags flags)

Specified by:

setFlags in interface Row

setColumnPartitionValue

public void setColumnPartitionValue(String columnPartitionValue)

Description copied from interface: Row

For rows that are to be used with file managers that allow dynamic column partition selection, set the column partition value.

Specified by:

setColumnPartitionValue in interface Row

Parameters:

columnPartitionValue - the column partition value

getColumnPartitionValue

public String getColumnPartitionValue()

Description copied from interface: Row

For rows that are to be used with file managers that allow dynamic column partition selection, retrieve the column partition value.

Specified by:

getColumnPartitionValue in interface Row

Returns:

the previously-set column partition value

getFlagSetter

public BinaryRowV2.FlagSetter getFlagSetter()