Hierarchy For Package org.apache.flink.contrib.streaming.state

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.contrib.streaming.state.AbstractRocksDBState<K,N,S,SD> (implements org.apache.flink.runtime.state.KvState<K,N,S,SD,Backend>, org.apache.flink.api.common.state.State)
    • org.apache.flink.contrib.streaming.state.RocksDBFoldingState<K,N,T,ACC> (implements org.apache.flink.api.common.state.FoldingState<T,ACC>)
    • org.apache.flink.contrib.streaming.state.RocksDBListState<K,N,V> (implements org.apache.flink.api.common.state.ListState<T>)
    • org.apache.flink.contrib.streaming.state.RocksDBReducingState<K,N,V> (implements org.apache.flink.api.common.state.ReducingState<T>)
    • org.apache.flink.contrib.streaming.state.RocksDBValueState<K,N,V> (implements org.apache.flink.api.common.state.ValueState<T>)
  • org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot<K,N,S,SD> (implements org.apache.flink.runtime.state.KvStateSnapshot<K,N,S,SD,Backend>)
  • org.apache.flink.runtime.state.AbstractStateBackend (implements java.io.Serializable)
    • org.apache.flink.contrib.streaming.state.DbStateBackend
    • org.apache.flink.contrib.streaming.state.RocksDBStateBackend
  • org.apache.flink.contrib.streaming.state.DbBackendConfig (implements java.io.Serializable)
  • org.apache.flink.contrib.streaming.state.DbStateHandle<S> (implements java.io.Serializable, org.apache.flink.runtime.state.StateHandle<T>)
  • org.apache.flink.contrib.streaming.state.LazyDbValueState<K,N,V> (implements org.apache.flink.runtime.state.CheckpointListener, org.apache.flink.runtime.state.KvState<K,N,S,SD,Backend>, org.apache.flink.api.common.state.ValueState<T>)
  • org.apache.flink.contrib.streaming.state.MySqlAdapter (implements org.apache.flink.contrib.streaming.state.DbAdapter)
  • org.apache.flink.contrib.streaming.state.ShardedConnection (implements java.lang.AutoCloseable, java.io.Serializable)
  • org.apache.flink.contrib.streaming.state.ShardedConnection.ModHashPartitioner (implements org.apache.flink.contrib.streaming.state.ShardedConnection.Partitioner)
  • org.apache.flink.contrib.streaming.state.ShardedConnection.ShardedStatement (implements java.lang.AutoCloseable, java.io.Serializable)
  • org.apache.flink.contrib.streaming.state.SQLRetrier (implements java.io.Serializable)

Interface Hierarchy

• java.io.Serializable
  • org.apache.flink.contrib.streaming.state.DbAdapter
  • org.apache.flink.contrib.streaming.state.OptionsFactory
  • org.apache.flink.contrib.streaming.state.ShardedConnection.Partitioner

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.contrib.streaming.state.PredefinedOptions