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

Adding config option for checkpointing #50

Merged
merged 10 commits into from
Nov 7, 2024
Merged

Conversation

ameyc
Copy link
Contributor

@ameyc ameyc commented Oct 25, 2024

No description provided.

@ameyc ameyc requested a review from emgeee October 25, 2024 11:00
Copy link
Contributor

@emgeee emgeee left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Config interface looks good

@ameyc ameyc merged commit ebcde97 into main Nov 7, 2024
11 checks passed
@ameyc ameyc deleted the amey/adding-config-option branch November 7, 2024 21:57
ameyc added a commit that referenced this pull request Nov 13, 2024
* Adding config option for checkpointing

* Add maturin build step for ci (#52)

* fix: correct python module name

* Fixing the streaming join example (#54)

* Fixing the streaming join example

* format

* add drop_columns

* update python internal package name

---------

Co-authored-by: Matt Green <[email protected]>

* merge with main

* Adding config option for checkpointing

* merge with main

* Cargo fmt

---------

Co-authored-by: Matt Green <[email protected]>
ameyc added a commit that referenced this pull request Nov 13, 2024
* Add example python udaf

* Fixing the streaming join example (#54)

* Fixing the streaming join example

* format

* add drop_columns

* update python internal package name

---------

Co-authored-by: Matt Green <[email protected]>

* Implement stream join in python (#51)

* Implement stream join in python

* update

* fmt

* clippy fmt

* example works

* fmt

* Adding config option for checkpointing (#50)

* Adding config option for checkpointing

* Add maturin build step for ci (#52)

* fix: correct python module name

* Fixing the streaming join example (#54)

* Fixing the streaming join example

* format

* add drop_columns

* update python internal package name

---------

Co-authored-by: Matt Green <[email protected]>

* merge with main

* Adding config option for checkpointing

* merge with main

* Cargo fmt

---------

Co-authored-by: Matt Green <[email protected]>

* Rm hardcoded checkpoint (#55)

* Add dockerfile to run emit_measurements and kafka (#56)

* Add dockerfile to run emit_measurements and kafka

* Add ability to specify timestamp_column on kafka stream (#57)

* Add example python udaf

* Fixing the UDAF example

* merge main

---------

Co-authored-by: Amey Chaugule <[email protected]>
Co-authored-by: Amey Chaugule <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants