org.apache.arrow.vector.ipc.message

Class ArrowDictionaryBatch

java.lang.Object

org.apache.arrow.vector.ipc.message.ArrowDictionaryBatch

All Implemented Interfaces:

AutoCloseable, ArrowMessage, FBSerializable

public class ArrowDictionaryBatch
extends Object
implements ArrowMessage

POJO wrapper around a Dictionary Batch IPC messages (https://arrow.apache.org/docs/format/IPC.html#dictionary-batches)

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.arrow.vector.ipc.message.ArrowMessage

ArrowMessage.ArrowMessageVisitor<T>

Constructor Summary

Constructors

Constructor and Description
ArrowDictionaryBatch(long dictionaryId, ArrowRecordBatch dictionary)

Method Summary

Modifier and Type	Method and Description
<T> T	accepts(ArrowMessage.ArrowMessageVisitor<T> visitor)
void	close()
int	computeBodyLength()
ArrowRecordBatch	getDictionary()
long	getDictionaryId()
byte	getMessageType() Returns the flatbuffer enum value indicating the type of the message.
String	toString()
int	writeTo(com.google.flatbuffers.FlatBufferBuilder builder) Returns the number of bytes taken to serialize the data in builder after writing to it.

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowDictionaryBatch

public ArrowDictionaryBatch(long dictionaryId,
                            ArrowRecordBatch dictionary)

Method Detail

getMessageType

public byte getMessageType()

Description copied from interface: ArrowMessage

Returns the flatbuffer enum value indicating the type of the message.

Specified by:

getMessageType in interface ArrowMessage

getDictionaryId

public long getDictionaryId()

getDictionary

public ArrowRecordBatch getDictionary()

writeTo

public int writeTo(com.google.flatbuffers.FlatBufferBuilder builder)

Description copied from interface: FBSerializable

Returns the number of bytes taken to serialize the data in builder after writing to it.

Specified by:

writeTo in interface FBSerializable

computeBodyLength

public int computeBodyLength()

Specified by:

computeBodyLength in interface ArrowMessage

accepts

public <T> T accepts(ArrowMessage.ArrowMessageVisitor<T> visitor)

Specified by:

accepts in interface ArrowMessage

toString

public String toString()

Overrides:

toString in class Object

close

public void close()

Specified by:

close in interface AutoCloseable