Uses of Class
org.apache.flink.state.forst.ContextKey

Packages that use ContextKey

Package	Description
org.apache.flink.state.forst

Uses of ContextKey in org.apache.flink.state.forst

Methods in org.apache.flink.state.forst with parameters of type ContextKey

Modifier and Type	Method	Description
byte[]	ForStAggregatingState.serializeKey(ContextKey<K,N> contextKey)
byte[]	ForStInnerTable.serializeKey(ContextKey<K,N> key)	Serialize the given key to bytes.
byte[]	ForStListState.serializeKey(ContextKey<K,N> contextKey)
byte[]	ForStMapState.serializeKey(ContextKey<K,N> contextKey)
byte[]	ForStReducingState.serializeKey(ContextKey<K,N> contextKey)
byte[]	ForStValueState.serializeKey(ContextKey<K,N> contextKey)
static <K,N> byte[]	ForStSerializerUtils.serializeKeyAndNamespace(ContextKey<K,N> contextKey, org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K> builder, N defaultNamespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, boolean enableKeyReuse)	Serialize a key and namespace.

Method parameters in org.apache.flink.state.forst with type arguments of type ContextKey

Modifier and Type	Method	Description
byte[]	ContextKey.getOrCreateSerializedKey(org.apache.flink.util.function.FunctionWithException<ContextKey<K,N>,byte[],IOException> serializeKeyFunc)	Get the serialized key.

Constructors in org.apache.flink.state.forst with parameters of type ContextKey

Constructor	Description
ForStDBBunchPutRequest(ContextKey<K,N> key, Map<UK,UV> value, ForStMapState<K,N,UK,UV> table, org.apache.flink.core.state.InternalStateFuture<Void> future)
ForStDBIterRequest(ContextKey<K,N> contextKey, ForStMapState<K,N,UK,UV> table, org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateRequestHandler, org.forstdb.RocksIterator rocksIterator)
ForStDBMapCheckRequest(ContextKey<K,N> key, ForStInnerTable<K,N,V> table, org.apache.flink.core.state.InternalStateFuture<Boolean> future, boolean checkEmpty)
ForStDBMapEntryIterRequest(ContextKey<K,N> contextKey, ForStMapState<K,N,UK,UV> table, org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateRequestHandler, org.forstdb.RocksIterator rocksIterator, org.apache.flink.core.state.InternalStateFuture<org.apache.flink.api.common.state.v2.StateIterator<Map.Entry<UK,UV>>> future)
ForStDBMapKeyIterRequest(ContextKey<K,N> contextKey, ForStMapState<K,N,UK,UV> table, org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateRequestHandler, org.forstdb.RocksIterator rocksIterator, org.apache.flink.core.state.InternalStateFuture<org.apache.flink.api.common.state.v2.StateIterator<UK>> future)
ForStDBMapValueIterRequest(ContextKey<K,N> contextKey, ForStMapState<K,N,UK,UV> table, org.apache.flink.runtime.asyncprocessing.StateRequestHandler stateRequestHandler, org.forstdb.RocksIterator rocksIterator, org.apache.flink.core.state.InternalStateFuture<org.apache.flink.api.common.state.v2.StateIterator<UV>> future)