Hi, I am writing some code inside an update function for updateStateByKey that flushes data to a remote system using akk-http.
For the akka-http request I need an ActorSystem and an ActorFlowMaterializer. Can anyone share a pattern or insights that address the following questions: - Where and when should I instantiate the ActorSystem and ActorFlowMaterializer? - How should I obtain them in the update function? - I am aware of the ConnectionPool example[1] in the docs, but fail to understand where such an object should be created and how to pass it either. Jan [1] https://spark.apache.org/docs/1.3.1/streaming-programming-guide.html#output-operations-on-dstreams --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
