class TimestampedTupleForwarder {

    public void maybeForward(final K key,
                             final V newValue,
                             final V oldValue) {
        if (!cachingEnabled) {
            context.forward(key, new Change<>(newValue, sendOldValues ? oldValue : null));
        }
    }

    @SuppressWarnings("unchecked")  TimestampedTupleForwarder(final StateStore store,
                              final ProcessorContext context,
                              final TimestampedCacheFlushListener<K, V> flushListener,
                              final boolean sendOldValues);

}