Skip to content

Commit 7df9291

Browse files
razvanadwk67
andauthored
test: add integration test for the delta lake catalog (#871)
* test: add delta catalog test * document delta properties * comment out parquet column index workaround * typo * cleanup * Apply suggestions from code review Co-authored-by: Andrew Kenworthy <1712947+adwk67@users.noreply.github.com> --------- Co-authored-by: Andrew Kenworthy <1712947+adwk67@users.noreply.github.com>
1 parent 6cdffb9 commit 7df9291

31 files changed

+1140
-1
lines changed

tests/spark/.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
.gradle/

tests/spark/README.md

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
This application was used to produce the `delta-table` for the delta kuttl test.
2+
3+
It cannot be placed in the delta test folder because beku tries to recurse into it and fails.
4+
5+
To run it, you need a S3 (minio) available. Update the variables below as needed:
6+
7+
S3_ENDPOINT=https://localhost:9000 \
8+
S3_ACCESS_KEY=minioAccessKey \
9+
S3_SECRET_KEY=minioSecretKey \
10+
S3_SKIP_TLS_VALIDATION=true \
11+
DELTA_TABLE_PATH=s3a://trino/delta-table \
12+
./gradlew run

tests/spark/build.gradle

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
plugins {
2+
id 'java'
3+
id 'application'
4+
}
5+
6+
group = 'org.example'
7+
version = '1.0-SNAPSHOT'
8+
9+
application {
10+
mainClass = 'org.example.Main'
11+
applicationDefaultJvmArgs = [
12+
'--add-opens=java.base/sun.nio.ch=ALL-UNNAMED'
13+
]
14+
}
15+
16+
repositories {
17+
mavenCentral()
18+
}
19+
20+
21+
dependencies {
22+
23+
// Source: https://mvnrepository.com/artifact/org.apache.spark/spark-sql
24+
implementation 'org.apache.spark:spark-sql_2.12:3.5.5'
25+
// Source: https://mvnrepository.com/artifact/io.delta/delta-spark
26+
implementation 'io.delta:delta-spark_2.12:3.3.2'
27+
// Source: https://mvnrepository.com/artifact/org.apache.hadoop/hadoop-aws
28+
implementation 'org.apache.hadoop:hadoop-aws:3.3.4'
29+
// Source: https://mvnrepository.com/artifact/com.amazonaws/aws-java-sdk-bundle
30+
implementation 'com.amazonaws:aws-java-sdk-bundle:1.12.262'
31+
32+
testImplementation platform('org.junit:junit-bom:5.10.0')
33+
testImplementation 'org.junit.jupiter:junit-jupiter'
34+
testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
35+
}
36+
37+
test {
38+
useJUnitPlatform()
39+
}
47.8 KB
Binary file not shown.
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
distributionBase=GRADLE_USER_HOME
2+
distributionPath=wrapper/dists
3+
distributionUrl=https\://services.gradle.org/distributions/gradle-9.4.1-bin.zip
4+
networkTimeout=10000
5+
validateDistributionUrl=true
6+
zipStoreBase=GRADLE_USER_HOME
7+
zipStorePath=wrapper/dists

tests/spark/gradlew

Lines changed: 248 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)