Canal establishes a convention for composable stream processing functions and provides a simple library for chaining such stream processing functions in a directed acyclic graph.
Introduction to Stream Processing
Enter search terms or a module, class or function name.