HDFS Persistence in Streaming Shell

[lenlen]

It is possible, using streaming shell, save the output in a simple file (as txt, csv, ...) in HDFS? Reading the doc seems that only Cassandra, MongoDB and ElasticSearch are supported. If not which classes I need to modify to achieve this?

[david-morales]

Hi,

It's possible and it could be a nice feature for our next release.

You can take a look at the functions (save2cassandra...) here:

https://github.com/Stratio/streaming-cep- engine/tree/master/engine/src/main/java/com/stratio/streaming/functions

But this feature also involves changes in the language, since it will be a new action to be applied on the streams.