| Class | Description |
|---|---|
| Checkpoint | |
| CheckpointReader | |
| CheckpointWriter |
Convenience class to handle the writing of graph checkpoint to file
|
| ContextWaiter | |
| DStreamGraph | |
| Duration | |
| Durations | |
| Interval | |
| 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. |
| ObjectInputStreamWithLoader | |
| Seconds |
Helper object that creates instance of
Duration representing
a given number of seconds. |
| StreamingContext |
Main entry point for Spark Streaming functionality.
|
| StreamingSource | |
| Time |
This is a simple class that represents an absolute instant of time.
|