@Override
        public void init(final ProcessorContext<?, ?> context) {
            this.context = (InternalProcessorContext<?, ?>) context;
            parentGetter.init(context);
        }
@throws StreamsException if key is null
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java