K - type of record keyV - type of record valuepublic class Branched<K,V> extends Object
Branched class is used to define the optional parameters when building branches with BranchedKStream.| Modifier and Type | Method and Description |
|---|---|
static <K,V> Branched<K,V> | as(String name)Create an instance of Branched with provided branch name suffix. |
static <K,V> Branched<K,V> | withConsumer(Consumer<? super KStream<K,V>> chain, String name)Create an instance of Branched with provided chain consumer and branch name suffix. |
static <K,V> Branched<K,V> | withConsumer(Consumer<KStream<K,V>> chain)Create an instance of Branched with provided chain consumer. |
static <K,V> Branched<K,V> | withFunction(Function<? super KStream<K,V>,? extends KStream<K,V>> chain)Create an instance of Branched with provided chain function. |
static <K,V> Branched<K,V> | withFunction(Function<? super KStream<K,V>,? extends KStream<K,V>> chain, String name)Create an instance of Branched with provided chain function and branch name suffix. |
Branched<K,V> | withName(String name)Configure the instance of Branched with a branch name suffix. |
public static <K,V> Branched<K,V> as(String name)
Branched with provided branch name suffix.K - key typeV - value typename - the branch name suffix to be used (see BranchedKStream description for details)Branchedpublic static <K,V> Branched<K,V> withFunction(Function<? super KStream<K,V>,? extends KStream<K,V>> chain)
Branched with provided chain function.K - key typeV - value typechain - A function that will be applied to the branch. If the provided function returns null, its result is ignored, otherwise it is added to the Map returned by BranchedKStream.defaultBranch() or BranchedKStream.noDefaultBranch() (see BranchedKStream description for details).Branchedpublic static <K,V> Branched<K,V> withConsumer(Consumer<KStream<K,V>> chain)
Branched with provided chain consumer.K - key typeV - value typechain - A consumer to which the branch will be sent. If a consumer is provided, the respective branch will not be added to the resulting Map returned by BranchedKStream.defaultBranch() or BranchedKStream.noDefaultBranch() (see BranchedKStream description for details).Branchedpublic static <K,V> Branched<K,V> withFunction(Function<? super KStream<K,V>,? extends KStream<K,V>> chain, String name)
Branched with provided chain function and branch name suffix.K - key typeV - value typechain - A function that will be applied to the branch. If the provided function returns null, its result is ignored, otherwise it is added to the Map returned by BranchedKStream.defaultBranch() or BranchedKStream.noDefaultBranch() (see BranchedKStream description for details).name - the branch name suffix to be used. If null, a default branch name suffix will be generated (see BranchedKStream description for details)Branchedpublic static <K,V> Branched<K,V> withConsumer(Consumer<? super KStream<K,V>> chain, String name)
Branched with provided chain consumer and branch name suffix.K - key typeV - value typechain - A consumer to which the branch will be sent. If a non-null consumer is provided, the respective branch will not be added to the resulting Map returned by BranchedKStream.defaultBranch() or BranchedKStream.noDefaultBranch() (see BranchedKStream description for details).name - the branch name suffix to be used. If null, a default branch name suffix will be generated (see BranchedKStream description for details)Branchedpublic Branched<K,V> withName(String name)
Branched with a branch name suffix.name - the branch name suffix to be used. If null a default branch name suffix will be generated (see BranchedKStream description for details)this