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

Mixing Spark Structured Streaming API and DStream to write to Kafka

apache-spark spark-streaming spark-structured-streaming

Value split is not a member of (String, String)

scala apache-spark apache-kafka spark-streaming spark-submit

how to save data in HDFS with spark?

hadoop apache-spark hdfs spark-streaming

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/streaming/StreamingContext

scala apache-spark intellij-idea sbt spark-streaming

Can we consume JMS messages from a Topic through Spark Streaming?

scala apache-spark spark-streaming

Spark Python Avro Kafka Deserialiser

python apache-spark apache-kafka avro spark-streaming

Shutdown spark structured streaming gracefully

apache-spark apache-spark-sql spark-streaming spark-structured-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
Older Entries »