Add Delta snapshot version to the web-console (#17023) (#17119)

Adds snapshot.version to the delta input source in the web-console:
apache · Sep 23, 2024 · 6c0ca77 · 6c0ca77
1 parent 0c58f88
commit 6c0ca77
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 1 deletion.
diff --git a/web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx b/web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx
@@ -1060,6 +1060,7 @@ export function getIoConfigFormFields(ingestionComboType: IngestionComboType): F
           name: 'inputSource.filter',
           label: 'Delta filter',
           type: 'json',
+          placeholder: '{"type": "=", "column": "name", "value": "foo"}',
           defaultValue: {},
           info: (
             <>
@@ -1072,6 +1073,19 @@ export function getIoConfigFormFields(ingestionComboType: IngestionComboType): F
             </>
           ),
         },
+        {
+          name: 'inputSource.snapshotVersion',
+          label: 'Delta snapshot version',
+          type: 'number',
+          placeholder: '(latest)',
+          defaultValue: {},
+          info: (
+            <>
+              The snapshot version to read from the Delta table. By default, the latest snapshot is
+              read.
+            </>
+          ),
+        },
       ];
 
     case 'index_parallel:hdfs':

diff --git a/web-console/src/druid-models/input-source/input-source.tsx b/web-console/src/druid-models/input-source/input-source.tsx
@@ -652,7 +652,7 @@ export const INPUT_SOURCE_FIELDS: Field<InputSource>[] = [
     label: 'Delta filter',
     type: 'json',
     placeholder: '{"type": "=", "column": "name", "value": "foo"}',
-    defined: inputSource => inputSource.type === 'delta' && deepGet(inputSource, 'filter'),
+    defined: typeIsKnown(KNOWN_TYPES, 'delta'),
     required: false,
     info: (
       <>
@@ -663,6 +663,19 @@ export const INPUT_SOURCE_FIELDS: Field<InputSource>[] = [
       </>
     ),
   },
+  {
+    name: 'snapshotVersion',
+    label: 'Delta snapshot version',
+    type: 'number',
+    placeholder: '(latest)',
+    defined: typeIsKnown(KNOWN_TYPES, 'delta'),
+    required: false,
+    info: (
+      <>
+        The snapshot version to read from the Delta table. By default, the latest snapshot is read.
+      </>
+    ),
+  },
 
   // sql
   {