Skip to content

Commit 9472474

Browse files
committed
Update TableCapabilityCheck after rebase.
1 parent 49e8dbd commit 9472474

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/TableCapabilityCheck.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,14 +44,14 @@ object TableCapabilityCheck extends (LogicalPlan => Unit) {
4444
// TODO: check STREAMING_WRITE capability. It's not doable now because we don't have a
4545
// a logical plan for streaming write.
4646

47-
case AppendData(r: DataSourceV2Relation, _, _) if !r.table.supports(BATCH_WRITE) =>
47+
case AppendData(r: DataSourceV2Relation, _, _, _) if !r.table.supports(BATCH_WRITE) =>
4848
failAnalysis(s"Table ${r.table.name()} does not support append in batch mode.")
4949

50-
case OverwritePartitionsDynamic(r: DataSourceV2Relation, _, _)
50+
case OverwritePartitionsDynamic(r: DataSourceV2Relation, _, _, _)
5151
if !r.table.supports(BATCH_WRITE) || !r.table.supports(OVERWRITE_DYNAMIC) =>
5252
failAnalysis(s"Table ${r.table.name()} does not support dynamic overwrite in batch mode.")
5353

54-
case OverwriteByExpression(r: DataSourceV2Relation, expr, _, _) =>
54+
case OverwriteByExpression(r: DataSourceV2Relation, expr, _, _, _) =>
5555
expr match {
5656
case Literal(true, BooleanType) =>
5757
if (!r.table.supports(BATCH_WRITE) ||

0 commit comments

Comments
 (0)