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 | static Named#as(String) |
| filter(Predicate, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| filterNot(Predicate, Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| filterNot(Predicate, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| mapValues(ValueMapper, Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| mapValues(ValueMapperWithKey, Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| mapValues(ValueMapper, Named named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| mapValues(ValueMapperWithKey, Named 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 | static Named#as(String) |
| transformValues(ValueTransformerWithKeySupplier, Materialized, Named 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 | static Named#as(String) |
| join(KTable, ValueJoiner, Named named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| leftJoin(KTable, ValueJoiner, Named); | YES | static Named#as(String) | N/A | static Named#as(String) |
| leftJoin(KTable, ValueJoiner, Named named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
| outerJoin(KTable, ValueJoiner, Named); | YES | static Named#as(String) | N/A | static Named#as(String) |
| outerJoin(KTable, ValueJoiner, Named named, Materialized) | YES | static Named#as(String) | N/A | static Materialized#as(String) |
Note that for all methods accepting a Materialized argument, if no state store named is provided then the node named will be used to generate a one. The state store name will be the node name suffixed with "-table".
KGroupedStream
WIP
KGroupedTable
WIP
TimeWindowedKStream
| method | Added for this KIP ? | Object/method used for node name | Used for repartition topic name | Used for |
|---|
| state store name ? | ||||
|---|---|---|---|---|
| count(Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| count(Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| aggregate(Initializer, Aggregator, Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| aggregate(Initializer, Aggregator, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| reduce(Reducer, Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| reduce(Reducer, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
SessionWindowedKStream
| method | Added for this KIP ? | Object/method used for node name | Used for repartition topic nameUsed for state store name ?topic name | Used for state store name ? |
|---|---|---|---|---|
| count(Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| count(Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| aggregate(Initializer, Aggregator, Merger, Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| aggregate(Initializer, Aggregator, Merger, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
| reduce(Reducer, Named) | YES | static Named#as(String) | N/A | static Named#as(String) |
| reduce(Reducer, Named, Materialized) | YES | static Named#as(String) | N/A | Materialized#as(String) |
Note that for all methods accepting a Materialized argument, if no state store named is provided then the node named will be used to generate a one. The state store name will be the node name suffixed with "-table".
Proposed Changes
- Implement the new interface NamedOperation and default class Named
- Update all parameter class to implement NamedOperation : Produced Consumed Printed Joined Grouped Suppressed
- Overload methods stateless for classes KStreams, KTables, KGroupedStream, KGroupedTable, TimeWindowedKStream, TimeWindowedKTable
- The processor names specified by developer will be used in place of the static processor prefix. Statics prefixes will still be used if no custom processor name are specified.
- Processor names should follow the same restrictions as the topic names. So legal characters are [a-zA-Z0-9._-] and the maximum length us 249.
...