Skip to content Skip to sidebar Skip to footer
Showing posts with the label Spark Streaming

Slice Function In Dstream Spark Streaming Not Work

Spark streaming providing sliding window function for get rdd for last k. But I want to try use sli… Read more Slice Function In Dstream Spark Streaming Not Work

How To Properly Use Pyspark To Send Data To Kafka Broker?

I'm trying to write a simple pyspark job, which would receive data from a kafka broker topic, d… Read more How To Properly Use Pyspark To Send Data To Kafka Broker?