mirror of https://github.com/apache/druid.git
Adds snapshot.version to the delta input source in the web-console:
This commit is contained in:
parent
0c58f88ded
commit
6c0ca77be4
|
@ -1060,6 +1060,7 @@ export function getIoConfigFormFields(ingestionComboType: IngestionComboType): F
|
||||||
name: 'inputSource.filter',
|
name: 'inputSource.filter',
|
||||||
label: 'Delta filter',
|
label: 'Delta filter',
|
||||||
type: 'json',
|
type: 'json',
|
||||||
|
placeholder: '{"type": "=", "column": "name", "value": "foo"}',
|
||||||
defaultValue: {},
|
defaultValue: {},
|
||||||
info: (
|
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':
|
case 'index_parallel:hdfs':
|
||||||
|
|
|
@ -652,7 +652,7 @@ export const INPUT_SOURCE_FIELDS: Field<InputSource>[] = [
|
||||||
label: 'Delta filter',
|
label: 'Delta filter',
|
||||||
type: 'json',
|
type: 'json',
|
||||||
placeholder: '{"type": "=", "column": "name", "value": "foo"}',
|
placeholder: '{"type": "=", "column": "name", "value": "foo"}',
|
||||||
defined: inputSource => inputSource.type === 'delta' && deepGet(inputSource, 'filter'),
|
defined: typeIsKnown(KNOWN_TYPES, 'delta'),
|
||||||
required: false,
|
required: false,
|
||||||
info: (
|
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
|
// sql
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue