THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| 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 |
KTable (16 new methods)
| 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 | (PREFIX + COUNT) |
| filter(Predicate, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| filterNot(Predicate, Named) | YES | static Named#as(String) | N/A | (PREFIX + COUNT) |
| filterNot(Predicate, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| mapValues(ValueMapper, Named) | YES | static Named#as(String) | N/A | (PREFIX + COUNT) |
| mapValues(ValueMapperWithKey, Named) | YES | static Named#as(String) | N/A | (PREFIX + COUNT) |
| mapValues(ValueMapper, Named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| mapValues(ValueMapperWithKey, Named, Materialized); | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| suppress(Suppressed) | NO | Suppressed#withName(String) | N/A | N/A |
| transformValues(ValueTransformerWithKeySupplier, Named, String...) | YES | static Named#as(String) | N/A | (PREFIX + COUNT) |
| transformValues(ValueTransformerWithKeySupplier, Materialized, Named, String...) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| groupBy(KeyValueMapper, KeyValue, Grouped) | NO | static Grouped#as(String) | static Grouped#as(String) | N/A |
| join(KTable, ValueJoiner, Named) | YES | static Named#as(String) | N/A | (PREFIX + COUNT) |
| join(KTable, ValueJoiner, Named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| leftJoin(KTable, ValueJoiner, Named); | YES | static Named#as(String) | N/A | (PREFIX + COUNT) |
| leftJoin(KTable, ValueJoiner, Named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| outerJoin(KTable, ValueJoiner, Named); | YES | static Named#as(String) | N/A | (PREFIX + COUNT) |
| outerJoin(KTable, ValueJoiner, Named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| toStream(Named) | YES | static Named#as(String) | N/A | N/A |
| toStream(KeyValueMapper, Named) | YES | static Named#as(String) | N/A | N/A |
...