This is an automated email from the ASF dual-hosted git repository.
lakshsingla pushed a commit to branch 31.0.0
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/31.0.0 by this push:
new 6c0ca77be4e Add Delta snapshot version to the web-console (#17023)
(#17119)
6c0ca77be4e is described below
commit 6c0ca77be4e4ac64c01f4748e36910b530931980
Author: Abhishek Radhakrishnan <[email protected]>
AuthorDate: Sun Sep 22 23:06:24 2024 -0700
Add Delta snapshot version to the web-console (#17023) (#17119)
Adds snapshot.version to the delta input source in the web-console:
---
.../src/druid-models/ingestion-spec/ingestion-spec.tsx | 14 ++++++++++++++
.../src/druid-models/input-source/input-source.tsx | 15 ++++++++++++++-
2 files changed, 28 insertions(+), 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
index 03898732bb0..45f84c8a809 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 4479150227d..eb19e4575db 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<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
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
