Package org.apache.spark.streaming

package org.apache.spark.streaming

Related Packages

Package	Description
org.apache.spark	Core Spark classes in Scala.
org.apache.spark.streaming.dstream	Various implementations of DStreams.
org.apache.spark.streaming.kinesis
org.apache.spark.streaming.receiver
org.apache.spark.streaming.scheduler
org.apache.spark.streaming.ui
org.apache.spark.streaming.util

Class	Description
CheckpointReader
Duration
Durations
Milliseconds	Helper object that creates instance of Duration representing a given number of milliseconds.
Minutes	Helper object that creates instance of Duration representing a given number of minutes.
Seconds	Helper object that creates instance of Duration representing a given number of seconds.
State<S>	Experimental Abstract class for getting and updating the state in mapping function used in the mapWithState operation of a pair DStream (Scala) or a JavaPairDStream (Java).
StateSpec<KeyType,ValueType,StateType,MappedType>	Experimental Abstract class representing all the specifications of the DStream transformation mapWithState operation of a pair DStream (Scala) or a JavaPairDStream (Java).
StreamingConf
StreamingContext	Deprecated. This is deprecated as of Spark 3.4.0.
StreamingContextPythonHelper
StreamingContextState	Developer API Represents the state of a StreamingContext.
Time	This is a simple class that represents an absolute instant of time.