...
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#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | ||||
leftJoin(KStream, ValueJoiner, JoinWindows, Joined) | NO | static Joined#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | ||||
outerJoin(KStream, ValueJoiner, JoinWindows, Joined) | NO | static Joined#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | ||||
join(KTable, ValueJoiner, Joined) | NO | static Joined#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | N/A | ||||
leftJoin(KTable, ValueJoiner, Joined) | NO | static Joined#namedJoined#as(final String name) | static Joined#namedJoined#as(final String name) | N/A | join(GlobalKTbale, KeyValueMapper, ValueJoiner) | NO | (PREFIX + COUNT) | N/A |
N/A | join(GlobalKTbale, KeyValueMapper, ValueJoiner, Named) | YES | static Joined#namedNamed#as(final String name) | N/A | N/A | |||
leftJoin(GlobalKTable, KeyValueMapper, ValueJoiner, Named) | NOYES | static Named#as(PREFIX + COUNTString) | N/A | N/A | ||||
leftJoinflatTransform(GlobalKTableTransformerSupplier, KeyValueMapper, ValueJoinerNamed named, String... stateStoreNames) | YES | static Joined#namedNamed#as(final String name) | 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#withNameSuppressed#as(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) |
...