@Internal public interface ChangelogApplierFactory
StateChangeApplier
factory. It's purpose is to decouple restore/apply logic from state
logic.Modifier and Type | Method and Description |
---|---|
<K,N,IN,SV,OUT> |
forAggregating(InternalAggregatingState<K,N,IN,SV,OUT> aggregating,
InternalKeyContext<K> keyContext) |
<K,N,T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> |
forList(InternalListState<K,N,T> list,
InternalKeyContext<K> keyContext) |
<K,N,UK,UV> |
forMap(InternalMapState<K,N,UK,UV> map,
InternalKeyContext<K> keyContext) |
<T> StateChangeApplier |
forPriorityQueue(KeyGroupedInternalPriorityQueue<T> priorityQueue,
TypeSerializer<T> serializer) |
<K,N,T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> |
forReducing(InternalReducingState<K,N,T> reducing,
InternalKeyContext<K> keyContext) |
<K,N,T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> |
forValue(InternalValueState<K,N,T> value,
InternalKeyContext<K> keyContext) |
<K,N,UK,UV> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> forMap(InternalMapState<K,N,UK,UV> map, InternalKeyContext<K> keyContext)
<K,N,T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> forValue(InternalValueState<K,N,T> value, InternalKeyContext<K> keyContext)
<K,N,T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> forList(InternalListState<K,N,T> list, InternalKeyContext<K> keyContext)
<K,N,T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> forReducing(InternalReducingState<K,N,T> reducing, InternalKeyContext<K> keyContext)
<K,N,IN,SV,OUT> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,N> forAggregating(InternalAggregatingState<K,N,IN,SV,OUT> aggregating, InternalKeyContext<K> keyContext)
<T> StateChangeApplier forPriorityQueue(KeyGroupedInternalPriorityQueue<T> priorityQueue, TypeSerializer<T> serializer)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.