Skip to content

Commit

Permalink
tests
Browse files Browse the repository at this point in the history
  • Loading branch information
vkorukanti committed Feb 21, 2025
1 parent 9836f7c commit 63d4376
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -463,10 +463,11 @@ public static void validateKernelCanWriteToTable(
Protocol protocol, Metadata metadata, String tablePath) {
Set<TableFeature> unsupportedFeatures =
protocol.getImplicitlyAndExplicitlySupportedFeatures().stream()
.filter(f ->
!f.hasKernelWriteSupport(metadata) ||
(f.isReaderWriterFeature() && !f.hasKernelReadSupport())
).collect(toSet());
.filter(
f ->
!f.hasKernelWriteSupport(metadata)
|| (f.isReaderWriterFeature() && !f.hasKernelReadSupport()))
.collect(toSet());

if (!unsupportedFeatures.isEmpty()) {
throw unsupportedWriterFeatures(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,10 @@
package io.delta.kernel.defaults

import scala.collection.immutable.Seq

import io.delta.kernel.engine.Engine
import io.delta.kernel.expressions.Literal

import org.apache.spark.sql.delta.DeltaLog
import org.apache.spark.sql.delta.actions.Protocol

Expand Down

0 comments on commit 63d4376

Please sign in to comment.