Re: subscribe user@spark.apache.org
You have to sign up by sending an email - see http://spark.apache.org/community.html for what to send where. On Tue, Jan 19, 2021 at 12:25 PM Peter Podlovics < peter.d.podlov...@gmail.com> wrote: > Hello, > > I would like to subscribe to the above mailing list. I already tried > subscribing through the webpage, but I still haven't received the email yet. > > Thanks, > Peter >
Re: Subscribe Multiple Topics Structured Streaming
I would like to know how to create stream and sink operations outside "main" method - just like another class which I can invoke from main. So that I can have different implementations for each topic which I subscribed in a specific class file. Is it a good practice or always the whole implementations should go inside "main" method? On Mon, Sep 17, 2018 at 11:35 PM naresh Goud wrote: > You can have below statement for multiple topics > > val dfStatus = spark.readStream. > format("kafka"). > option("subscribe", "utility-status, utility-critical"). > option("kafka.bootstrap.servers", "localhost:9092"). > option("startingOffsets", "earliest") > .load() > > > > > > On Mon, Sep 17, 2018 at 3:28 AM sivaprakash < > sivaprakashshanmu...@gmail.com> wrote: > >> Hi >> >> I have integrated Spark Streaming with Kafka in which Im listening 2 >> topics >> >> def main(args: Array[String]): Unit = { >> >> val schema = StructType( >> List( >> StructField("gatewayId", StringType, true), >> StructField("userId", StringType, true) >> ) >> ) >> >> val spark = SparkSession >> .builder >> .master("local[4]") >> .appName("DeviceAutomation") >> .getOrCreate() >> >> val dfStatus = spark.readStream. >> format("kafka"). >> option("subscribe", "utility-status, utility-critical"). >> option("kafka.bootstrap.servers", "localhost:9092"). >> option("startingOffsets", "earliest") >> .load() >> >> >> } >> >> Since I have few more topics to be listed and perform different >> operations I >> would like to move each topics into separate case class for better >> clarity. >> Is it possible? >> >> >> >> -- >> Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ >> >> - >> To unsubscribe e-mail: user-unsubscr...@spark.apache.org >> >> -- > Thanks, > Naresh > www.linkedin.com/in/naresh-dulam > http://hadoopandspark.blogspot.com/ > > -- - Prakash.
Re: Subscribe Multiple Topics Structured Streaming
You can have below statement for multiple topics val dfStatus = spark.readStream. format("kafka"). option("subscribe", "utility-status, utility-critical"). option("kafka.bootstrap.servers", "localhost:9092"). option("startingOffsets", "earliest") .load() On Mon, Sep 17, 2018 at 3:28 AM sivaprakash wrote: > Hi > > I have integrated Spark Streaming with Kafka in which Im listening 2 topics > > def main(args: Array[String]): Unit = { > > val schema = StructType( > List( > StructField("gatewayId", StringType, true), > StructField("userId", StringType, true) > ) > ) > > val spark = SparkSession > .builder > .master("local[4]") > .appName("DeviceAutomation") > .getOrCreate() > > val dfStatus = spark.readStream. > format("kafka"). > option("subscribe", "utility-status, utility-critical"). > option("kafka.bootstrap.servers", "localhost:9092"). > option("startingOffsets", "earliest") > .load() > > > } > > Since I have few more topics to be listed and perform different operations > I > would like to move each topics into separate case class for better clarity. > Is it possible? > > > > -- > Sent from: http://apache-spark-user-list.1001560.n3.nabble.com/ > > - > To unsubscribe e-mail: user-unsubscr...@spark.apache.org > > -- Thanks, Naresh www.linkedin.com/in/naresh-dulam http://hadoopandspark.blogspot.com/
Re: Subscribe
Please Subscribe via the mailing list as described here: http://beam.incubator.apache.org/use/mailing-lists/ On Mon, Sep 26, 2016, 12:11 Lakshmi Rajagopalanwrote: > >
Re: subscribe
To subscribe, please go to http://spark.apache.org/community.html to join the mailing list. On Fri, Jan 8, 2016 at 3:58 AM Jeetendra Gangelewrote: > >
Re: subscribe
You should email users-subscr...@kafka.apache.org if you are trying to subscribe. On 3 January 2016 at 11:52, Rajdeep Duawrote: > >
Re: subscribe
https://www.youtube.com/watch?v=umDr0mPuyQc On Sat, Aug 22, 2015 at 8:01 AM, Ted Yu yuzhih...@gmail.com wrote: See http://spark.apache.org/community.html Cheers On Sat, Aug 22, 2015 at 2:51 AM, Lars Hermes li...@hermes-it-consulting.de wrote: subscribe - To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
Re: subscribe
See http://spark.apache.org/community.html Cheers On Sat, Aug 22, 2015 at 2:51 AM, Lars Hermes li...@hermes-it-consulting.de wrote: subscribe - To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
Re: subscribe
https://www.youtube.com/watch?v=H07zYvkNYL8 On Mon, Aug 10, 2015 at 10:55 AM, Ted Yu yuzhih...@gmail.com wrote: Please take a look at the first section of https://spark.apache.org/community Cheers On Mon, Aug 10, 2015 at 10:54 AM, Phil Kallos phil.kal...@gmail.com wrote: please
Re: subscribe
Welcome aboard! Thanks Best Regards On Thu, Aug 6, 2015 at 11:21 AM, Franc Carter franc.car...@rozettatech.com wrote: subscribe
Re: subscribe
See http://spark.apache.org/community.html Cheers On Aug 5, 2015, at 10:51 PM, Franc Carter franc.car...@rozettatech.com wrote: subscribe
Re: Subscribe
Please email user-subscr...@spark.apache.org On Apr 8, 2015, at 6:28 AM, Idris Ali psychid...@gmail.com wrote: - To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
Re: Subscribe
Send email to user-subscr...@spark.apache.org Cheers On Fri, Jan 16, 2015 at 11:51 AM, Andrew Musselman andrew.mussel...@gmail.com wrote:
Re: subscribe me to the list
Hi Ningjun Please send email to this address to get subscribed: user-subscr...@spark.apache.org On Dec 5, 2014, at 10:36 PM, Wang, Ningjun (LNG-NPV) ningjun.w...@lexisnexis.com wrote: I would like to subscribe to the user@spark.apache.org Regards, Ningjun Wang Consulting Software Engineer LexisNexis 121 Chanlon Road New Providence, NJ 07974-1541
Re: subscribe
send this to 'user-request', not 'user' 2014-03-10 17:32 GMT+08:00 hequn cheng chenghe...@gmail.com: hi