- 225e8b0 fix: udf type in multiproc source transformer (#171)
- Sidhant Kohli
- 06a6fdc feat: UDF container should crash on exceptions (#160)
- Sidhant Kohli
- 0c2501b feat: add fallback sink support (#157)
- af095a1 fix: convert headers to dict before exposing to users (#151)
- Sidhant Kohli
- Yashash H L
- 06a6fdc feat: UDF container should crash on exceptions (#160)
- 0c2501b feat: add fallback sink support (#157)
- af095a1 fix: convert headers to dict before exposing to users (#151)
- 5d99fb8 feat: support headers for message (#138)
- 04914fa fix: readme (#143)
- b366e2f feat: implement reduce streaming (#134)
- c3f9c60 feat: implement update script #102 (#137)
- df6afe6 feat: add support for new reduce proto (#133)
- 39ec103 feat: class based refactor for SDK (#129)
- Abdullah Yildirim
- Sidhant Kohli
- Vigith Maurice
- Yashash H L
- e6e1261 feat: adding partitions for user defined source (#124)
- 3e3b25f fix: require event time when dropping messages (#123)
- Keran Yang
- Sidhant Kohli
- Aaron Tolman
- Sidhant Kohli
- 71c2b52 feat: Add User Defined Source support (#114)
- Sidhant Kohli
- c04a279 fix: multiproc mapper max threads and default numprocess (#112)
- Avik Basu
- c5a4695 feat: add side input grpc service (#107)
- Sidhant Kohli
- 0be0b48 Update flatmap stream sdk version dependency (#99)
- xdevxy
- 15a6723 feat!: support len, iter and indexing on udf datatypes (#96)
- c441ebe feat: introduce
MapStreamFnfor streaming map udf in async sever (#93) - 97d7f4e fix: update event time filter transformer to use tag (#92)
- Avik Basu
- Keran Yang
- xdevxy
- ee753f5 feat: introduce handshake to client and gRPC server (#89)
- Sidhant Kohli
- 58ff85c chore!: remove support for py3.8; add 3.11 (#85)
- 405c5cd doc: explain how to use datum metadata. (#78)
- d252283 feat: introducing tags for conditional forwarding (#76)
- 786b48e feat: Add ID and numDelivered fields to Datum in udf (#77)
- 1849f10 fix: doc typo fix (#75)
- d142648 feat: add multiprocessing support for Map (#73)
- acba109 feat: support for multi keys (#72)
- 6fa43d6 fix: stream to stdout stderr based on log level (#69)
- f6c914e fix: store strong references of task objects (#66)
- 3e81304 refactor: make default constructor private for Message/MessageT (#67)
- cd8eac2 feat: add mapt sdk support (#64)
- ea78057 feat: bidirectional streaming for reduce (#55)
- Avik Basu
- Keran Yang
- San Nguyen
- Sidhant Kohli
- Vigith Maurice
- Yashash H L
- xdevxy
- f13bc5f feat: reduce stream per window using asyncio (#49)
- df9c8c8 perf: improve performance by adding slots (#47)
- Avik Basu
- ashwinidulams
- a650aac fix: time unit bug/dockerfile/add a guide (#44)
- Juanlu Yu
- d33ddd0 feat: udf reduce (#40)
- Juanlu Yu
- Avik Basu
- Juanlu Yu
- 0fbecc1 feat: introduces sync gRPC server (#27)
- b6a4bc0 feat: add support to configure max message size (#23)
- Avik Basu
- Juanlu Yu
- 97b410e fix: catch exception in udf and udsink (#18)
- Avik Basu
- 3559e15 update function socket (#12)
- shrivardhan
- dd861c0 doc: update UDSink (#10)
- Vigith Maurice
- fd88178 fix: unix domain socket path and examples (#6)
- Juanlu Yu
- 043e109 feat: udsink gRPC (#5)
- Juanlu Yu
- 496543c feature: gRPC (#4)
- Chrome