New posts in Spark Streaming

How to use Spark Streaming to read a stream and find the IP over a time Window?

Spark Structured Streaming with Kafka doesn't honor startingOffset="earliest"

How to handle small file problem in spark structured streaming?

Is there a way to dynamically stop Spark Structured Streaming?

SBT Test Error: java.lang.NoSuchMethodError: net.jpountz.lz4.LZ4BlockInputStream

What is the difference between Spark Structured Streaming and DStreams?

AbstractMethodError creating Kafka stream

Spark structured streaming consistency across sinks

How does Spark-submit in cluster deploy mode manage the application Jars

How do I delete files in hdfs directory after reading it using scala?