source -> pipe -> compute queues should have a backpressure

cylondata / twister2

A composable framework for fast and scalable data analytics

https://twister2.org

Apache License 2.0

57 stars 32 forks source link

Open supunkamburugamuve opened 3 years ago

supunkamburugamuve commented 3 years ago

If the compute is slow it should be propergated to the source, and source should stop reading