An APIs to connect systems Apache Flink to Apache Cassandra and be able to provide the functionality of streaming systems shown above, to have global state.
Note down all the situations while working with Cassandra. e.g. If something is not compatible and why? Some concepts are not possible to implement and why?
Abstract the query in API and think what data structure can be used to store the machine state in the DB.
e.g. K-Means result -> save to Cassandra
Categorise Machine learning Algorithm so that an additional argument can be passed through the query to store.
Think high level picture of the project and try to create a tutorial
System does not require strong consistency but the machine learning state should be highly available
Use case to Visualise the system for API. (check RESTAPI for reference)