Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can express both batch and stream transformations.
Outputs have to be stateful operators to fully support fault tolerance, checkpointing and rewinding (if applicable). Introducing this into the common DAG will also solve #255.
je-ik
commented
6 years ago
Outputs have to be stateful operators to fully support fault tolerance, checkpointing and rewinding (if applicable). Introducing this into the common DAG will also solve #255.