org.apache.paimon.arrow

Class ArrowUtils

java.lang.Object

org.apache.paimon.arrow.ArrowUtils

public class ArrowUtils
extends Object

Utilities for creating Arrow objects.

Constructor Summary

Constructors

Constructor and Description
ArrowUtils()

Method Summary

Modifier and Type	Method and Description
static ArrowFieldWriter[]	createArrowFieldWriters(org.apache.arrow.vector.VectorSchemaRoot vectorSchemaRoot, RowType rowType)
static org.apache.arrow.vector.FieldVector	createVector(DataField dataField, org.apache.arrow.memory.BufferAllocator allocator, boolean allowUpperCase)
static org.apache.arrow.vector.VectorSchemaRoot	createVectorSchemaRoot(RowType rowType, org.apache.arrow.memory.BufferAllocator allocator)
static org.apache.arrow.vector.VectorSchemaRoot	createVectorSchemaRoot(RowType rowType, org.apache.arrow.memory.BufferAllocator allocator, boolean allowUpperCase)
static ArrowCStruct	serializeToCStruct(org.apache.arrow.vector.VectorSchemaRoot vsr, org.apache.arrow.c.ArrowArray array, org.apache.arrow.c.ArrowSchema schema)
static void	serializeToIpc(org.apache.arrow.vector.VectorSchemaRoot vsr, OutputStream out)
static long	timestampToEpoch(Timestamp timestamp, int precision, java.time.ZoneId castZoneId)
static org.apache.arrow.vector.types.pojo.Field	toArrowField(String fieldName, int fieldId, DataType dataType, int depth)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowUtils

public ArrowUtils()

Method Detail

createVectorSchemaRoot

public static org.apache.arrow.vector.VectorSchemaRoot createVectorSchemaRoot(RowType rowType,
                                                                              org.apache.arrow.memory.BufferAllocator allocator)

createVectorSchemaRoot

public static org.apache.arrow.vector.VectorSchemaRoot createVectorSchemaRoot(RowType rowType,
                                                                              org.apache.arrow.memory.BufferAllocator allocator,
                                                                              boolean allowUpperCase)

createVector

public static org.apache.arrow.vector.FieldVector createVector(DataField dataField,
                                                               org.apache.arrow.memory.BufferAllocator allocator,
                                                               boolean allowUpperCase)

toArrowField

public static org.apache.arrow.vector.types.pojo.Field toArrowField(String fieldName,
                                                                    int fieldId,
                                                                    DataType dataType,
                                                                    int depth)

createArrowFieldWriters

public static ArrowFieldWriter[] createArrowFieldWriters(org.apache.arrow.vector.VectorSchemaRoot vectorSchemaRoot,
                                                         RowType rowType)

timestampToEpoch

public static long timestampToEpoch(Timestamp timestamp,
                                    int precision,
                                    @Nullable
                                    java.time.ZoneId castZoneId)

serializeToCStruct

public static ArrowCStruct serializeToCStruct(org.apache.arrow.vector.VectorSchemaRoot vsr,
                                              org.apache.arrow.c.ArrowArray array,
                                              org.apache.arrow.c.ArrowSchema schema)

serializeToIpc

public static void serializeToIpc(org.apache.arrow.vector.VectorSchemaRoot vsr,
                                  OutputStream out)