Package org.apache.flink.runtime.io.network.api.reader
-
Interface Summary Interface Description MutableReader<T extends IOReadableWritable> A record-oriented reader for mutable record types.Reader<T extends IOReadableWritable> A record-oriented reader for immutable record types.ReaderBase The basic API for every reader. -
Class Summary Class Description AbstractReader A basic reader implementation, which wraps an input gate and handles events.MutableRecordReader<T extends IOReadableWritable> Implementation of the record-oriented reader for mutable record types.RecordReader<T extends IOReadableWritable> Record oriented reader for immutable types.