This is an automated email from the ASF dual-hosted git repository.
abhishekrb pushed a commit to branch 30.0.0
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/30.0.0 by this push:
new bec033cd44c Web console changes for
https://github.com/apache/druid/pull/16288 (#16379) (#16385)
bec033cd44c is described below
commit bec033cd44c0a8fd5250e91ef6aead1e3f616bd7
Author: Abhishek Radhakrishnan <[email protected]>
AuthorDate: Fri May 3 10:38:00 2024 -0700
Web console changes for https://github.com/apache/druid/pull/16288 (#16379)
(#16385)
Adds a text box for delta filter that can accept an optional json
object.
---
.../druid-models/ingestion-spec/ingestion-spec.tsx | 21 +++++++++++++++++++
.../src/druid-models/input-source/input-source.tsx | 24 +++++++++++++++++++++-
2 files changed, 44 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 205d287ac2b..393c3e7ee1b 100644
--- a/web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx
+++ b/web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx
@@ -1030,6 +1030,27 @@ export function
getIoConfigFormFields(ingestionComboType: IngestionComboType): F
type: 'string',
placeholder: '/path/to/deltaTable',
required: true,
+ info: (
+ <>
+ <p>A full path to the Delta Lake table.</p>
+ </>
+ ),
+ },
+ {
+ name: 'inputSource.filter',
+ label: 'Delta filter',
+ type: 'json',
+ defaultValue: {},
+ info: (
+ <>
+ <ExternalLink
+
href={`${getLink('DOCS')}/ingestion/input-sources/#delta-filter-object`}
+ >
+ filter
+ </ExternalLink>
+ <p>A Delta filter json object to filter Delta Lake scan
files.</p>
+ </>
+ ),
},
];
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 2b0b60eecfc..17b137412ef 100644
--- a/web-console/src/druid-models/input-source/input-source.tsx
+++ b/web-console/src/druid-models/input-source/input-source.tsx
@@ -117,7 +117,8 @@ export type InputSourceDesc =
}
| {
type: 'delta';
- tablePath?: string;
+ tablePath: string;
+ filter?: string;
}
| {
type: 'sql';
@@ -624,6 +625,27 @@ export const INPUT_SOURCE_FIELDS: Field<InputSource>[] = [
placeholder: '/path/to/deltaTable',
defined: typeIsKnown(KNOWN_TYPES, 'delta'),
required: true,
+ info: (
+ <>
+ <p>A full path to the Delta Lake table.</p>
+ </>
+ ),
+ },
+ {
+ name: 'filter',
+ label: 'Delta filter',
+ type: 'json',
+ placeholder: '{"type": "=", "column": "name", "value": "foo"}',
+ defined: inputSource => inputSource.type === 'delta' &&
deepGet(inputSource, 'filter'),
+ required: false,
+ info: (
+ <>
+ <ExternalLink
href={`${getLink('DOCS')}/ingestion/input-sources/#delta-filter-object`}>
+ filter
+ </ExternalLink>
+ <p>A Delta filter json object to filter Delta Lake scan files.</p>
+ </>
+ ),
},
// sql
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
