Skip to content

Commit 73dc655

Browse files
committed
feat: update s3 deps & fix json serializers
1 parent 153a576 commit 73dc655

85 files changed

Lines changed: 1371 additions & 803 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

development/bruno/bruno.json

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
{
2+
"version": "1",
3+
"name": "Kasanari",
4+
"type": "collection",
5+
"ignore": [
6+
"node_modules",
7+
".git"
8+
]
9+
}

development/bruno/collection.bru

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
docs {
2+
Manual API test pipelines for Kasanari (Iceberg, Paimon, Lance).
3+
4+
Prerequisites:
5+
1. docker compose -f development/docker-compose.yml up -d
6+
2. Start Quarkus with dev profile (port 9090)
7+
3. Open this collection in Bruno and select the `dev` environment
8+
4. Run each pipeline folder top-to-bottom
9+
10+
https://www.usebruno.com/
11+
}
12+
13+
auth {
14+
mode: bearer
15+
}
16+
17+
auth:bearer {
18+
token: {{token}}
19+
}
Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
vars {
2+
baseUrl: http://localhost:9090
3+
token: dev
4+
catalogIdIcebergInternal: dev-iceberg-internal
5+
catalogIdIcebergProxy: dev-iceberg-proxy
6+
catalogIdPaimonInternal: dev-paimon-internal
7+
catalogIdPaimonProxy: dev-paimon-proxy
8+
catalogIdLanceProxy: dev-lance-proxy
9+
namespace: demo
10+
database: demo
11+
table: events
12+
s3Endpoint: http://localhost:9000
13+
jdbcUri: jdbc:postgresql://localhost:5432/postgres
14+
tableUuid:
15+
}
Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
meta {
2+
name: 01 Register catalog
3+
type: http
4+
seq: 1
5+
}
6+
7+
post {
8+
url: {{baseUrl}}/management/v1/catalogs
9+
body: json
10+
auth: inherit
11+
}
12+
13+
headers {
14+
Content-Type: application/json
15+
}
16+
17+
body:json {
18+
{
19+
"catalogId": "{{catalogIdIcebergInternal}}",
20+
"catalogType": "ICEBERG",
21+
"mode": "INTERNAL",
22+
"spec": {
23+
"fileIoProperties": {},
24+
"catalogProperties": {
25+
"kasanari.jdbc.user": "postgres",
26+
"kasanari.jdbc.password": "postgres",
27+
"uri": "{{jdbcUri}}",
28+
"warehouse": "s3a://warehouse",
29+
"io-impl": "org.apache.iceberg.aws.s3.S3FileIO",
30+
"s3.endpoint": "{{s3Endpoint}}",
31+
"s3.access-key-id": "admin",
32+
"s3.secret-access-key": "password",
33+
"s3.path-style-access": "true",
34+
"s3.client-factory": "kasanari.catalog.iceberg.s3.NoneRegionS3FileIOAwsClientFactory"
35+
}
36+
}
37+
}
38+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
meta {
2+
name: 02 Get catalog metadata
3+
type: http
4+
seq: 2
5+
}
6+
7+
get {
8+
url: {{baseUrl}}/management/v1/catalogs/ICEBERG/{{catalogIdIcebergInternal}}
9+
body: none
10+
auth: inherit
11+
}
Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
meta {
2+
name: 03 Get catalog config
3+
type: http
4+
seq: 3
5+
}
6+
7+
get {
8+
url: {{baseUrl}}/iceberg/v1/config
9+
body: none
10+
auth: inherit
11+
}
12+
13+
params:query {
14+
warehouse: {{catalogIdIcebergInternal}}
15+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
meta {
2+
name: 04 List namespaces
3+
type: http
4+
seq: 4
5+
}
6+
7+
get {
8+
url: {{baseUrl}}/iceberg/v1/{{catalogIdIcebergInternal}}/namespaces
9+
body: none
10+
auth: inherit
11+
}
Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
meta {
2+
name: 05 Create namespace
3+
type: http
4+
seq: 5
5+
}
6+
7+
post {
8+
url: {{baseUrl}}/iceberg/v1/{{catalogIdIcebergInternal}}/namespaces
9+
body: json
10+
auth: inherit
11+
}
12+
13+
headers {
14+
Content-Type: application/json
15+
}
16+
17+
body:json {
18+
{
19+
"namespace": [
20+
"{{namespace}}"
21+
],
22+
"properties": {}
23+
}
24+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
meta {
2+
name: 06 List tables
3+
type: http
4+
seq: 6
5+
}
6+
7+
get {
8+
url: {{baseUrl}}/iceberg/v1/{{catalogIdIcebergInternal}}/namespaces/{{namespace}}/tables
9+
body: none
10+
auth: inherit
11+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
meta {
2+
name: 07 List views
3+
type: http
4+
seq: 7
5+
}
6+
7+
get {
8+
url: {{baseUrl}}/iceberg/v1/{{catalogIdIcebergInternal}}/namespaces/{{namespace}}/views
9+
body: none
10+
auth: inherit
11+
}

0 commit comments

Comments
 (0)