Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.state.changelog | |
org.apache.flink.streaming.api.operators.sorted.state |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractKeyedStateBackend.deregisterKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener) |
boolean |
KeyedStateBackend.deregisterKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener)
Stop calling listener registered in
KeyedStateBackend.registerKeySelectionListener(org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K>) . |
void |
AbstractKeyedStateBackend.registerKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener) |
void |
KeyedStateBackend.registerKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener)
State backend will call
keySelected(K) when key context is switched
if supported. |
Modifier and Type | Method and Description |
---|---|
boolean |
ChangelogKeyedStateBackend.deregisterKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener) |
void |
ChangelogKeyedStateBackend.registerKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener) |
Modifier and Type | Class and Description |
---|---|
class |
BatchExecutionInternalTimeServiceManager<K>
An implementation of a
InternalTimeServiceManager that manages timers with a single
active key at a time. |
Modifier and Type | Method and Description |
---|---|
boolean |
BatchExecutionKeyedStateBackend.deregisterKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener) |
void |
BatchExecutionKeyedStateBackend.registerKeySelectionListener(KeyedStateBackend.KeySelectionListener<K> listener) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.