Skip to content

Commit 0d377d0

Browse files
committed
Refine condition (use lit for Boolean)
1 parent 2a75bd5 commit 0d377d0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/scala/ldbc/snb/datagen/transformation/transform/RawToBiTransform.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ case class RawToBiTransform(mode: BI, simulationStart: Long, simulationEnd: Long
5353
val idColumns = tpe.primaryKey.map(qcol)
5454
df
5555
.filter(inBatch($"deletionDate", batchStart, batchEnd))
56-
.filter(if (df.columns.contains("explicitlyDeleted")) "explicitlyDeleted" else "true")
56+
.filter(if (df.columns.contains("explicitlyDeleted")) col("explicitlyDeleted") else lit(true))
5757
.pipe(batched)
5858
.select(Seq($"delete_batch_id".as("batch_id"), $"deletionDate") ++ idColumns: _*)
5959
.repartitionByRange($"batch_id")

0 commit comments

Comments
 (0)