Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(ingestion/dremio): Add Dremio as a source #11383

Closed
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
5e4db8f
feat - dremio connector
acrylJonny Sep 16, 2024
3056ba5
Move code to right location & add doc configs
pedro93 Sep 16, 2024
159bc3e
initial set of lint fixes
anshbansal Sep 16, 2024
0d46f7f
more lint fixes
anshbansal Sep 16, 2024
7f6161d
Merge branch 'master' into feature-dremio-connector
acrylJonny Sep 27, 2024
d200df5
fix lineage issue and add mapping
acrylJonny Sep 30, 2024
012b3d1
Merge branch 'master' into feature-dremio-connector
acrylJonny Sep 30, 2024
0ea7446
linting
acrylJonny Sep 30, 2024
b3c3ebe
Code improvements
acrylJonny Oct 5, 2024
9657068
Merge branch 'master' into feature-dremio-connector
acrylJonny Oct 5, 2024
826b491
Update dremio_aspects.py
acrylJonny Oct 5, 2024
4908a09
Update dremio_config.py
acrylJonny Oct 5, 2024
bdc33f1
update docs
acrylJonny Oct 6, 2024
b47dcb3
Merge branch 'master' into feature-dremio-connector
acrylJonny Oct 6, 2024
f598fa6
add profiling to Dremio connector
acrylJonny Oct 6, 2024
d560237
add glossaryTerm aspects
acrylJonny Oct 6, 2024
7998006
Update dremio_api.py
acrylJonny Oct 7, 2024
a2388eb
bug fix in container paths
acrylJonny Oct 7, 2024
ab8de90
Update dremio_config.py
acrylJonny Oct 7, 2024
01e7a59
bug fix
acrylJonny Oct 7, 2024
abdb39f
surpress insecurerequestswarning
acrylJonny Oct 7, 2024
542e21a
feat - support broken dremio sources
acrylJonny Oct 8, 2024
c43a275
Merge branch 'master' into feature-dremio-connector
acrylJonny Oct 8, 2024
4365449
feat support CE
acrylJonny Oct 8, 2024
92b25f9
Update dremio_api.py
acrylJonny Oct 10, 2024
5343642
Update dremio_api.py
acrylJonny Oct 10, 2024
f941ee0
Update dremio_api.py
acrylJonny Oct 10, 2024
3d428e0
Merge branch 'master' into feature-dremio-connector
acrylJonny Oct 10, 2024
646dd9a
bug fix
acrylJonny Oct 10, 2024
58e0ba1
Update dremio_source.py
acrylJonny Oct 10, 2024
2388277
improvement to metadata gathering
acrylJonny Oct 10, 2024
bd2727e
Update dremio_api.py
acrylJonny Oct 10, 2024
e4ad9a3
Update dremio_sql_queries.py
acrylJonny Oct 10, 2024
d787c94
Update dremio_source.py
acrylJonny Oct 11, 2024
6079f05
Merge branch 'master' into feature-dremio-connector
acrylJonny Oct 11, 2024
982482c
Update dremio_source.py
acrylJonny Oct 11, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions datahub-web-react/src/app/ingest/source/builder/constants.ts
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ import clickhouseLogo from '../../../../images/clickhouselogo.png';
import cockroachdbLogo from '../../../../images/cockroachdblogo.png';
import trinoLogo from '../../../../images/trinologo.png';
import dbtLogo from '../../../../images/dbtlogo.png';
import dremioLogo from '../../../../images/dremiologo.png';
import druidLogo from '../../../../images/druidlogo.png';
import elasticsearchLogo from '../../../../images/elasticsearchlogo.png';
import feastLogo from '../../../../images/feastlogo.png';
Expand Down Expand Up @@ -51,6 +52,8 @@ export const COCKROACHDB = 'cockroachdb';
export const COCKROACHDB_URN = `urn:li:dataPlatform:${COCKROACHDB}`;
export const DBT = 'dbt';
export const DBT_URN = `urn:li:dataPlatform:${DBT}`;
export const DREMIO = 'dremio';
export const DREMIO_URN = `urn:li:dataPlatform:${DREMIO}`;
export const DRUID = 'druid';
export const DRUID_URN = `urn:li:dataPlatform:${DRUID}`;
export const DYNAMODB = 'dynamodb';
Expand Down Expand Up @@ -133,6 +136,7 @@ export const PLATFORM_URN_TO_LOGO = {
[CLICKHOUSE_URN]: clickhouseLogo,
[COCKROACHDB_URN]: cockroachdbLogo,
[DBT_URN]: dbtLogo,
[DREMIO_URN]: dremioLogo,
[DRUID_URN]: druidLogo,
[DYNAMODB_URN]: dynamodbLogo,
[ELASTICSEARCH_URN]: elasticsearchLogo,
Expand Down
8 changes: 8 additions & 0 deletions datahub-web-react/src/app/ingest/source/builder/sources.json
Original file line number Diff line number Diff line change
Expand Up @@ -302,5 +302,13 @@
"description": "Configure a custom recipe using YAML.",
"docsUrl": "https://datahubproject.io/docs/metadata-ingestion/",
"recipe": "source:\n type: <source-type>\n config:\n # Source-type specifics config\n <source-configs>"
},
{
"urn": "urn:li:dataPlatform:dremio",
"name": "dremio",
"displayName": "Dremio",
"description": "Import Tables, Databases, Schemas, and statistics from Dremio.",
"docsUrl": "https://datahubproject.io/docs/metadata-ingestion/",
"recipe": "source:\n type: dremio\n config:\n # Coordinates\n hostname: null\n port: null\n # Credentials\n authentication_method: password\n username: null\n password: null\n stateful_ingestion:\n enabled: true"
}
]
Binary file added datahub-web-react/src/images/dremiologo.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
1 change: 1 addition & 0 deletions docs/cli.md
Original file line number Diff line number Diff line change
Expand Up @@ -705,6 +705,7 @@ Please see our [Integrations page](https://datahubproject.io/integrations) if yo
| [datahub-lineage-file](./generated/ingestion/sources/file-based-lineage.md) | _no additional dependencies_ | Lineage File source |
| [datahub-business-glossary](./generated/ingestion/sources/business-glossary.md) | _no additional dependencies_ | Business Glossary File source |
| [dbt](./generated/ingestion/sources/dbt.md) | _no additional dependencies_ | dbt source |
| [dremio](./generated/ingestion/sources/dremio.md) | `pip install 'acryl-datahub[dremio]'` | Dremio Source |
| [druid](./generated/ingestion/sources/druid.md) | `pip install 'acryl-datahub[druid]'` | Druid Source |
| [feast](./generated/ingestion/sources/feast.md) | `pip install 'acryl-datahub[feast]'` | Feast source (0.26.0) |
| [glue](./generated/ingestion/sources/glue.md) | `pip install 'acryl-datahub[glue]'` | AWS Glue source |
Expand Down
25 changes: 25 additions & 0 deletions metadata-ingestion/docs/sources/dremio/dremio_recipe.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
source:
type: dremio
config:
# Coordinates
hostname: localhost
port: 9047
tls: true

# Credentials
authentication_method: password
username: user
password: pass

include_query_lineage: True

source_mappings:
- platform: s3
platform_name: samples

schema_pattern:
allow:
- ".*"

sink:
# sink configs
3 changes: 3 additions & 0 deletions metadata-ingestion/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -375,6 +375,7 @@
"delta-lake": {*data_lake_profiling, *delta_lake},
"dbt": {"requests"} | dbt_common | aws_common,
"dbt-cloud": {"requests"} | dbt_common,
"dremio": {"requests"} | sqlglot_lib,
"druid": sql_common | {"pydruid>=0.6.2"},
"dynamodb": aws_common | classification_lib,
# Starting with 7.14.0 python client is checking if it is connected to elasticsearch client. If its not it throws
Expand Down Expand Up @@ -589,6 +590,7 @@
"clickhouse-usage",
"cockroachdb",
"delta-lake",
"dremio",
"druid",
"elasticsearch",
"feast",
Expand Down Expand Up @@ -687,6 +689,7 @@
"s3 = datahub.ingestion.source.s3:S3Source",
"dbt = datahub.ingestion.source.dbt.dbt_core:DBTCoreSource",
"dbt-cloud = datahub.ingestion.source.dbt.dbt_cloud:DBTCloudSource",
"dremio = datahub.ingestion.source.dremio.dremio_source:DremioSource",
"druid = datahub.ingestion.source.sql.druid:DruidSource",
"dynamodb = datahub.ingestion.source.dynamodb.dynamodb:DynamoDBSource",
"elasticsearch = datahub.ingestion.source.elastic_search:ElasticsearchSource",
Expand Down
Empty file.
Loading
Loading