THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
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(); } } |
Proposed Changes
We will add two new internal classes
...