RE: Spark SQL DataFrame to Kafka Topic

2017-05-16 Thread Revin Chalil
Thanks Michael, that worked, appreciate your help. From: Michael Armbrust [mailto:mich...@databricks.com] Sent: Monday, May 15, 2017 11:45 AM To: Revin Chalil Cc: User Subject: Re: Spark SQL DataFrame to Kafka Topic The foreach sink from that blog post requires that you have a DataFrame with

Re: Spark SQL DataFrame to Kafka Topic

2017-05-15 Thread Michael Armbrust
ted. Thank you. > > > > > > *From:* Tathagata Das [mailto:tathagata.das1...@gmail.com] > *Sent:* Friday, January 13, 2017 3:31 PM > *To:* Koert Kuipers > *Cc:* Peyman Mohajerian ; Senthil Kumar < > senthilec...@gmail.com>; User ; > senthilec...@apache.org &g

RE: Spark SQL DataFrame to Kafka Topic

2017-05-15 Thread Revin Chalil
Kumar ; User ; senthilec...@apache.org; Ofir Manor ; Hemanth Gudela ; lucas.g...@gmail.com; Koert Kuipers ; silvio.fior...@granturing.com Subject: RE: Spark SQL DataFrame to Kafka Topic Hi TD / Michael, I am trying to use the foreach sink to write to Kafka and followed this<ht

RE: Spark SQL DataFrame to Kafka Topic

2017-05-14 Thread Revin Chalil
.das1...@gmail.com] Sent: Friday, January 13, 2017 3:31 PM To: Koert Kuipers Cc: Peyman Mohajerian ; Senthil Kumar ; User ; senthilec...@apache.org Subject: Re: Spark SQL DataFrame to Kafka Topic Structured Streaming has a foreach sink, where you can essentially do what you want wit

Re: Spark SQL DataFrame to Kafka Topic

2017-01-24 Thread ayan guha
Is there a plan to have this in pyspark in dome later release? On Wed, 25 Jan 2017 at 10:01 am, Koert Kuipers wrote: > i implemented a sink using foreach it was indeed straightforward thanks > > On Fri, Jan 13, 2017 at 6:30 PM, Tathagata Das < > tathagata.das1...@gmail.com> wrote: > > Structured

Re: Spark SQL DataFrame to Kafka Topic

2017-01-24 Thread Koert Kuipers
i implemented a sink using foreach it was indeed straightforward thanks On Fri, Jan 13, 2017 at 6:30 PM, Tathagata Das wrote: > Structured Streaming has a foreach sink, where you can essentially do what > you want with your data. Its easy to create a Kafka producer, and write the > data out to k

Re: Spark SQL DataFrame to Kafka Topic

2017-01-13 Thread Tathagata Das
Structured Streaming has a foreach sink, where you can essentially do what you want with your data. Its easy to create a Kafka producer, and write the data out to kafka. http://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#using-foreach On Fri, Jan 13, 2017 at 8:28 AM, K

Re: Spark SQL DataFrame to Kafka Topic

2017-01-13 Thread Koert Kuipers
how do you do this with structured streaming? i see no mention of writing to kafka On Fri, Jan 13, 2017 at 10:30 AM, Peyman Mohajerian wrote: > Yes, it is called Structured Streaming: https://docs. > databricks.com/_static/notebooks/structured-streaming-kafka.html > http://spark.apache.org/docs/

Re: Spark SQL DataFrame to Kafka Topic

2017-01-13 Thread Peyman Mohajerian
Yes, it is called Structured Streaming: https://docs.databricks.com/_static/notebooks/structured-streaming-kafka.html http://spark.apache.org/docs/latest/structured-streaming-programming-guide.html On Fri, Jan 13, 2017 at 3:32 AM, Senthil Kumar wrote: > Hi Team , > > Sorry if this question