streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java [53:168]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.delegate = delegate;
    }

    @Override
    public String applicationId() {
        return delegate.applicationId();
    }

    @Override
    public TaskId taskId() {
        return delegate.taskId();
    }

    @Override
    public Serde<?> keySerde() {
        return delegate.keySerde();
    }

    @Override
    public Serde<?> valueSerde() {
        return delegate.valueSerde();
    }

    @Override
    public File stateDir() {
        return delegate.stateDir();
    }

    @Override
    public StreamsMetricsImpl metrics() {
        return delegate.metrics();
    }

    @Override
    public void setSystemTimeMs(final long timeMs) {
        delegate.setSystemTimeMs(timeMs);
    }

    @Override
    public long currentSystemTimeMs() {
        return delegate.currentSystemTimeMs();
    }

    @Override
    public ProcessorRecordContext recordContext() {
        return delegate.recordContext();
    }

    @Override
    public void setRecordContext(final ProcessorRecordContext recordContext) {
        delegate.setRecordContext(recordContext);
    }

    @Override
    public void setCurrentNode(final ProcessorNode<?, ?, ?, ?> currentNode) {
        delegate.setCurrentNode(currentNode);
    }

    @Override
    public ProcessorNode<?, ?, ?, ?> currentNode() {
        return delegate.currentNode();
    }

    @Override
    public ThreadCache cache() {
        return delegate.cache();
    }

    @Override
    public void initialize() {
        delegate.initialize();
    }

    @Override
    public void uninitialize() {
        delegate.uninitialize();
    }

    @Override
    public Task.TaskType taskType() {
        return delegate.taskType();
    }

    @Override
    public void transitionToActive(final StreamTask streamTask, final RecordCollector recordCollector, final ThreadCache newCache) {
        delegate.transitionToActive(streamTask, recordCollector, newCache);
    }

    @Override
    public void transitionToStandby(final ThreadCache newCache) {
        delegate.transitionToStandby(newCache);
    }

    @Override
    public void registerCacheFlushListener(final String namespace, final ThreadCache.DirtyEntryFlushListener listener) {
        delegate.registerCacheFlushListener(namespace, listener);
    }

    @Override
    public <T extends StateStore> T getStateStore(final StoreBuilder<T> builder) {
        return delegate.getStateStore(builder);
    }

    @Override
    public void logChange(final String storeName, final Bytes key, final byte[] value, final long timestamp) {
        delegate.logChange(storeName, key, value, timestamp);
    }

    @Override
    public String changelogFor(final String storeName) {
        return delegate.changelogFor(storeName);
    }

    @Override
    public void register(final StateStore store, final StateRestoreCallback stateRestoreCallback) {
        delegate.register(store, stateRestoreCallback);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java [49:164]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.delegate = delegate;
    }

    @Override
    public String applicationId() {
        return delegate.applicationId();
    }

    @Override
    public TaskId taskId() {
        return delegate.taskId();
    }

    @Override
    public Serde<?> keySerde() {
        return delegate.keySerde();
    }

    @Override
    public Serde<?> valueSerde() {
        return delegate.valueSerde();
    }

    @Override
    public File stateDir() {
        return delegate.stateDir();
    }

    @Override
    public StreamsMetricsImpl metrics() {
        return delegate.metrics();
    }

    @Override
    public void setSystemTimeMs(final long timeMs) {
        delegate.setSystemTimeMs(timeMs);
    }

    @Override
    public long currentSystemTimeMs() {
        return delegate.currentSystemTimeMs();
    }

    @Override
    public ProcessorRecordContext recordContext() {
        return delegate.recordContext();
    }

    @Override
    public void setRecordContext(final ProcessorRecordContext recordContext) {
        delegate.setRecordContext(recordContext);
    }

    @Override
    public void setCurrentNode(final ProcessorNode<?, ?, ?, ?> currentNode) {
        delegate.setCurrentNode(currentNode);
    }

    @Override
    public ProcessorNode<?, ?, ?, ?> currentNode() {
        return delegate.currentNode();
    }

    @Override
    public ThreadCache cache() {
        return delegate.cache();
    }

    @Override
    public void initialize() {
        delegate.initialize();
    }

    @Override
    public void uninitialize() {
        delegate.uninitialize();
    }

    @Override
    public Task.TaskType taskType() {
        return delegate.taskType();
    }

    @Override
    public void transitionToActive(final StreamTask streamTask, final RecordCollector recordCollector, final ThreadCache newCache) {
        delegate.transitionToActive(streamTask, recordCollector, newCache);
    }

    @Override
    public void transitionToStandby(final ThreadCache newCache) {
        delegate.transitionToStandby(newCache);
    }

    @Override
    public void registerCacheFlushListener(final String namespace, final ThreadCache.DirtyEntryFlushListener listener) {
        delegate.registerCacheFlushListener(namespace, listener);
    }

    @Override
    public <T extends StateStore> T getStateStore(final StoreBuilder<T> builder) {
        return delegate.getStateStore(builder);
    }

    @Override
    public void logChange(final String storeName, final Bytes key, final byte[] value, final long timestamp) {
        delegate.logChange(storeName, key, value, timestamp);
    }

    @Override
    public String changelogFor(final String storeName) {
        return delegate.changelogFor(storeName);
    }

    @Override
    public void register(final StateStore store, final StateRestoreCallback stateRestoreCallback) {
        delegate.register(store, stateRestoreCallback);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -