This repository was archived by the owner on Sep 4, 2025. It is now read-only.

[+] add python based iceberg sink - #101

Merged

destrex271 merged 19 commits into

destrex271:mainfrom

0xgouda:add-pyiceberg-sink

Aug 26, 2025

Commits on Aug 23, 2025

implement python gRPC server code in iceberg sink
0xgouda
committed
6990d17
update .gitignore
0xgouda
committed
7305331
implement iceberg table initalization logic
0xgouda
committed
c698c75

Commits on Aug 24, 2025

Commits on Aug 25, 2025

add tests for iceberg receiver
0xgouda
committed
d2cdf7d
extract arrow schema directly from table
0xgouda
committed
b6cded9
add docstrings to methods
0xgouda
committed
e448324
fix temp `.pyiceberg.yaml` creation logic in tests
0xgouda
committed
66be6fc
ignore pytest cache
0xgouda
committed
9605dd8
run python tests in ci
0xgouda
committed
b60ed9b
add README for iceberg receiver
0xgouda
committed
17645e5
move iceberg sink `requirements.txt` to `pyiceberg_receiver/`
0xgouda
committed
96104f0
add install `requirements.txt` step to README
0xgouda
committed
5019067
increase golang tests timeout
0xgouda
committed
e615ba4
update iceberg sink `requirements.txt`
0xgouda
committed
b7ec3e1
generate python grpc code in before python tests
0xgouda
committed
da8bbe7