TimestampedTupleForwarder is used by processors to determine whether or not to forward records to child nodes (downstream processors) (that happens only with no caching).
TimestampedTupleForwarder takes the following to be created:
TimestampedTupleForwarder is created when:
KStreamAggregateProcessoris requested to initialize
KStreamSlidingWindowAggregateProcessoris requested to initialize
KStreamWindowAggregateProcessoris requested to initialize
KTableSourceis requested to initialize
void maybeForward( K key, V newValue, V oldValue) // (1) void maybeForward( K key, V newValue, V oldValue, long timestamp) void maybeForward( Record<K, Change<V>> record)