DEBUG, REVERTABLE

oap-project · Apr 12, 2022 · ab262f7 · ab262f7
1 parent cc96fc5
commit ab262f7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/native-sql-engine/core/src/main/java/com/intel/oap/vectorized/ExpressionEvaluator.java b/native-sql-engine/core/src/main/java/com/intel/oap/vectorized/ExpressionEvaluator.java
@@ -158,6 +158,10 @@ public void evaluate(ColumnarNativeIterator batchItr)
    */
   public ArrowRecordBatch[] evaluate2(ArrowRecordBatch recordBatch) throws RuntimeException, IOException {
     byte[] bytes = UnsafeRecordBatchSerializer.serializeUnsafe(recordBatch);
+    for (ArrowBuf buffer : recordBatch.getBuffers()) {
+      System.out.printf("[JAVA SORT DEBUG 2] address: %s, hex: %s\n",
+          buffer.memoryAddress(), buffer.toHexString(0, (int) buffer.capacity()));
+    }
     byte[][] serializedBatchArray = jniWrapper.nativeEvaluate2(nativeHandler, bytes);
     BufferAllocator allocator = SparkMemoryUtils.contextAllocatorForBufferImport();
     ArrowRecordBatch[] recordBatchList = new ArrowRecordBatch[serializedBatchArray.length];