Package io.fury.format.vectorized

Class ArrowUtils

java.lang.Object

io.fury.format.vectorized.ArrowUtils

public class ArrowUtils
extends Object

Arrow utils.

Author:

chaokunyang

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.arrow.memory.RootAllocator	allocator

Constructor Summary

Constructors

Constructor	Description
ArrowUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.arrow.memory.ArrowBuf	buffer(long initialRequestSize)
static ArrowWriter	createArrowWriter(org.apache.arrow.vector.types.pojo.Schema schema)
static org.apache.arrow.vector.VectorSchemaRoot	createVectorSchemaRoot(org.apache.arrow.vector.types.pojo.Schema schema)
static org.apache.arrow.memory.ArrowBuf	decimalArrowBuf()
static org.apache.arrow.vector.ipc.message.ArrowRecordBatch	deserializeRecordBatch(MemoryBuffer recordBatchMessageBuffer)
static void	serializeRecordBatch(org.apache.arrow.vector.ipc.message.ArrowRecordBatch recordBatch, MemoryBuffer buffer)

Methods inherited from class java.lang.Object

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

Field Details

allocator

public static org.apache.arrow.memory.RootAllocator allocator

Constructor Details

ArrowUtils

public ArrowUtils()

Method Details

buffer

public static org.apache.arrow.memory.ArrowBuf buffer(long initialRequestSize)

decimalArrowBuf

public static org.apache.arrow.memory.ArrowBuf decimalArrowBuf()

createVectorSchemaRoot

public static org.apache.arrow.vector.VectorSchemaRoot createVectorSchemaRoot(org.apache.arrow.vector.types.pojo.Schema schema)

createArrowWriter

public static ArrowWriter createArrowWriter(org.apache.arrow.vector.types.pojo.Schema schema)

serializeRecordBatch

public static void serializeRecordBatch(org.apache.arrow.vector.ipc.message.ArrowRecordBatch recordBatch,
 MemoryBuffer buffer)

deserializeRecordBatch

public static org.apache.arrow.vector.ipc.message.ArrowRecordBatch deserializeRecordBatch(MemoryBuffer recordBatchMessageBuffer)