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 4 ... 5
Title Δ
In Spark SQL, how do you register and use a generic UDF? +2.23
Converting a Spark Dataframe to a Scala Map collection +0.46
Merging micro batches in Spark Streaming 0.00
SparkSQL second explode after the first explode 0.00
Take only the first (or nth) element after explode 0.00
Spark Streaming from Kafka Source Go Back to a Checkpoint or Rewind... 0.00
Mid-Stream Changing Configuration with Check-Pointed Spark Stream +0.68
Spark:Error writing stream to file /XXX/stderr java.io.IOException:... -0.52
Creating a dataframe of rows of many fields in Spark -0.01
Shortcuts for creating complicated Column structures in Spark 0.00
Spark: Task not Serializable for UDF on DataFrame 0.00
How to deploy custom libraries to Apache Spark? 0.00
identify records in parent dataframe which are not present in subse... +0.47
spark udf with data frame 0.00
How to Find the maximum consecutive years for each ID using Scala /... +1.47
Splitting string in dataset Apache Spark 0.00
get topic from kafka message in spark +1.92
controlling fields nullability in spark-sql and dataframes 0.00
Recursive case class to DataFrame 0.00
Terms in Apache Kafka -0.51
SparkSQL datetime function 0.00
kafka + storm topology vs microservices -0.01
kafka + storm topology vs microservices -0.01
SPARK - Joining two data streams - maintenance of cache -0.02
mkString and sortByKey are not working with Arrays in Spark -0.53
Handling RDDs to an specific worker in Apache Spark 0.00
extract or filter MapType of Spark DataFrame 0.00
How should I structure this execution flow in Spark? 0.00
Avro with Kafka - Deserializing with changing schema 0.00
Kafka : Does Kafka provide support for application level state tran... 0.00
Store about 120 Column based flat data structure to Spark Parquet S... 0.00
Spark : anti-join two DStreams 0.00
How can i get the Avro schema object from the received message in k... 0.00
Why Mutable map becomes immutable automatically in UserDefinedAggre... 0.00
Defining new schema for Spark Rows 0.00
Scala +Spark+Dataframe Exception When i try to dynamically cast a c... 0.00
spark: How to do a dropDuplicates on a dataframe while keeping the... -0.52
add new column (string length) to df by UserDefinedFunction in spar... +2.47
Does GraphFrames api support creation of Bipartite graphs? 0.00
What is the best way to publish and consume different type of messa... 0.00
I want to convert all my existing UDTFs in Hive to Scala functions... -0.02
Aggregation with arbitrary granularity in Spark 0.00
Spark drop colums with 0 or NaN 0.00
no valid constructor on spark 0.00
How to create custom UDF for Spark SQL? 0.00
SPARK : Set a column value based on multiple row conditions -0.88
Spark Dataset API - join -0.03
Spark - Random Number Generation -0.52
Add column with a case in spark 0.00
Retrieve a message by knowing its partition and offset in Kafka -0.52