You can write a simple custom processor which uses local caching (like Caffeine cache implementation ) with cache expiry time as ur window time and build the logic. May be you can store words in cache and keep updating the count or something like that
... View more
