StackRating

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

thebluephantom

Rating
1474.42 (4,512,370th)
Reputation
3,105 (54,452nd)
Page: 1 ... 4 5 6 7 8 ... 14
Title Δ
Read latest records from Kafka using pyspark batch job 0.00
How to break the Key/sequence pairs in Spark RDDs into Key/Value pa... 0.00
Is there a way to compare all rows in one column of a dataframe aga... 0.00
How to save the records that are dropped by watermarking in spark s... +0.05
NGram on dataset with one word 0.00
Analyze Table Optimization in Databricks for Views 0.00
Searching for strings from column and creating new column in spark... 0.00
spark sql where clause after select 0.00
SOAP & IBM MQ JMS 0.00
Using Spark SQL joinWith, how can I join two datasets to match curr... 0.00
Hive: merge or tag multiple rows based on neighboring rows +0.04
How to concat two ArrayType(StringType()) columns element-wise in P... -0.58
How to concat two ArrayType(StringType()) columns element-wise in P... -0.58
How to transform dataframes to rdds in structured streaming? +1.18
Substracting multiple DFs in Spark 0.00
Reading files which are written using PartitionBy or BucketBy in Sp... 0.00
Is a PairRDD faster than a non-Pair RDD? 0.00
How to write result of streaming query to multiple database tables? 0.00
Spark: Is preservesPartitioning in mapPartitions ignored unless we... +0.50
How to obtain the average of an array-type column in scala-spark ov... -1.80
Spark Structured Streaming - Streaming data joined with static data... 0.00
Spark SQL alternatives to groupby/pivot/agg/collect_list using fold... -0.21
Writing Data into Hive Transactional table 0.00
Does Hive ORC ACID on Hive 3 require TEZ if not using Map Reduce? 0.00
Is it efficient to cache a dataframe for a single Action Spark appl... +0.54
Kafka's exactly-once-semantics producer side 0.00
Incremental copy between Hadoop Clusters (using Spark) given that F... 0.00
pyspark - get consistent random value across Spark sessions 0.00
What part of this code will execute on Spark driver? +0.24
Filename usage with Spark RDD 0.00
How to synchronize a function between executors in spark to avoid c... 0.00
Spark: reading tables and filtering by partition 0.00
Set column value depending on previous ones with Spark without repe... 0.00
Spark: disk I/O on stage boundaries explanation +0.54
How to get status of running driver programmatically? 0.00
Efficient execution on PySpark/Delta dataframes 0.00
Spark SQL execute multiple commands as an ACID unit 0.00
How to enforce processing only one task per executor in Spark? 0.00
How to convert the below into pyspark 2.4? 0.00
KUDU for JDBC replication purposes, but not for Off-loaded Analytics 0.00
Cannot run collect after using reduceByKey() 0.00
How do I get one row for every Min or Max on every column of a data... 0.00
What is the best way to "cache" Spark datasets between re... 0.00
Can Talend generate Scala code for Apache Spark? 0.00
Why are the results of RDD.getNumPartitions and RDD.mapPartitions d... 0.00
The way to let Spark SQL knows the Primary,Foreign,Not NULL constra... 0.00
spark sql : How to achieve parallel processing of dataframe at grou... 0.00
apache-spark-Cost Based Optimizer(CBO) stats are not used while eva... 0.00
dynamic partition pruning not clear 0.00
Is 'load' command in spark an action or transformation? +0.52