org.apache.flink.runtime.state

Interface KeyGroupPartitioner.ElementWriterFunction<T>

Type Parameters:

T - type of the written 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.ElementWriterFunction<T>

This functional interface defines how one element is written to a DataOutputView.

Method Summary

Modifier and Type	Method and Description
void	writeElement(T element, DataOutputView dov) This method defines how to write a single element to the output.

Method Detail

writeElement

void writeElement(@Nonnull
                  T element,
                  @Nonnull
                  DataOutputView dov)
           throws IOException

This method defines how to write a single element to the output.

Parameters:

element - the element to be written.

dov - the output view to write the element.

Throws:

IOException - on write-related problems.