THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
interface Processor extends Node { /** * The names of all connected stores. * @return set of store names */ @Deprecated Set<String> stores(); /** * The namesset of all connected stores. * @return set of stores */ Set<Store> storeSet(); <---- NEW FUNC } /** * A state store of a topology <---- NEW CLASS */ interface Store { /** * Name of the stat store */ String name(); /** * Name of the corresponding changelog topic of this store. * @return name of the changelog topic; null if the store is not logging enabled */ String changelogTopic(); /** * Names of serde classes that are associated with the store */ List<String> serdeNames(); } interface Source extends Node { .... /** * Names of key serde class used for this source node */ String keySerdeName(); <---- NEW FUNC /** * Names of value serde class used for this source node */ String valueSerdeName(); <---- NEW FUNC } interface Sink extends Node { .... /** * Names of key serde class used for this source node */ String keySerdeName(); <---- NEW FUNC /** * Names of value serde class used for this source node */ String valueSerdeName(); <---- NEW FUNC } interface Subtopology { /** * Internally assigned unique ID. * @return the ID of the sub-topology */ int id(); /** * All nodes of this sub-topology. * @return set of all nodes within the sub-topology */ Set<Node> nodes(); /** * All source nodes of this sub-topology. * @return set of all source nodes within the sub-topology */ Set<Source> sourceNodes(); /** * All sink nodes of this sub-topology. * @return set of all sink nodes within the sub-topology */ Set<Sink> sinkNodes(); /** * All state stores of this sub-topology. * @return set of all state stores within the sub-topology */ Set<Store> stores(); <---- NEW FUNC } |
...