Skip to content

Commit

Permalink
Remove path
Browse files Browse the repository at this point in the history
  • Loading branch information
liurenjie1024 committed Jun 27, 2024
1 parent 06f4089 commit 1af8266
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 @@ -40,7 +40,7 @@ case class LoreRDDMeta(numPartitions: Int, outputPartitions: Seq[Int], attrs: Se
case class LoreRDDPartitionMeta(numBatches: Int, dataType: Seq[DataType])

trait GpuLoreRDD {
val rootPath: Path
def rootPath: Path

def pathOfMeta: Path = new Path(rootPath, "rdd.meta")

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ case class LoreDumpRDDInfo(idxInParent: Int, loreOutputInfo: LoreOutputInfo, att

class GpuLoreDumpRDD(info: LoreDumpRDDInfo, input: RDD[ColumnarBatch])
extends RDD[ColumnarBatch](input) with GpuLoreRDD {
override val rootPath: Path = pathOfChild(info.loreOutputInfo.path, info.idxInParent)
override def rootPath: Path = pathOfChild(info.loreOutputInfo.path, info.idxInParent)

private val hadoopConf = new SerializableConfiguration(this.context.hadoopConfiguration)

Expand Down

0 comments on commit 1af8266

Please sign in to comment.