unable to find how to integrate SparkSession with a Custom Receiver.

[kant kodali]

Hi All,

I have a Custom Receiver that implements onStart() and OnStop Methods of
the Receiver class and I am trying to figure out how to integrate with
SparkSession since I want to do stateful analytics using Structured
Streaming. I couldn't find it in the docs. any idea? When I was doing
stateless streaming I was calling
javaStreamingContext.receiverStream(CustomReceiver)
and it worked fine but now I am trying to do Structured Streaming using the
same custom receiver and I couldn't find how to integrate with
SparkSession.

Thanks!