public class SourceRDD
extends java.lang.Object
Source
RDD
s.Modifier and Type | Class and Description |
---|---|
static class |
SourceRDD.Bounded<T>
|
static class |
SourceRDD.Unbounded<T,CheckpointMarkT extends UnboundedSource.CheckpointMark>
A
SourceRDD.Unbounded is the implementation of a micro-batch in a SourceDStream . |
Constructor and Description |
---|
SourceRDD() |