Skip to content

Commit

Permalink
Rename object to make its usage clearer
Browse files Browse the repository at this point in the history
  • Loading branch information
revans2 committed Jan 3, 2024
1 parent 1f3b7bb commit 876aeeb
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ import ai.rapids.cudf.{DType, Scalar}
import com.nvidia.spark.rapids.Arm.{withResource, withResourceIfAllowed}
import com.nvidia.spark.rapids.RapidsPluginImplicits.AutoCloseableProducingSeq

object GpuBatchedWindowIterator {
object GpuBatchedWindowIteratorUtils {
def cudfAnd(lhs: cudf.ColumnVector,
rhs: cudf.ColumnVector): cudf.ColumnVector = {
withResource(lhs) { lhs =>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ class GpuCachedDoublePassWindowIterator(
numOutputBatches: GpuMetric,
numOutputRows: GpuMetric,
opTime: GpuMetric) extends Iterator[ColumnarBatch] with BasicWindowCalc {
import GpuBatchedWindowIterator._
import GpuBatchedWindowIteratorUtils._

override def isRunningBatched: Boolean = true

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ class GpuRunningWindowIterator(
numOutputBatches: GpuMetric,
numOutputRows: GpuMetric,
opTime: GpuMetric) extends Iterator[ColumnarBatch] with BasicWindowCalc {
import GpuBatchedWindowIterator._
import GpuBatchedWindowIteratorUtils._

override def isRunningBatched: Boolean = true

Expand Down

0 comments on commit 876aeeb

Please sign in to comment.