@SuppressWarnings("unchecked")
    private static <KIn, VIn, KOut, VOut> ProcessorNode<KIn, VIn, KOut, VOut> getProcessor(
        final Map<String, ProcessorNode<?, ?, ?, ?>> processorMap,
        final String predecessor) {

        return (ProcessorNode<KIn, VIn, KOut, VOut>) processorMap.get(predecessor);
    }
Builds the topology for any global state stores
@return ProcessorTopology of global state
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java