Public signup for this instance is disabled. Go to our Self serve sign up page to request an account.
To fully support streaming on Nemo, we should support watermark.
Support Nemo Streaming
UnboundedSource WindowedWordCount ITCase
Emit collected data when receiving watermark in GroupByKeyAndWindowTransform
Add onWatermark() method to Transform
Emit watermark at unbounded source
Refactor ParentTaskDataFetcher to emit streaming data and watermark
Handle watermark in OutputWriter
Refactor TaskExecutor's data processing logic
Support side inputs and windowing