Package org.apache.spark.streaming.util
package org.apache.spark.streaming.util
-
ClassesClassDescriptionA helper program that sends blocks of Kryo-serialized text strings out on a socket at a specified rate.:: DeveloperApi :: This abstract class represents a write ahead log (aka journal) that is used by Spark Streaming to save the received data (by receivers) and associated metadata to a reliable storage, so that they can be recovered after driver failures.:: DeveloperApi :: This abstract class represents a handle that refers to a record written in a
WriteAheadLog.A helper class with utility functions related to the WriteAheadLog interface