Hello, I hope this email finds you well!
I have a simple dataflow in which I read from a kafka topic, perform a map transformation and then I write the result to another topic. Based on your documentation here <https://spark.apache.org/docs/3.3.2/structured-streaming-kafka-integration.html#content>, I need to work with Dataset data structures. Even though my solution works, I need to utilize map transformation asynchronously. So my question is how can I asynchronously call map transformation with Dataset data structures in a java structured streaming environment? Can you please share a working example? I am looking forward to hearing from you as soon as possible. Thanks in advance! Kind regards ------------------------------------------------------------------ Emmanouil (Manos) Kritharakis Ph.D. candidate in the Department of Computer Science <https://sites.bu.edu/casp/people/ekritharakis/> Boston University
