Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
wangxinshuo.db committed Jul 4, 2024
1 parent 2731284 commit 9aaf96b
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 @@ -165,7 +165,7 @@ object VeloxColumnarToRowExec {
if (rowId == baseLength + info.lengths.length) {
baseLength += info.lengths.length
val before = System.currentTimeMillis()
info = jniWrapper.nativeColumnarToRowConvert(batchHandle, c2rId, rowId)
info = jniWrapper.nativeColumnarToRowConvert(c2rId, batchHandle, rowId)
convertTime += (System.currentTimeMillis() - before)
}
val (offset, length) =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ object ExecUtil {
if (rowId >= batch.numRows()) throw new NoSuchElementException
if (rowId == baseLength + info.lengths.length) {
baseLength += info.lengths.length
info = jniWrapper.nativeColumnarToRowConvert(batchHandle, c2rHandle, rowId)
info = jniWrapper.nativeColumnarToRowConvert(c2rHandle, batchHandle, rowId)
}
val (offset, length) =
(info.offsets(rowId - baseLength), info.lengths(rowId - baseLength))
Expand Down

0 comments on commit 9aaf96b

Please sign in to comment.