Skip to content

Commit 4e0acf7

Browse files
committed
chore: trying stuff
1 parent 66c6d27 commit 4e0acf7

File tree

5 files changed

+37
-19
lines changed

5 files changed

+37
-19
lines changed
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
id: 22ed2a5a-1778-4431-ab2a-b546c4c3a1e4

nessie-stack/jaffle-shop-classic-spark/dbt_project.yml

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ name: 'jaffle_shop'
33
config-version: 2
44
version: '0.1'
55

6-
profile: 'jaffle_shop'
6+
profile: 'spark_profile'
77

88
model-paths: ["models"]
99
seed-paths: ["seeds"]
@@ -21,6 +21,7 @@ require-dbt-version: [">=1.0.0", "<2.0.0"]
2121

2222
models:
2323
jaffle_shop:
24+
+table_format: iceberg
2425
materialized: table
2526
staging:
2627
materialized: view

nessie-stack/jaffle-shop-classic-spark/profiles.yaml

Lines changed: 0 additions & 17 deletions
This file was deleted.
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
spark_profile:
2+
target: dev
3+
outputs:
4+
dev:
5+
type: spark
6+
method: thrift
7+
host: localhost
8+
port: 10000 # Default Spark Thrift port, adjust if needed
9+
user: # leave blank if not using auth
10+
password: # leave blank if not using auth
11+
database: default # or your specific database
12+
schema: default # or your specific schema
13+
threads: 1
14+
connect_timeout: 60
15+
connect_retries: 5
16+
connect_retry_wait: 5
17+
# Iceberg specific configurations
18+
catalog: iceberg # The name of your Iceberg catalog
19+
20+
# Additional Spark configurations for Iceberg
21+
connect_args:
22+
spark.jars.packages: org.apache.iceberg:iceberg-spark-runtime-3.5_2.12:1.8.1,org.projectnessie.nessie-integrations:nessie-spark-extensions-3.5_2.12:0.102.5
23+
spark.sql.extensions: org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions,org.projectnessie.spark.extensions.NessieSparkSessionExtensions
24+
spark.sql.catalog.iceberg: org.apache.iceberg.spark.SparkCatalog
25+
spark.sql.catalog.iceberg.type: nessie
26+
spark.sql.catalog.iceberg.warehouse: s3a://warehouse
27+
spark.sql.catalog.iceberg.uri: http://nessie:19120/api/v1
28+
spark.sql.catalog.iceberg.ref: main
29+
spark.sql.catalog.iceberg.io-impl: org.apache.iceberg.aws.s3.S3FileIO
30+
spark.sql.catalog.iceberg.s3.endpoint: http://minio:9000
31+
spark.sql.catalog.iceberg.s3.path-style-access: true
32+
spark.sql.catalog.iceberg.s3.impl: org.apache.hadoop.fs.s3a.S3AFileSystem
33+
spark.sql.catalog.iceberg.s3.access.key: minioadmin
34+
spark.sql.catalog.iceberg.s3.secret.key: minioadmin

nessie-stack/spark/spark-defaults.conf

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
# Example:
2222
# Iceberg extensions
2323
spark.sql.extensions org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions,org.projectnessie.spark.extensions.NessieSparkSessionExtensions
24-
2524
# Iceberg catalog configuration
2625
spark.sql.catalog.iceberg org.apache.iceberg.spark.SparkCatalog
2726
spark.sql.catalog.iceberg.type nessie

0 commit comments

Comments
 (0)