Skip to content

Commit

Permalink
run mvn spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
Zand100 committed Nov 14, 2024
1 parent df138e3 commit ac960fb
Showing 1 changed file with 2 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,12 +18,7 @@ package org.apache.spark.sql.execution

import org.apache.spark.SparkEnv
import org.apache.spark.executor.ShuffleWriteMetrics
import org.apache.spark.memory.{
MemoryConsumer,
MemoryMode,
SparkOutOfMemoryError,
TaskMemoryManager
}
import org.apache.spark.memory.{MemoryConsumer, MemoryMode, SparkOutOfMemoryError, TaskMemoryManager}
import org.apache.spark.sql.catalyst.expressions.UnsafeArrayData
import org.apache.spark.unsafe.{Platform, UnsafeAlignedOffset}
import org.apache.spark.unsafe.memory.MemoryBlock
Expand Down Expand Up @@ -60,7 +55,7 @@ class UnsafeArray(taskMemoryManager: TaskMemoryManager)
val offset = keyOffsets(rowId)
val klen = UnsafeAlignedOffset.getSize(base, offset - UnsafeAlignedOffset.getUaoSize)
val result = new UnsafeArrayData
result.pointTo (base, offset, klen)
result.pointTo(base, offset, klen)
result
}

Expand Down Expand Up @@ -115,5 +110,4 @@ class UnsafeArray(taskMemoryManager: TaskMemoryManager)
0L // TODO return released size
}


}

0 comments on commit ac960fb

Please sign in to comment.