clear query| facets| time Search criteria: .   Results from 21 to 30 from 768 (0.0s).
Loading phrases to help you
refine your search...
What is the default value I can specify for bytes when it is in union? - Avro - [mail # user]
...Hi All,What is the default value I can specify for bytes when it is in union?Tried the following and all fail.{"type":"record","name":"hello","fields":[{"name":"id","type":["bytes","null"],"...
   Author: kant kodali , 2018-06-04, 09:02
is it possible to create one KafkaDirectStream (Dstream) per topic? - Spark - [mail # user]
...Hi All,I have 5 Kafka topics and I am wondering if is even possible to create oneKafkaDirectStream (Dstream) per topic within the same JVM i.e using onlyone sparkcontext?Thanks!...
   Author: kant kodali , 2018-05-20, 22:25
[expand - 1 more] - [VOTE] Spark 2.3.1 (RC1) - Spark - [mail # dev]
...I am not sure how SPARK-23406 is a new feature. sincestreaming joins are already part of SPARK 2.3.0. The self joins didn't workbecause of a bug and it is fixed but I can understand if ...
   Author: kant kodali , 2018-05-16, 21:15
What to consider when implementing a custom streaming sink? - Spark - [mail # user]
...Hi All,I am trying to implement a custom sink and I have few questions mainly onoutput modes.1) How does spark let the sink know that a new row is an update of anexisting row? does it look a...
   Author: kant kodali , 2018-05-15, 10:06
I cannot use spark 2.3.0 and kafka 0.9? - Spark - [mail # user]
...Hi All,This link seems to suggest I cant use Spark 2.3.0 and Kafka 0.9 broker. isthat correct?https://spark.apache.org/docs/latest/streaming-kafka-integration.htmlThanks!...
   Author: kant kodali , 2018-05-04, 09:03
[expand - 2 more] - question on collect_list or say aggregations in general in structured streaming 2.3.0 - Spark - [mail # user]
...1) I get an error when I set watermark to 0.2) I set window and slide interval to 1 second with no watermark. It sillaggregates messages from the previous batch that are in 1 second window.s...
   Author: kant kodali , 2018-05-04, 08:39
what is the query language used for graphX? - Spark - [mail # user]
...Hi All,what is the query language used for graphX? are there any plans tointroduce gremlin or is that idea being dropped and go with Spark SQL?Thanks!...
   Author: kant kodali , 2018-05-02, 11:01
is there a minOffsetsTrigger in spark structured streaming 2.3.0? - Spark - [mail # user]
...Hi All,just like maxOffsetsTrigger is there a minOffsetsTrigger in sparkstructured streaming 2.3.0?Thanks!...
   Author: kant kodali , 2018-04-29, 10:20
[expand - 2 more] - A naive ML question - Spark - [mail # user]
...Hi Nick,Thanks for that idea!! Just to be more clear. The problem I am trying tosolve is that when a bunch of financial transactional data is thrown at meI am trying to identify all possible...
   Author: kant kodali , 2018-04-29, 10:19
[expand - 1 more] - is it ok to make I/O calls in UDF? other words is it a standard practice ? - Spark - [mail # user]
...yes for sure it works. I am just not sure if it is a good idea when gettinga stream of messages from kafka?On Mon, Apr 23, 2018 at 2:54 PM, Sathish Kumaran Vairavelu <[EMAIL PROTECTED]>...
   Author: kant kodali , 2018-04-23, 22:36