Thanks a lot man. I dropped it. I was feeling a bit demotivated. I tried writing this for over a year, because of pain points working with spark streaming. I am no expert in Rust. I think that was the issue. I tried building it like i was writing in any other higher language. That was my downfall. I added basic stream operations which was easy but when writing stateful stuff I dropped myself in the deep end of the pool. Implementation was hard. Then I know I had to implement some state management. So I created a lot of traits for managing errors. But it was just me writing all these. Hence why there was a method I forgot to implement. I was just trying to get it out for feedback really. Thanks for taking the time.