use ES as DStream source?

[bwalsh]

Hi. Great job. I found the examples to be very useful.

The examples here show opening a Twitter stream and writing to ES. I was wondering if there was a way to write a spark StreamingContext that will observe updates to ES?

Something like

ssc.elasticSearchStream(...)

Thanks for your time.

-b