import org.apache.arrow.memory.*; import org.apache.arrow.vector.*; import org.apache.arrow.vector.ipc.message.*; import org.apache.arrow.vector.types.pojo.*; import org.apache.arrow.vector.util.*; public class ArrowCorePerformanceOptimizationExample { public static void main(String[] args) { try (RootAllocator allocator = new RootAllocator(Long.MAX_VALUE)) { BigIntVector idVector = new BigIntVector("id", allocator); Field idField = idVector.getField(); Float8Vector valueVector = new Float8Vector("value", allocator); Field valueField = valueVector.getField(); idVector.setInitialCapacity(1000); valueVector.setInitialCapacity(1000); idVector.allocateNew(); valueVector.allocateNew(); for (int i = 0; i < 1000; i++) { idVector.setSafe(i, i); valueVector.setSafe(i, Math.random()); } idVector.setValueCount(1000); valueVector.setValueCount(1000); for (int i = 0; i < 1000; i++) { double value = valueVector.get(i); System.out.println("Value: " + value); } } } }


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