[Spark Structured Streaming] predicate pushdown in custom connector source.
This post was updated on .
I'm trying to implement structured spark streaming source for a custom
connector. I'm wondering if it is possible to do predicate pushdown in the
streaming source? I'm aware this may be something native to the datastore in
question. However, I would really appreciate if someone can redirect me to
an existing connector, which does it.