vanekjar questions

vanekjar answers

• How did Apache Spark implement its topK() API?
• What is spark.streaming.receiver.maxRate? How does it work with batch interval
• wrong value class: class org.apache.hadoop.io.Text is not class org.apache.hadoop.io.IntWritable
• Sending key-value pairs payload to Google Analytics
• Spark Streaming get warn "replicated to only 0 peer(s) instead of 1 peers"
• Android Sqlite Performance
• What is the correct way to start/stop spark streaming jobs in yarn?
• Apache Spark does not delete temporary directories