Skip to content

Latest commit

 

History

History
244 lines (143 loc) · 9.21 KB

CHANGELOG.md

File metadata and controls

244 lines (143 loc) · 9.21 KB

Changelog

v0.7.2 (2024-06-10)

  • 225e8b0 fix: udf type in multiproc source transformer (#171)

Contributors

  • Sidhant Kohli

v0.7.1 (2024-05-30)

  • 06a6fdc feat: UDF container should crash on exceptions (#160)

Contributors

  • Sidhant Kohli

v0.7.0a1 (2024-04-17)

  • 0c2501b feat: add fallback sink support (#157)
  • af095a1 fix: convert headers to dict before exposing to users (#151)

Contributors

  • Sidhant Kohli
  • Yashash H L

v0.7.0a0 (2024-03-26)

Contributors

v0.7.0 (2024-05-03)

  • 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)

Contributors

  • Abdullah Yildirim
  • Sidhant Kohli
  • Vigith Maurice
  • Yashash H L

v0.6.0 (2023-12-18)

  • e6e1261 feat: adding partitions for user defined source (#124)
  • 3e3b25f fix: require event time when dropping messages (#123)

Contributors

  • Keran Yang
  • Sidhant Kohli

v0.5.4 (2023-11-21)

  • 2f0d4c4 fix: async source init (#120)
  • b24f87d fix: typo in async_server.py (#118)

Contributors

  • Aaron Tolman
  • Sidhant Kohli

v0.5.3 (2023-10-13)

  • 71c2b52 feat: Add User Defined Source support (#114)

Contributors

  • Sidhant Kohli

v0.5.2 (2023-09-29)

  • c04a279 fix: multiproc mapper max threads and default numprocess (#112)

Contributors

  • Avik Basu

v0.5.1 (2023-09-08)

  • c5a4695 feat: add side input grpc service (#107)

Contributors

  • Sidhant Kohli

v0.5.0 (2023-09-05)

  • 0be0b48 Update flatmap stream sdk version dependency (#99)

Contributors

  • xdevxy

v0.4.2 (2023-06-07)

  • 15a6723 feat!: support len, iter and indexing on udf datatypes (#96)
  • c441ebe feat: introduce MapStreamFn for streaming map udf in async sever (#93)
  • 97d7f4e fix: update event time filter transformer to use tag (#92)

Contributors

  • Avik Basu
  • Keran Yang
  • xdevxy

v0.4.1 (2023-04-24)

  • ee753f5 feat: introduce handshake to client and gRPC server (#89)

Contributors

  • Sidhant Kohli

v0.4.0 (2023-04-14)

  • 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)

Contributors

  • Avik Basu
  • Keran Yang
  • San Nguyen
  • Sidhant Kohli
  • Vigith Maurice
  • Yashash H L
  • xdevxy

v0.3.3 (2023-02-14)

  • f13bc5f feat: reduce stream per window using asyncio (#49)
  • df9c8c8 perf: improve performance by adding slots (#47)

Contributors

  • Avik Basu
  • ashwinidulams

v0.3.2 (2022-12-21)

  • a650aac fix: time unit bug/dockerfile/add a guide (#44)

Contributors

  • Juanlu Yu

v0.3.1 (2022-12-20)

Contributors

  • Juanlu Yu

v0.3.0 (2022-12-15)

  • e717b1b feat: udsink gRPC stream (#34)
  • ad55710 fix: .flake8 file (#35)

Contributors

  • Avik Basu
  • Juanlu Yu

v0.2.6 (2022-11-22)

  • 0fbecc1 feat: introduces sync gRPC server (#27)
  • b6a4bc0 feat: add support to configure max message size (#23)

Contributors

  • Avik Basu
  • Juanlu Yu

v0.2.5 (2022-10-31)

  • 97b410e fix: catch exception in udf and udsink (#18)

Contributors

  • Avik Basu

v0.2.4 (2022-09-29)

  • 3559e15 update function socket (#12)

Contributors

  • shrivardhan

v0.2.3 (2022-09-30)

Contributors

  • Vigith Maurice

v0.2.2 (2022-09-21)

  • fd88178 fix: unix domain socket path and examples (#6)

Contributors

  • Juanlu Yu

v0.2.1 (2022-09-19)

Contributors

  • Juanlu Yu

v0.2.0 (2022-09-16)

Contributors

  • Chrome