Is it possible to call batch job on a streaming context?
what i want to do is:
for a given input event, fetch cassandra elements based on event data, apply transformation on them and apply a ranking when all elements fetched by cassandra are processed.
If i do this in batch mode i would have to submit a job on each events and i can have an event every 45 seconds.
Is there any alternative? can i start a batch job that will receive some external request, process it and wait for another request?