Fix delta example to use delta for both tasks

pflooky · pflooky · commit 418732035eb6 · 2024-09-30T17:45:49.000+08:00
diff --git a/src/main/scala/io/github/datacatering/plan/DeltaLakePlan.scala b/src/main/scala/io/github/datacatering/plan/DeltaLakePlan.scala
@@ -16,7 +16,7 @@ class DeltaLakePlan extends PlanRun {
     )
     .count(count.records(100))
 
-  val transactionTask = iceberg("customer_transactions", "/opt/app/data/customer/delta")
+  val transactionTask = delta("customer_transactions", "/opt/app/data/customer/delta")
     .schema(
       field.name("account_id"),
       field.name("full_name"),

Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ class DeltaLakePlan extends PlanRun {`
`16`	`16`	`)`
`17`	`17`	`.count(count.records(100))`
`18`	`18`
`19`		`- val transactionTask = iceberg("customer_transactions", "/opt/app/data/customer/delta")`
	`19`	`+ val transactionTask = delta("customer_transactions", "/opt/app/data/customer/delta")`
`20`	`20`	`.schema(`
`21`	`21`	`field.name("account_id"),`
`22`	`22`	`field.name("full_name"),`