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 elemental2.core.Uint8Array	bbToUint8ArrayView(ByteBuffer byteBuffer)
static elemental2.core.Uint8Array	emptyMessage()
static Map<String,String>	keyValuePairs(String filterPrefix, double count, IntFunction<org.apache.arrow.flatbuf.KeyValue> accessor)
static org.apache.arrow.flatbuf.Schema	readSchemaMessage(elemental2.core.Uint8Array flightSchemaMessage)
static InitialTableDefinition	readTableDefinition(elemental2.core.Uint8Array flightSchemaMessage)
static InitialTableDefinition	readTableDefinition(org.apache.arrow.flatbuf.Schema schema)
static ByteBuffer	serializeRanges(Set<RangeSet> rangeSets)
static elemental2.core.Uint8Array	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 elemental2.core.Uint8Array wrapMessage(com.google.flatbuffers.FlatBufferBuilder innerBuilder,
 byte messageType)

bbToUint8ArrayView

public static elemental2.core.Uint8Array bbToUint8ArrayView(ByteBuffer byteBuffer)

emptyMessage

public static elemental2.core.Uint8Array emptyMessage()

readTableDefinition

public static InitialTableDefinition readTableDefinition(elemental2.core.Uint8Array flightSchemaMessage)

readTableDefinition

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

readSchemaMessage

public static org.apache.arrow.flatbuf.Schema readSchemaMessage(elemental2.core.Uint8Array flightSchemaMessage)

keyValuePairs

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

serializeRanges

public static ByteBuffer serializeRanges(Set<RangeSet> rangeSets)