StackRating

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

Jacek Laskowski

Rating
1525.89 (22,827th) 		Reputation
48,121 (2,126th)
Page: 1 2 3 4 5 6 ... 26
Title Δ
How to fix "ImportError: PyArrow >= 0.8.0 must be installed... 0.00
How to write a streaming DataFrame out to Kafka with all rows as JS... +0.47
Scala => with = 0.00
Is there any difference between joining tables and exists when filt... 0.00
What is the difference between DStream and Seq[RDD]? 0.00
How to know the name of Kafka consumer group that streaming query u... 0.00
How to execute queries on Hive tables sent over Kafka in Spark Stre... 0.00
How to implement exactly-once processing when reading reading from... 0.00
How to check how many cores PySpark uses? 0.00
How to run query for each record in a dataframe? 0.00
Spark SQL explain plan calls the temporary table calculation many t... 0.00
Where does log4j writes the logs in cluster mode? +0.21
Exception has occurred: pyspark.sql.utils.AnalysisException 'Qu... 0.00
Do Spark Streaming and Spark Structured Streaming use same micro-ba... +1.97
multiple queries in a Spark Struct Streaming job, so how to cache d... 0.00
How to get progress of streaming query after awaitTermination? 0.00
How to skip header in multi-line records when consuming data from K... 0.00
How to specify number of partitions for different code parts of a s... 0.00
How to merge two or more columns into one? +0.17
Why does streaming aggregation delay until two batches of data alwa... 0.00
What does "method process in class ForeachWriter of type (valu... 0.00
Why does Kafka Streams app fail with AccessDeniedException on Windo... 0.00
How to write spark structured streaming data to REST API? 0.00
Too many UnknownProducerIdException in kafka broker for kafka inter... 0.00
How to access nested schema column? +0.48
How to update HDFS files after every trigger? 0.00
How to read ASCII file with variable delimiters? 0.00
How does Spark handle failure scenarios involving JDBC data source? -0.53
How to write windowed aggregation in CSV format? 0.00
How to collect a streaming dataset (to a Scala value)? 0.00
How to run multiple batches when streaming from HDFS source? 0.00
How to access value in array of structs? 0.00
Why does Dataset.unpersist cascade to all dependent cached Datasets? 0.00
How to specify retention period of join window? 0.00
How to insert spark structured streaming DataFrame to Hive external... +0.50
How to use different Spark version (Spark 2.4) on YARN cluster depl... -0.02
How to optimize streaming aggregation with socket data source? 0.00
How to query nested Array type of a json file using Spark? +0.48
How to run streaming query on updated lines in CSV file? +0.47
How to set CHARACTER SET for writing to MySQL table using JDBC data... +0.47
How to access global temp view in another pyspark application? 0.00
How to set up metadata database for Spark SQL? +0.48
How to execute Hive query inside sparkcontext.parallelize(.......).... 0.00
How to pass Row in UDF? 0.00
How to convert DataFrame to Dataset[CaseClass]? +0.48
How to get all products with at least X reviews in SQL? -0.66
How to find common elements among two array columns? +0.92
Why does streaming query not write any data to HDFS? 0.00
When to use "sbt assembly" and "sbt compile &&am... +0.47
How to head DataFrame with Map[String,Long] column and preserve typ... -1.06