Uses of Class
org.apache.flink.core.io.InputStatus

Packages that use InputStatus

Package	Description
org.apache.flink.api.connector.source
org.apache.flink.api.connector.source.lib.util
org.apache.flink.api.connector.source.util.ratelimit
org.apache.flink.core.io

Uses of InputStatus in org.apache.flink.api.connector.source

Methods in org.apache.flink.api.connector.source that return InputStatus

Modifier and Type	Method	Description
InputStatus	SourceReader.pollNext(ReaderOutput<T> output)	Poll the next available record into the ReaderOutput.

Uses of InputStatus in org.apache.flink.api.connector.source.lib.util

Methods in org.apache.flink.api.connector.source.lib.util that return InputStatus

Modifier and Type	Method	Description
InputStatus	IteratorSourceReaderBase.pollNext(ReaderOutput<O> output)
protected InputStatus	IteratorSourceReaderBase.tryMoveToNextSplit()

Uses of InputStatus in org.apache.flink.api.connector.source.util.ratelimit

Methods in org.apache.flink.api.connector.source.util.ratelimit that return InputStatus

Modifier and Type	Method	Description
InputStatus	RateLimitedSourceReader.pollNext(ReaderOutput<E> output)

Uses of InputStatus in org.apache.flink.core.io

Methods in org.apache.flink.core.io that return InputStatus

Modifier and Type	Method	Description
static InputStatus	InputStatus.valueOf(String name)	Returns the enum constant of this type with the specified name.
static InputStatus[]	InputStatus.values()	Returns an array containing the constants of this enum type, in the order they are declared.