Package io.deephaven.extensions.barrage.util

Class ArrowToTableConverter

java.lang.Object

io.deephaven.extensions.barrage.util.ArrowToTableConverter

Direct Known Subclasses:

ArrowFlightUtil.DoPutObserver

public class ArrowToTableConverter
extends Object

This class allows the incremental making of a BarrageTable from Arrow IPC messages, starting with an Arrow Schema message followed by zero or more RecordBatches

Field Summary

Fields

Modifier and Type	Field	Description
protected BarrageSubscriptionOptions	options
protected BarrageTable	resultTable
protected long	totalRowsRead

Constructor Summary

Constructors

Constructor	Description
ArrowToTableConverter()

Method Summary

Modifier and Type	Method	Description
void	addRecordBatch(ByteBuffer ipcMessage)
void	addRecordBatches(ByteBuffer... ipcMessages)
protected BarrageMessage	createBarrageMessage(BarrageProtoUtil.MessageInfo mi, int numColumns)
BarrageTable	getResultTable()
void	onCompleted()
protected void	parseSchema(org.apache.arrow.flatbuf.Message message)
void	setSchema(ByteBuffer ipcMessage)

Methods inherited from class java.lang.Object

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

Field Details

totalRowsRead

protected long totalRowsRead

resultTable

protected BarrageTable resultTable

options

protected BarrageSubscriptionOptions options

Constructor Details

ArrowToTableConverter

public ArrowToTableConverter()

Method Details

setSchema

@ScriptApi
public void setSchema(ByteBuffer ipcMessage)

addRecordBatches

@ScriptApi
public void addRecordBatches(ByteBuffer... ipcMessages)

addRecordBatch

@ScriptApi
public void addRecordBatch(ByteBuffer ipcMessage)

getResultTable

@ScriptApi
public BarrageTable getResultTable()

onCompleted

@ScriptApi
public void onCompleted()
                 throws InterruptedException

Throws:

InterruptedException

parseSchema

protected void parseSchema(org.apache.arrow.flatbuf.Message message)

createBarrageMessage

protected BarrageMessage createBarrageMessage(BarrageProtoUtil.MessageInfo mi,
 int numColumns)