Says to create a state store from the result and give it the name
count_store so you can reference and use the data later.
Carl
On Mon, Dec 23, 2019, 12:31 Aurel Sandu <asandu1...@gmail.com> wrote:
> I'am reading the folowing 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 the last line ... what is this ?
> Materialized.<String, Long, KeyValueStore<Bytes, byte[]>> ... ?
> Materialized is from this
> https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/kstream/Materialized.html
> Please give me a link where I can find explanations ,
> Many thanks,
> Aurel
>
>
>
