Page History

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

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

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

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

    public final class Source implements Node {
        public final String name;
        // topicNames and topicPattern are mutually exclusive, i.e., only one will be not-null
        public final List<String> topicNamesString topics; // nullcan if #addSource(..., Pattern) was used
        public final Pattern topicPattern; // null if #addSource(..., String...) was usedbe comma separated list of topic names or pattern (as String)
    }

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

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

}