org.apache.flink.streaming.runtime.io

Interface StreamingReader

All Superinterfaces:

ReaderBase

@Internal
public interface StreamingReader
extends ReaderBase

Method Summary

Modifier and Type	Method and Description
void	cleanup()

Methods inherited from interface org.apache.flink.runtime.io.network.api.reader.ReaderBase

hasReachedEndOfSuperstep, isFinished, registerTaskEventListener, sendTaskEvent, setIterativeReader, setReporter, startNextSuperstep

Method Detail

cleanup

void cleanup()
      throws IOException

Throws:

IOException