Skip to content

Commit 1f99118

Browse files
authored
[Spark] Change readPredicates from Seq to Vector (delta-io#4771)
#### Which Delta project/connector is this regarding? - [X] Spark - [ ] Standalone - [ ] Flink - [ ] Kernel - [ ] Other (fill in here) ## Description Change the type of `readPredicates` in `OptimisticTransaction` class from generic `Seq` to `Vector`. ## How was this patch tested? No behaviour change. Existing tests are suficient. ## Does this PR introduce _any_ user-facing changes? No
1 parent e9c156d commit 1f99118

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

spark/src/main/scala/org/apache/spark/sql/delta/ConflictChecker.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ import org.apache.spark.sql.types.StructType
5353
*/
5454
private[delta] case class CurrentTransactionInfo(
5555
val txnId: String,
56-
val readPredicates: Seq[DeltaTableReadPredicate],
56+
val readPredicates: Vector[DeltaTableReadPredicate],
5757
val readFiles: Set[AddFile],
5858
val readWholeTable: Boolean,
5959
val readAppIds: Set[String],

spark/src/main/scala/org/apache/spark/sql/delta/OptimisticTransaction.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1474,7 +1474,7 @@ trait OptimisticTransactionImpl extends TransactionHelper
14741474
}
14751475
val currentTransactionInfo = CurrentTransactionInfo(
14761476
txnId = txnId,
1477-
readPredicates = readPredicates.asScala.toSeq,
1477+
readPredicates = readPredicates.asScala.toVector,
14781478
readFiles = readFiles.toSet,
14791479
readWholeTable = readTheWholeTable,
14801480
readAppIds = readTxn.toSet,

0 commit comments

Comments
 (0)