org.apache.arrow.flatbuf

Class RecordBatch

java.lang.Object

com.google.flatbuffers.Table

org.apache.arrow.flatbuf.RecordBatch

public final class RecordBatch
extends com.google.flatbuffers.Table

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RecordBatch.Vector

Field Summary

Fields inherited from class com.google.flatbuffers.Table

bb, bb_pos

Constructor Summary

Constructors

Constructor and Description
RecordBatch()

Method Summary

Modifier and Type	Method and Description
RecordBatch	__assign(int _i, ByteBuffer _bb)
void	__init(int _i, ByteBuffer _bb)
static void	addBuffers(com.google.flatbuffers.FlatBufferBuilder builder, int buffersOffset)
static void	addCompression(com.google.flatbuffers.FlatBufferBuilder builder, int compressionOffset)
static void	addLength(com.google.flatbuffers.FlatBufferBuilder builder, long length)
static void	addNodes(com.google.flatbuffers.FlatBufferBuilder builder, int nodesOffset)
Buffer	buffers(Buffer obj, int j)
Buffer	buffers(int j) Buffers correspond to the pre-ordered flattened buffer tree The number of buffers appended to this list depends on the schema.
int	buffersLength()
Buffer.Vector	buffersVector()
Buffer.Vector	buffersVector(Buffer.Vector obj)
BodyCompression	compression() Optional compression of the message body
BodyCompression	compression(BodyCompression obj)
static int	createRecordBatch(com.google.flatbuffers.FlatBufferBuilder builder, long length, int nodesOffset, int buffersOffset, int compressionOffset)
static int	endRecordBatch(com.google.flatbuffers.FlatBufferBuilder builder)
static RecordBatch	getRootAsRecordBatch(ByteBuffer _bb)
static RecordBatch	getRootAsRecordBatch(ByteBuffer _bb, RecordBatch obj)
long	length() number of records / rows.
FieldNode	nodes(FieldNode obj, int j)
FieldNode	nodes(int j) Nodes correspond to the pre-ordered flattened logical schema
int	nodesLength()
FieldNode.Vector	nodesVector()
FieldNode.Vector	nodesVector(FieldNode.Vector obj)
static void	startBuffersVector(com.google.flatbuffers.FlatBufferBuilder builder, int numElems)
static void	startNodesVector(com.google.flatbuffers.FlatBufferBuilder builder, int numElems)
static void	startRecordBatch(com.google.flatbuffers.FlatBufferBuilder builder)
static void	ValidateVersion()

Methods inherited from class com.google.flatbuffers.Table

__has_identifier, __indirect, __indirect, __offset, __offset, __reset, __reset, __string, __string, __union, __union, __vector_as_bytebuffer, __vector_in_bytebuffer, __vector_len, __vector, compareStrings, compareStrings, getByteBuffer, keysCompare, sortTables

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordBatch

public RecordBatch()

Method Detail

ValidateVersion

public static void ValidateVersion()

getRootAsRecordBatch

public static RecordBatch getRootAsRecordBatch(ByteBuffer _bb)

getRootAsRecordBatch

public static RecordBatch getRootAsRecordBatch(ByteBuffer _bb,
                                               RecordBatch obj)

__init

public void __init(int _i,
                   ByteBuffer _bb)

__assign

public RecordBatch __assign(int _i,
                            ByteBuffer _bb)

length

public long length()

number of records / rows. The arrays in the batch should all have this length

nodes

public FieldNode nodes(int j)

Nodes correspond to the pre-ordered flattened logical schema

nodes

public FieldNode nodes(FieldNode obj,
                       int j)

nodesLength

public int nodesLength()

nodesVector

public FieldNode.Vector nodesVector()

nodesVector

public FieldNode.Vector nodesVector(FieldNode.Vector obj)

buffers

public Buffer buffers(int j)

Buffers correspond to the pre-ordered flattened buffer tree The number of buffers appended to this list depends on the schema. For example, most primitive arrays will have 2 buffers, 1 for the validity bitmap and 1 for the values. For struct arrays, there will only be a single buffer for the validity (nulls) bitmap

buffers

public Buffer buffers(Buffer obj,
                      int j)

buffersLength

public int buffersLength()

buffersVector

public Buffer.Vector buffersVector()

buffersVector

public Buffer.Vector buffersVector(Buffer.Vector obj)

compression

public BodyCompression compression()

Optional compression of the message body

compression

public BodyCompression compression(BodyCompression obj)

createRecordBatch

public static int createRecordBatch(com.google.flatbuffers.FlatBufferBuilder builder,
                                    long length,
                                    int nodesOffset,
                                    int buffersOffset,
                                    int compressionOffset)

startRecordBatch

public static void startRecordBatch(com.google.flatbuffers.FlatBufferBuilder builder)

addLength

public static void addLength(com.google.flatbuffers.FlatBufferBuilder builder,
                             long length)

addNodes

public static void addNodes(com.google.flatbuffers.FlatBufferBuilder builder,
                            int nodesOffset)

startNodesVector

public static void startNodesVector(com.google.flatbuffers.FlatBufferBuilder builder,
                                    int numElems)

addBuffers

public static void addBuffers(com.google.flatbuffers.FlatBufferBuilder builder,
                              int buffersOffset)

startBuffersVector

public static void startBuffersVector(com.google.flatbuffers.FlatBufferBuilder builder,
                                      int numElems)

addCompression

public static void addCompression(com.google.flatbuffers.FlatBufferBuilder builder,
                                  int compressionOffset)

endRecordBatch

public static int endRecordBatch(com.google.flatbuffers.FlatBufferBuilder builder)