org.apache.flink.runtime.state

Interface KeyedStateBackend.KeySelectionListener<K>

All Known Implementing Classes:

BatchExecutionInternalTimeServiceManager

Enclosing interface:

KeyedStateBackend<K>

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 KeyedStateBackend.KeySelectionListener<K>

Listener is given a callback when KeyedStateBackend.setCurrentKey(K) is called (key context changes).

Method Summary

Modifier and Type	Method and Description
void	keySelected(K newKey) Callback when key context is switched.

Method Detail

keySelected

void keySelected(K newKey)

Callback when key context is switched.