@Override
  public R transform(final K readOnlyKey, final GenericRow value) {
    return delegate.transform(
        readOnlyKey,
        value,
        context.orElseThrow(() -> new IllegalStateException("Not initialized"))
    );
  }
@Test
  public void shouldExposeRowTime() {
    // Given:
    ksTransformer.transform(KEY, VALUE);

    final KsqlProcessingContext ksqlCtx = getKsqlProcessingContext();

    // When:
    final long rowTime = ksqlCtx.getRowTime();

    // Then:
    assertThat(rowTime, is(ROWTIME));
  }