[FLINK-9514] Create wrapper with TTL logic for value state

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.6.0
• Fix Version/s: 1.6.0
• Component/s: Runtime / State Backends
• Labels: pull-request-available
• Assignee: Andrey Zagrebin
• Reporter: Andrey Zagrebin
• Created: 04/Jun/18 07:59
• Updated: 12/Jul/18 09:37
• Resolved: 29/Jun/18 12:30

Description

TTL state decorator uses original state with packed TTL and add TTL logic using time provider:

TtlValueState<V> implements ValueState<V> {
  ValueState<TtlValue<V>> underlyingState;
  InternalTimeService timeProvider;
  V value() {
    TtlValue<V> valueWithTtl = underlyingState.get();
    // ttl logic here (e.g. update timestamp)
    return valueWithTtl.getValue();
  }
  void update() { ... underlyingState.update(valueWithTtl) ...  }
}

TTL decorators are apply to state produced by normal state binder in its TTL wrapper from FLINK-9513

Issue Links

• links to: GitHub Pull Request #6186