com.alibaba.fastjson2.support.arrow

Class ArrowByteArrayConsumer

java.lang.Object

com.alibaba.fastjson2.support.arrow.ArrowByteArrayConsumer

All Implemented Interfaces:

ByteArrayValueConsumer

public class ArrowByteArrayConsumer
extends java.lang.Object
implements ByteArrayValueConsumer

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.arrow.memory.BufferAllocator	allocator
(package private) int	blockIndex
(package private) int	blockRowIndex
(package private) int	blockSize
(package private) static int	CHUNK_SIZE
(package private) java.util.function.Consumer<java.lang.Long[]>	committer
(package private) org.apache.arrow.vector.VectorSchemaRoot	root
(package private) java.util.function.ObjIntConsumer<org.apache.arrow.vector.VectorSchemaRoot>	rootConsumer
(package private) int	rowCount
(package private) org.apache.arrow.vector.types.pojo.Schema	schema
(package private) int[]	valueCapacities
(package private) int	varcharValueSize

Constructor Summary

Constructors

Constructor and Description
ArrowByteArrayConsumer(org.apache.arrow.vector.types.pojo.Schema schema, int rowCount, java.util.function.ObjIntConsumer<org.apache.arrow.vector.VectorSchemaRoot> rootConsumer, java.util.function.Consumer<java.lang.Long[]> committer)

Method Summary

Modifier and Type	Method and Description
void	accept(int row, int column, byte[] bytes, int off, int len, java.nio.charset.Charset charset)
void	afterRow(int row)
void	allocateNew(int blockSize)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alibaba.fastjson2.reader.ByteArrayValueConsumer

beforeRow, end, start

Field Detail

CHUNK_SIZE

static final int CHUNK_SIZE

See Also:

Constant Field Values

schema

final org.apache.arrow.vector.types.pojo.Schema schema

rowCount

final int rowCount

varcharValueSize

final int varcharValueSize

See Also:

Constant Field Values

rootConsumer

final java.util.function.ObjIntConsumer<org.apache.arrow.vector.VectorSchemaRoot> rootConsumer

committer

final java.util.function.Consumer<java.lang.Long[]> committer

allocator

org.apache.arrow.memory.BufferAllocator allocator

root

org.apache.arrow.vector.VectorSchemaRoot root

blockSize

int blockSize

blockRowIndex

int blockRowIndex

blockIndex

int blockIndex

valueCapacities

int[] valueCapacities

Constructor Detail

ArrowByteArrayConsumer

public ArrowByteArrayConsumer(org.apache.arrow.vector.types.pojo.Schema schema,
                              int rowCount,
                              java.util.function.ObjIntConsumer<org.apache.arrow.vector.VectorSchemaRoot> rootConsumer,
                              java.util.function.Consumer<java.lang.Long[]> committer)

Method Detail

afterRow

public void afterRow(int row)

Specified by:

afterRow in interface ByteArrayValueConsumer

allocateNew

public void allocateNew(int blockSize)

accept

public void accept(int row,
                   int column,
                   byte[] bytes,
                   int off,
                   int len,
                   java.nio.charset.Charset charset)

Specified by:

accept in interface ByteArrayValueConsumer