Re: WordCount Example using GlobalKStore

2017-11-01 Thread Damian Guy
Count will always use a StateStore, but if you want you can use an InMemory store if you don't want a persistent store. You can do this by using the overloaded `count(StateStoreSupplier)` method. You would use `Stores.create(name).inMemory()...` to create the inmemory store On Wed, 1 Nov 2017 at

WordCount Example using GlobalKStore

2017-11-01 Thread pravin kumar
i have created 3 inputtopics with 10 partitions each and output Topic with 10 partitions I did wordcount example and stored it in GlobalKTable. i initally stored counted value in LocalStateStore and then it to GlobalStateStore. i have atteated the code here: