Skip to content

Commit 0342a8c

Browse files
authored
Merge pull request #310 from ldbc/only-serialize-explicit-deletes
Only serialize explicitlyDeleted entities for the deletes
2 parents 4bbd99c + c4309fc commit 0342a8c

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
@@ -52,7 +52,7 @@ case class RawToBiTransform(mode: BI, simulationStart: Long, simulationEnd: Long
5252
val idColumns = tpe.primaryKey.map(qcol)
5353
df
5454
.filter(inBatch($"deletionDate", batchStart, batchEnd))
55-
.filter(if (df.columns.contains("explicitlyDeleted")) col("explicitlyDeleted") else lit(true))
55+
.filter(if (df.columns.contains("explicitlyDeleted")) col("explicitlyDeleted") else lit(false))
5656
.pipe(batched)
5757
.select(Seq($"delete_batch_id".as("batch_id"), $"deletionDate") ++ idColumns: _*)
5858
.repartitionByRange($"batch_id")

0 commit comments

Comments
 (0)