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 | |
Time |
This is a simple class that represents an absolute instant of time.
|
Enum | Description |
---|---|
StreamingContextState |
:: DeveloperApi ::
Represents the state of a StreamingContext.
|