@Override
    public StateStore getGlobalStore(final String name) {
        return globalStores.get(name);
    }
@throws ProcessorStateException if the task directory does not exist and could not be created
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java