kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: Process KTable on Predicate
Date Sun, 13 Nov 2016 07:33:43 GMT
-----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:
> 
> KTable<key, value> 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 event.
> 
> Thank you, Nick DeCoursin
> 
-----BEGIN PGP SIGNATURE-----
Comment: GPGTools - https://gpgtools.org

iQIcBAEBCgAGBQJYKBdXAAoJECnhiMLycopPV48P/RqOx7JfrT56CSaWx57xowgx
p7GFrmQ81F+Mx8jGOlFyn5KBV1f5q4MJH/X22pwjTyD+Gc6Bw30aBDwUI4GCx2yV
anay1SNhMQRed3hiOrhXRHikw0DEBozsYCXE0n4JN1AWL5REaS/rl2+ls6yfLy/b
QzbGYIeOQQ2JwmsQFru3XCp5Ubyaam5C+H3uFO2d6Ol2gG9EhtfIo1ZpszgaT/TR
bVnUPEobR7NG7cBehNWiMOz8QJYL1by+nx1soMcUJaFYdMWa5y8RpuPESYHni1M9
IjcGnbcIeHpiELWHSeb0s6ZJkZjeFSwbkwfK1kNyweu37sGVRjvuJaysjY39klSG
xaDQO17ETQm0YnYhq5V4llCDp+KVcmPjG8spxA5PyV6SZb/dLOZZEtWZhCCfm+yd
kEuvZRBdjVVue5/yUpZHGh/DJ5uc1KJCNghzR8CTkUHCBbSiYLOH7lRt1SBAS1/g
X/HGlyFLyKjVqLGVQuLHklq6T7vFz6FwhVjEqEVaNmu8mBsDHi3B+5kBi6MZ2M8e
Sfl7nx9yfadwOOgZ37NpxluIuC2y0AlzFTe9pBnnfrN44HpIx4RqsFZtaOht2aip
CocF6cQBcxc4Q0+F5hzUJwMmPwhwyI68//e6LJ1V3Q1g+zO32ukitNsDov8kyKaB
fZ+rqGbDrHhhAEvXQE98
=tQgk
-----END PGP SIGNATURE-----

Mime
View raw message