diff --git a/web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx b/web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx index 03898732bb00..45f84c8a809c 100644 --- 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 index 4479150227d3..eb19e4575db5 100644 --- 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[] = [ 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[] = [ ), }, + { + 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 {