SourceRDD

public class SourceRDD
extends java.lang.Object

Classes implementing Beam Source RDDs.

Nested Classes
Modifier and Type	Class and Description
`static class`	`SourceRDD.Bounded<T>` A `SourceRDD.Bounded` reads input from a `BoundedSource` and creates a Spark `RDD`.
`static class`	`SourceRDD.Unbounded<T,CheckpointMarkT extends UnboundedSource.CheckpointMark>` A `SourceRDD.Unbounded` is the implementation of a micro-batch in a `SourceDStream`.

Constructors
Constructor and Description
`SourceRDD()`

Method Summary
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Class SourceRDD