[Kernel] Add the InCommitTimestamp table feature (#3218)

[Kernel] Add the `InCommitTimestamp` as supported writer table feature
delta-io · Jun 5, 2024 · 18d1a27 · 18d1a27
1 parent a8e339f
commit 18d1a27
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/kernel/kernel-api/src/main/java/io/delta/kernel/internal/TableFeatures.java b/kernel/kernel-api/src/main/java/io/delta/kernel/internal/TableFeatures.java
@@ -71,7 +71,8 @@ public static void validateReadSupportedTable(
      * <ul>
      *     <li>protocol writer version 1.</li>
      *     <li>protocol writer version 2 only with appendOnly feature enabled.</li>
-     *     <li>protocol writer version 7 with "appendOnly" feature enabled.</li>
+     *     <li>protocol writer version 7 with {@code appendOnly}, {@code inCommitTimestamp-preview}
+     *     feature enabled.</li>
      * </ul>
      *
      * @param protocol    Table protocol
@@ -110,6 +111,8 @@ public static void validateWriteSupportedTable(
                         // Only supported writer features as of today in Kernel
                         case "appendOnly":
                             break;
+                        case "inCommitTimestamp-preview":
+                            break;
                         default:
                             throw unsupportedWriterFeature(tablePath, writerFeature);
                     }

diff --git a/kernel/kernel-api/src/test/scala/io/delta/kernel/internal/TableFeaturesSuite.scala b/kernel/kernel-api/src/test/scala/io/delta/kernel/internal/TableFeaturesSuite.scala
@@ -68,8 +68,10 @@ class TableFeaturesSuite extends AnyFunSuite {
     checkSupported(createTestProtocol(minWriterVersion = 7))
   }
 
-  test("validateWriteSupported: protocol 7 with appendOnly") {
-    checkSupported(createTestProtocol(minWriterVersion = 7, writerFeatures = "appendOnly"))
+  Seq("appendOnly", "inCommitTimestamp-preview").foreach { supportedWriterFeature =>
+    test(s"validateWriteSupported: protocol 7 with $supportedWriterFeature") {
+      checkSupported(createTestProtocol(minWriterVersion = 7, supportedWriterFeature))
+    }
   }
 
   Seq("invariants", "checkConstraints", "generatedColumns", "allowColumnDefaults", "changeDataFeed",