Package | Description |
---|---|
org.apache.flink.runtime.query |
Modifier and Type | Method and Description |
---|---|
KvStateInfo<K,N,V> |
KvStateInfo.duplicate()
Creates a deep copy of the current
KvStateInfo by duplicating all the included
serializers. |
KvStateInfo<K,N,V> |
KvStateEntry.getInfoForCurrentThread() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.