org.apache.flink.runtime.state

Interface KeyGroupPartitioner.ElementReaderFunction<T>

Type Parameters:

T - type of the read elements.

Enclosing class:

KeyGroupPartitioner<T>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface KeyGroupPartitioner.ElementReaderFunction<T>

This functional interface defines how one element is read from a DataInputView.

Method Summary

Modifier and Type	Method and Description
T	readElement(DataInputView div)

Method Detail

readElement

@Nonnull
T readElement(@Nonnull
                       DataInputView div)
                throws IOException

Throws:

IOException