package state
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- abstract class EvictableStateFunction[In, Out, StateType] extends KeyedProcessFunction[String, In, Out]
- abstract class LatelyEvictableStateCoFunction[In1, In2, Out, StateType] extends CoProcessFunction[In1, In2, Out] with LatelyEvictableStateFunctionMixin[StateType]
- abstract class LatelyEvictableStateFunction[In, Out, StateType] extends KeyedProcessFunction[String, In, Out] with LatelyEvictableStateFunctionMixin[StateType]
- trait LatelyEvictableStateFunctionMixin[StateType] extends RichFunction with StateHolder[StateType]
- case class MultiMap[K, V](map: TreeMap[K, List[V]]) extends Product with Serializable
- trait StateHolder[StateType] extends AnyRef
- abstract class TimestampedEvictableStateFunction[In, Out, StateType] extends EvictableStateFunction[In, Out, MultiMap[Long, StateType]]