public final class TopologyDescription {
    public final Set<Subtopology> subtopologies();
    public final Set<GlobalStore> globalStores();

    public final class Subtopology {
        public final int id();
        public final Set<Node> nodes();
    }

    public final class GlobalStore {
        public final StringSource namesource();
        public final StringProcessor topicprocessor();
    }

    public interface Node {
        String name()
        Set<Node> getPredecessors();
        Set<Node> getSuccessors();
    }

    public final class Source implements Node {
        public final String name;
        public final String topicstopics(); // can be comma separated list of topic names or pattern (as String)
    }

    public final class Processor implements Node {
        public final String name;
        public final Set<String> stores();
    }

    public final class Sink implements Node {
        public final String name;
        public final String topic();
    }

}