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