I am looking for a generic schema aware feed construct for streaming workflow. The schema can be managed by a catalog service like HCatalog. The streaming workflow executor would be a system like Storm/SparkStreaming/Samza.
I want to know if this is the right thing to be supported in Falcon and if yes what is the plugging interface for that. Would this be a new implementation of workflow engine ? Thanks Sharad
