public class ArrowUtils extends Object
Constructor and Description |
---|
ArrowUtils() |
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,
DataType dataType) |
public static org.apache.arrow.vector.VectorSchemaRoot createVectorSchemaRoot(RowType rowType, org.apache.arrow.memory.BufferAllocator allocator)
public static org.apache.arrow.vector.VectorSchemaRoot createVectorSchemaRoot(RowType rowType, org.apache.arrow.memory.BufferAllocator allocator, boolean allowUpperCase)
public static org.apache.arrow.vector.FieldVector createVector(DataField dataField, org.apache.arrow.memory.BufferAllocator allocator, boolean allowUpperCase)
public static org.apache.arrow.vector.types.pojo.Field toArrowField(String fieldName, DataType dataType)
public static ArrowFieldWriter[] createArrowFieldWriters(org.apache.arrow.vector.VectorSchemaRoot vectorSchemaRoot, RowType rowType)
public static long timestampToEpoch(Timestamp timestamp, int precision, @Nullable java.time.ZoneId castZoneId)
public static ArrowCStruct serializeToCStruct(org.apache.arrow.vector.VectorSchemaRoot vsr, org.apache.arrow.c.ArrowArray array, org.apache.arrow.c.ArrowSchema schema)
public static void serializeToIpc(org.apache.arrow.vector.VectorSchemaRoot vsr, OutputStream out)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.