StackRating

An Elo-based rating system for Stack Overflow
Home   |   About   |   Stats and Analysis   |   Get a Badge
Rating Stats for

David Griffin

Rating
1521.92 (28,405th)
Reputation
9,074 (17,079th)
Page: 1 2 3 ... 5
Title Δ
How can i get list of topics from kafka server using kafka-node lib... 0.00
Comparing two RDDs -0.54
to check the existence of kafka topic in nodejs 0.00
Is there any way to delete a topic in kafka-node 0.00
spark dataframe calculated column 0.00
kafka-node - pass arguments to async function consumer.on(); 0.00
Spark - scala Window-lead function and case statment result is not... 0.00
Is it possible to create a topic with Kafka Rest Proxy? 0.00
How do I detach/close JavaDStream and TwitterUtils.createStream(...) 0.00
Aggregating multiple columns with custom function in spark +2.04
Node.js: How to use kafka-node for fetching messages from beginning... 0.00
Spark: convert rdd[row] to dataframe where one of the columns in th... 0.00
-bash: kafka-server-start.sh: command not found 0.00
Store inverted index in Spark 0.00
Graph constructed using graphx is not getting broadcast-ed properly 0.00
Spark Deduplicate column in dataframe based on column in other data... 0.00
moving median as a window function (UDAF) in Apache Spark SQL 0.00
How to define the parameters inside of KafkaUtils.createDirectStrea... 0.00
How to handle out of order asynchronous update? 0.00
Automatic spark schema inference for custom data source 0.00
Understanding Kafka Partition Metadata 0.00
How to map spark DataFrame row values to columns? 0.00
Automatically and Elegantly flatten DataFrame in Spark SQL +0.47
Spark Streaming or Storm for streaming processing? 0.00
How to insert or update spark rdd which is already loaded from exte... +0.48
How do I ensure that logs are retained forever in Kafka? 0.00
Spark DataFrame aggregate column values by key 0.00
what are other approaches instead of using collect() in spark scala 0.00
Spark UDF error - Schema for type Any is not supported 0.00
How to use Spark graph's function mask? 0.00
UDAF in Spark with multiple input columns 0.00
Why does Spark Streaming stop working when I send two input streams? 0.00
create Array[Struct] in Spark using existing columns of DataFrame 0.00
Spark dataframe - how to fill nulls with sequential integer values? 0.00
how to write case with when condition in spark sql using scala 0.00
Is var used when we do Spark programming in Scala? -0.01
Spark RDD.cache changes output 0.00
How to convert a case-class-based RDD into a DataFrame? -0.54
How to replace epoch column in DataFrame with date in scala +1.18
stop spark Streaming context kafkaDirectStream -0.03
Grouping a column as list in spark 0.00
How to define multiple serializers in kafka? +0.01
Can I create an RDD from a kafka topic if I do not know the until o... 0.00
Encode GenericData.Record field separately as encoded key 0.00
Apache Kafka Scaling Topics using partitions 0.00
Difference between the vertex program and Merge Message part in Pre... 0.00
Why Spark SQL considers the support of indexes unimportant? -0.24
For GraphX how do i convert an array of object to an array of Edges 0.00
Spark: What is the time complexity of the connected components algo... 0.00
Read specific messages using Apache Kafka and NodeJS 0.00