Skip to content

Commit

Permalink
fix code style
Browse files Browse the repository at this point in the history
  • Loading branch information
jinchengchenghh committed Aug 14, 2024
1 parent 96f550c commit e247471
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -334,7 +334,8 @@ case class ColumnarArrowEvalPythonExec(
val inputBatchIter = contextAwareIterator.map {
inputCb =>
start_time = System.nanoTime()
val loadedCb = ColumnarBatches.ensureLoaded(ArrowBufferAllocators.contextInstance, inputCb)
val loadedCb =
ColumnarBatches.ensureLoaded(ArrowBufferAllocators.contextInstance, inputCb)
// 0. cache input for later merge
inputCbCache += loadedCb
numInputRows += loadedCb.numRows
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,6 @@ public void testOffloadAndLoadWithWrites() {
});
}


private static ColumnarBatch newArrowBatch(String schema, int numRows) {
final ArrowWritableColumnVector[] columns =
ArrowWritableColumnVector.allocateColumns(numRows, StructType.fromDDL(schema));
Expand Down

0 comments on commit e247471

Please sign in to comment.