Realtime stream processing analytics possible?

[cloudcompute]

Hi

Does Ballista support both realtime stream and batch processing analytics similar to what Flink does?

Spark is not a true realtime stream processor, it does this analytics in micro-batches. So where does Ballista stand in this context?

Flink has the concept of Source and Sink. It typically accepts the incoming data from a pub-sub messaging system. How can we feed realtime (and historical) data to Ballista? Can we link a distributed key-value store to it?

Thanks