UnboundedSource

UnboundedSource<T> is a Source that produces an unbounded amount of input (of type T).

CheckpointMark

UnboundedSource requires a CheckpointMark.