removed function not needed

apache · Jul 17, 2017 · 063dcd9 · 063dcd9
1 parent 11a7a87
commit 063dcd9
Showing 1 changed file with 0 additions and 16 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowConverters.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowConverters.scala
@@ -273,22 +273,6 @@ private[sql] object ArrowConverters {
       reader.close()
     }
   }
-
-  private[arrow] def execByteArrayAsVectors(
-     batchBytes: Array[Byte],
-     allocator: BufferAllocator)(block: (VectorSchemaRoot) => Unit): Unit = {
-    val in = new ByteArrayReadableSeekableByteChannel(batchBytes)
-    val reader = new ArrowFileReader(in, allocator)
-
-    // Read a batch from a byte stream, ensure the reader is closed
-    Utils.tryWithSafeFinally {
-      val root = reader.getVectorSchemaRoot  // throws IOException
-      reader.loadNextBatch()  // throws IOException
-      block(root)
-    } {
-      reader.close()
-    }
-  }
 }
 
 /**