i think probably the best implementation is from this: https://github.com/huawei-noah/streamDM but it is spark. it is based on this paper: https://dl.acm.org/doi/10.1145/347090.347107 also another implementation: https://github.com/soundcloud/spdt
i think probably the best implementation is from this: https://github.com/huawei-noah/streamDM
but it is spark.
it is based on this paper: https://dl.acm.org/doi/10.1145/347090.347107
also another implementation:
https://github.com/soundcloud/spdt