| Table of Contents |
|---|
Status
Current state: Under DiscussionAccepted
Discussion thread: here
JIRA: here
...
| method | Added for this KIP ? | Object/method used for node name | Used for repartition topic name | Used for state store name ? |
|---|---|---|---|---|
| filter(Predicate, Named) | YES | static Named#as(String) | N/A | N/A |
| filterNot(Predicate, Named) | YES | static Named#as(String) | N/A | N/A |
| selectKey(KeyValueMapper, Named) | YES | static Named#as(String) | N/A | N/A |
| map(KeyValueMapper, Named) | YES | static Named#as(String) | N/A | N/A |
| mapValues(ValueMapper, Named) | YES | static Named#as(String) | N/A | N/A |
| mapValues(ValueMapperWithKey, Named) | YES | static Named#as(String) | N/A | N/A |
| flatMap(KeyValueMapper, Named) | YES | static Named#as(String) | N/A | N/A |
| flatMapValues(ValueMapper, Named) | YES | static Named#as(String) | N/A | N/A |
| flatMapValues(ValueMapperWithKey, Named) | YES | static Named#as(String) | N/A | N/A |
| print(Printed) | NO | static Printed#as(String) | N/A | N/A |
| foreach(ForeachAction, Named) | YES | static Named#as(String) | N/A | N/A |
| peek(ForeachAction, Named) | YES | static Named#as(String) | N/A | N/A |
| branch(Named, Predicate...) | YES | static Named#as(String) | N/A | N/A |
| through(String, Produced) | NO | static Produced#as(String) | N/A | N/A |
| to(String, Produced) | NO | static Produced#as(String) | N/A | N/A |
| to(TopicNameExtractor, Produced) | NO | static Produced#as(String) | N/A | N/A |
| transform(TransformerSupplier, Named, String... ) | YES | static Named#as(String) | N/A | N/A |
| transformValues(ValueTransformerSupplier, Named, String...) | YES | static Named#as(String) | N/A | N/A |
| transformValues( ValueTransformerWithKeySupplier, Named, String...) | YES | static Named#as(String) | N/A | N/A |
| process(ProcessorSupplier, Named, String...) | YES | static Named#as(String) | N/A | N/A |
| join( KStream, ValueJoiner, JoinWindows windows, Joined) | NO | static Joined#as(final String name) | static Joined#as(final String name) | static Joined#as(final String name) |
| leftJoin(KStream, ValueJoiner, JoinWindows, Joined) | NO | static Joined#as(final String name) | static Joined#as(final String name) | static Joined#as(final String name) |
| outerJoin(KStream, ValueJoiner, JoinWindows, Joined) | NO | static Joined#as(final String name) | static Joined#as(final String name) | static Joined#as(final String name) |
| join(KTable, ValueJoiner, Joined) | NO | static Joined#as(final String name) | static Joined#as(final String name) | N/A |
| leftJoin(KTable, ValueJoiner, Joined) | NO | static Joined#as(final String name) | static Joined#as(final String name) | N/A |
| join(GlobalKTbale, KeyValueMapper, ValueJoiner, Named) | YES | static Named#as(String) | N/A | N/A |
| leftJoin(GlobalKTable, KeyValueMapper, ValueJoiner, Named) | YES | static Named#as(String) | N/A | N/A |
| flatTransform(TransformerSupplier, Named named, String... stateStoreNames) | YES | static Named#as(String) | N/A | N/A |
| flatTransformValues(ValueTransformerWithKeySupplier, Named named, String... ) | YES | static Named#as(String) | N/A | N/A |
| flatTransformValues(ValueTransformerSupplier, Named, String...) | YES | static Named#as(String) | N/A | N/A |
...