Package io.deephaven.web.client.api.barrage

Class WebBarrageUtils

java.lang.Object

io.deephaven.web.client.api.barrage.WebBarrageUtils

public class WebBarrageUtils
extends Object

Utility to read barrage record batches.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	FLATBUFFER_MAGIC

Constructor Summary

Constructors

Constructor	Description
WebBarrageUtils()

Method Summary

Modifier and Type	Method	Description
static ByteBuffer	emptyMessage()
static Map<String,String>	keyValuePairs(String filterPrefix, int count, IntFunction<org.apache.arrow.flatbuf.KeyValue> accessor)
static org.apache.arrow.flatbuf.Schema	readSchemaMessage(ByteBuffer flightSchemaMessage)	Reads the buffer into a Message and unwraps the Schema within.
static InitialTableDefinition	readTableDefinition(ByteBuffer flightSchemaMessage)
static InitialTableDefinition	readTableDefinition(org.apache.arrow.flatbuf.Schema schema)
static ByteBuffer	serializeRanges(Set<RangeSet> rangeSets)
static ByteBuffer	wrapMessage(com.google.flatbuffers.FlatBufferBuilder innerBuilder, byte messageType)

Methods inherited from class java.lang.Object

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

Field Details

FLATBUFFER_MAGIC

public static final int FLATBUFFER_MAGIC

See Also:

• Constant Field Values

Constructor Details

WebBarrageUtils

public WebBarrageUtils()

Method Details

wrapMessage

public static ByteBuffer wrapMessage(com.google.flatbuffers.FlatBufferBuilder innerBuilder,
 byte messageType)

emptyMessage

public static ByteBuffer emptyMessage()

readTableDefinition

public static InitialTableDefinition readTableDefinition(ByteBuffer flightSchemaMessage)

readTableDefinition

public static InitialTableDefinition readTableDefinition(org.apache.arrow.flatbuf.Schema schema)

readSchemaMessage

public static org.apache.arrow.flatbuf.Schema readSchemaMessage(ByteBuffer flightSchemaMessage)

Reads the buffer into a Message and unwraps the Schema within. The buffer's contents are consumed. We expect this payload to consist of

• IPC_CONTINUATION_TOKEN (4-byte int of -1)
• message size (4-byte int)
• a Message wrapping the schema

keyValuePairs

public static Map<String,String> keyValuePairs(String filterPrefix,
 int count,
 IntFunction<org.apache.arrow.flatbuf.KeyValue> accessor)

serializeRanges

public static ByteBuffer serializeRanges(Set<RangeSet> rangeSets)