Ah works! Thanks! I was under the impression that these are sequentially
chained using the DSL. Didn’t realize I can still use allRecords parallel to
the branches.
Ara.
> On Sep 9, 2016, at 5:27 AM, Michael Noll wrote:
>
> Oh, my bad.
>
> Updating the third predicate in `branch()` may not even
Oh, my bad.
Updating the third predicate in `branch()` may not even be needed.
You could simply do:
KStream[] branches = allRecords
.branch(
(imsi, callRecord) -> "VOICE".equalsIgnoreCase(callR
ecord.getCallCommType()),
(imsi, callRecord) -> "DATA".equalsIgnoreCas
Ara,
you have shared this code snippet:
>allRecords.branch(
>(imsi, callRecord) -> "VOICE".equalsIgnoreCase(
callRecord.getCallCommType()),
>(imsi, callRecord) -> "DATA".equalsIgnoreCase(
callRecord.getCallCommType()),
>(imsi, callRecord) -> true
>);
T
Let’s say I have this:
KStream[] branches = allRecords
.branch(
(imsi, callRecord) ->
"VOICE".equalsIgnoreCase(callRecord.getCallCommType()),
(imsi, callRecord) ->
"DATA".equalsIgnoreCase(callRecord.getCallCommType()),
(imsi, callRecord) -> true
);
KS
