Nick,
if I understand you correctly you can already do this today:
Think: KTable.toStream().filter().foreach() (or just
KTable.filter().foreach(), depending on what you are aiming to do)
Would that work for you?
On Sun, Nov 13, 2016 at 12:12 AM, Nick DeCoursin
wrote:
> Feature proposal:
>
>
-BEGIN PGP SIGNED MESSAGE-
Hash: SHA512
I cannot completely follow what this feature is supposed to do. Can
you maybe describe you scenario with some example input data and
expected behavior in more detail?
- -Matthias
On 11/12/16 3:12 PM, Nick DeCoursin wrote:
> Feature proposal:
>
>
Feature proposal:
KTable when(predicate);
I have a KTable, but I'd only like to trigger a stream processor on certain
conditions. I'd like to do something like:
myKtable.when(
(key, value) -> some predicate
);
The result is just the same KTable. The predicate function is called on any
new
