Hello Aurel,
Maybe this helps:
https://kafka.apache.org/24/documentation/streams/developer-guide/dsl-api.html
Guozhang
On Fri, Dec 27, 2019 at 8:50 AM Aurel Sandu <asandu1...@gmail.com> wrote:
> Hi all of you,
>
> I am reading the following code :
> ..........
> KTable<String, Long> wordCounts = textLines
> .flatMapValues(textLine ->
> Arrays.asList(textLine.toLowerCase().split("\\W+")))
> .groupBy((key, word) -> word)
> .count(Materialized.<String, Long, KeyValueStore<Bytes,
> byte[]>>as("counts-store"));
> ..........
>
> I do not understand this line
>
> count(Materialized.<String, Long, KeyValueStore<Bytes,
> byte[]>>as("counts-store"))
>
> Please tell me where to read to understand this
>
> Thank you,
> Aurel
>
>
>
--
-- Guozhang
