| Class | Description |
|---|---|
| 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). |
| StreamingContext |
Main entry point for Spark Streaming functionality.
|
| Time |
This is a simple class that represents an absolute instant of time.
|
| Enum | Description |
|---|---|
| StreamingContextState |
:: DeveloperApi ::
Represents the state of a StreamingContext.
|