Creating a Source using an Akka actor

Posted by hveiga on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Creating-a-Source-using-an-Akka-actor-tp2956.html

Hi,

Is there any way to create a source using an Akka actor? It would be really powerful to be able to use any akka actor as source. The only way I know now is to implement the run() method while extending the interface SourceFunction.

On the same page, it would be good to be able to use any Apache Camel endpoint as source or sink.

Is there any work planned to make this happen?

Thanks,

Héctor.