-----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-----
