import org.apache.arrow.vector.*; import org.apache.arrow.vector.types.pojo.*; Allocator allocator = new RootAllocator(Long.MAX_VALUE); VectorSchemaRoot schemaRoot = VectorSchemaRoot.create(schema, allocator); schemaRoot.setRowCount(rowCount); FieldVector column1 = new IntVector("column1", FieldType.nullable(new ArrowType.Int(32, true)), allocator); FieldVector column2 = new Float8Vector("column2", FieldType.nullable(new ArrowType.FloatingPoint(FloatingPointPrecision.DOUBLE)), allocator); IntVector intVector = (IntVector) column1; for (int i = 0; i < rowCount; i++) { intVector.setSafe(i, i); } schemaRoot.close();


上一篇:
下一篇:
切换中文