THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public final class TopologyDescription {
public final List<Subtopology> subtopologies;
public final List<GlobalStore> globalStores;
public final class Subtopology {
public final int id;
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;
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> stores;
}
public final class Sink implements Node {
public final String name;
public final String topic;
}
} |
...