All pull requests

Pull requests

• Release completed keyed partition state

  #503·akshitkhokhani opened Oct 26, 2026·

  ·

• Release metadata references in partition_unique

  #502·harbinresearcher opened Oct 11, 2026·

  ·
  1

  1

• Transfer to notebook

  #448·martindurant opened Dec 30, 2021Member·

  ·
  1

• Add Stream node constructor for sub-classing #442

  #445·florentbr opened Dec 10, 2021·

  ·
  11

• Generic exception handling

  #433·freol35241 opened Oct 1, 2021·

  ·
  11

• Add filter class to dask and do the tests for it

  #283·xuzifan08 opened Nov 25, 2019·

  ·
  9

• Added to_kafka directly from a Dask worker

  #279·jsmaupin opened Oct 9, 2019Contributor·

  ·
  13

• cover tests

  #273·CJ-Wright opened Sep 9, 2019Member·

  ·
  13

• add reset_stream to accumulate

  #249·CJ-Wright opened May 7, 2019Member·

  ·
  4