Page History

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

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

    public final class GlobalStore {
        public final String name;
        public final String topic;
    }

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

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

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

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

}