org.apache.flink.api.connector.source.lib.util

Class IteratorSourceReader<E,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>

java.lang.Object

org.apache.flink.api.connector.source.lib.util.IteratorSourceReaderBase<E,E,IterT,SplitT>

org.apache.flink.api.connector.source.lib.util.IteratorSourceReader<E,IterT,SplitT>

Type Parameters:

E - The type of events returned by the reader.

IterT - The type of the iterator that produces the events. This type exists to make the conversion between iterator and IteratorSourceSplit type safe.

SplitT - The concrete type of the IteratorSourceSplit that creates and converts the iterator that produces this reader's elements.

All Implemented Interfaces:

AutoCloseable, CheckpointListener, SourceReader<E,SplitT>

@Public
public class IteratorSourceReader<E,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>
extends IteratorSourceReaderBase<E,E,IterT,SplitT>

A SourceReader that returns the values of an iterator, supplied via an IteratorSourceSplit.

The IteratorSourceSplit is also responsible for taking the current iterator and turning it back into a split for checkpointing.

Constructor Summary

Constructors

Constructor and Description
IteratorSourceReader(SourceReaderContext context)

Method Summary

Modifier and Type	Method and Description
protected E	convert(E value)

Methods inherited from class org.apache.flink.api.connector.source.lib.util.IteratorSourceReaderBase

addSplits, close, isAvailable, notifyNoMoreSplits, pollNext, snapshotState, start, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.connector.source.SourceReader

handleSourceEvents, notifyCheckpointComplete, pauseOrResumeSplits

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Constructor Detail

IteratorSourceReader

public IteratorSourceReader(SourceReaderContext context)

Method Detail

convert

protected E convert(E value)

Specified by:

convert in class IteratorSourceReaderBase<E,E,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>