Package io.deephaven.extensions.barrage.util

Class BarrageProtoUtil

java.lang.Object

io.deephaven.extensions.barrage.util.BarrageProtoUtil

public class BarrageProtoUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BarrageProtoUtil.ExposedByteArrayOutputStream
static final class	BarrageProtoUtil.MessageInfo
static class	BarrageProtoUtil.ObjectInputStreamAdapter

Field Summary

Fields

Modifier and Type	Field	Description
static final int	APP_METADATA_TAG
static final int	BODY_TAG
static final int	DATA_HEADER_TAG
static final BarrageSubscriptionOptions	DEFAULT_SER_OPTIONS
static final int	FLIGHT_DESCRIPTOR_TAG

Constructor Summary

Constructors

Constructor	Description
BarrageProtoUtil()

Method Summary

Modifier and Type	Method	Description
static BarrageProtoUtil.MessageInfo	parseProtoMessage(InputStream stream)
static ByteBuffer	toByteBuffer(RowSet rowSet)
static RowSet	toRowSet(ByteBuffer string)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SER_OPTIONS

public static final BarrageSubscriptionOptions DEFAULT_SER_OPTIONS

BODY_TAG

public static final int BODY_TAG

See Also:

• Constant Field Values

DATA_HEADER_TAG

public static final int DATA_HEADER_TAG

See Also:

• Constant Field Values

APP_METADATA_TAG

public static final int APP_METADATA_TAG

See Also:

• Constant Field Values

FLIGHT_DESCRIPTOR_TAG

public static final int FLIGHT_DESCRIPTOR_TAG

See Also:

• Constant Field Values

Constructor Details

BarrageProtoUtil

public BarrageProtoUtil()

Method Details

toByteBuffer

public static ByteBuffer toByteBuffer(RowSet rowSet)

toRowSet

public static RowSet toRowSet(ByteBuffer string)

parseProtoMessage

public static BarrageProtoUtil.MessageInfo parseProtoMessage(InputStream stream)
                                                      throws IOException

Throws:

IOException