Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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

* Web-console change to add Delta snapshot version.

Web-console change for https://github.com/apache/druid/pull/17004.

* Update web-console/src/druid-models/input-source/input-source.tsx

* Update web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx
This commit is contained in:
Abhishek Radhakrishnan 2024-09-09 14:49:53 -04:00 committed by GitHub
parent aa833a711c
commit f4261c0e4d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 28 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx
View File

@ -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':

15
web-console/src/druid-models/input-source/input-source.tsx
View File

@ -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
{