Logo Questions Linux Laravel Mysql Ubuntu Git Menu
HTML CSS JAVASCRIPT SQL PYTHON PHP BOOTSTRAP JAVA JQUERY R React Kotlin
 

New posts in spark-streaming

Reading latest in spark kafka streaming

apache-spark apache-kafka spark-streaming

"java.io.NotSerializableException: org.apache.spark.streaming.StreamingContext" When execute spark streaming

apache-spark spark-streaming

Why are Apache Spark worker executor killed with exit status 1?

hadoop apache-spark mapreduce spark-streaming

How to give dependent jars to spark submit in cluster mode

apache-spark spark-streaming

Cannot call methods on a stopped SparkContext

scala apache-spark spark-streaming

How can I make (Spark1.6) saveAsTextFile to append existing file?

apache-spark spark-streaming apache-spark-sql

Exception while accessing KafkaOffset from RDD

scala apache-spark apache-kafka spark-streaming rdd

How to save/insert each DStream into a permanent table

apache-spark pyspark apache-spark-sql spark-streaming

How can I control the number of output files written from Spark DataFrame?

scala apache-spark apache-kafka apache-spark-sql spark-streaming

Why is the "topics" argument of KafkaUtils.createStream() a Map rather then array?

java apache-spark apache-kafka spark-streaming

How do I start Spark's Shell on Window's 8.1?

scala spark-streaming

How to set offset committed by the consumer group using Spark's Direct Stream for Kafka?

java apache-spark apache-kafka spark-streaming

How to solve "Exception in thread "main" org.apache.spark.SparkException: Application application finished with failed status"?

apache-spark spark-streaming

Spark doesnt print outputs on the console within the map function

scala apache-spark spark-streaming

RestAPI service call from Spark Streaming

scala rest apache-spark spark-streaming

What does Spark recover the data from a failed node?

apache-spark spark-streaming rdd failover

Kafka Spark streaming: unable to read messages

hadoop apache-kafka spark-streaming spark-streaming-kafka

Spark - Sort DStream by Key and limit to 5 values

apache-spark pyspark spark-streaming rdd

How to add the "--deploy-mode cluster" option to my scala code

scala apache-spark spark-streaming apache-spark-standalone

How to use SparkSession and StreamingContext together?

scala apache-spark spark-dataframe spark-streaming
Older Entries »