Package org.apache.flink.state.changelog.restore

Interface ChangelogApplierFactory

  • @Internal
public interface ChangelogApplierFactory
    StateChangeApplier factory. It's purpose is to decouple restore/apply logic from state logic.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      <K,​N,​IN,​SV,​OUT>
      org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N>      		 forAggregating​(org.apache.flink.runtime.state.internal.InternalAggregatingState<K,​N,​IN,​SV,​OUT> aggregating, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)  
      <K,​N,​T>
      org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N>      		 forList​(org.apache.flink.runtime.state.internal.InternalListState<K,​N,​T> list, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)  
      <K,​N,​UK,​UV>
      org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N>      		 forMap​(org.apache.flink.runtime.state.internal.InternalMapState<K,​N,​UK,​UV> map, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)  
      <T> StateChangeApplier forPriorityQueue​(org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<T> priorityQueue, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)  
      <K,​N,​T>
      org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N>      		 forReducing​(org.apache.flink.runtime.state.internal.InternalReducingState<K,​N,​T> reducing, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)  
      <K,​N,​T>
      org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N>      		 forValue​(org.apache.flink.runtime.state.internal.InternalValueState<K,​N,​T> value, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)  

    • Method Detail

      • forMap

        <K,​N,​UK,​UV> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N> forMap​(org.apache.flink.runtime.state.internal.InternalMapState<K,​N,​UK,​UV> map,
                                                                                                              org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)

      • forValue

        <K,​N,​T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N> forValue​(org.apache.flink.runtime.state.internal.InternalValueState<K,​N,​T> value,
                                                                                                      org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)

      • forList

        <K,​N,​T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N> forList​(org.apache.flink.runtime.state.internal.InternalListState<K,​N,​T> list,
                                                                                                     org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)

      • forReducing

        <K,​N,​T> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N> forReducing​(org.apache.flink.runtime.state.internal.InternalReducingState<K,​N,​T> reducing,
                                                                                                         org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)

      • forAggregating

        <K,​N,​IN,​SV,​OUT> org.apache.flink.state.changelog.restore.KvStateChangeApplier<K,​N> forAggregating​(org.apache.flink.runtime.state.internal.InternalAggregatingState<K,​N,​IN,​SV,​OUT> aggregating,
                                                                                                                                org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)

      • forPriorityQueue

        <T> StateChangeApplier forPriorityQueue​(org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<T> priorityQueue,
                                        org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)