You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Aurel Sandu <as...@gmail.com> on 2019/12/23 15:49:45 UTC

Please help me with link to documentation ... (generics I think) 

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

Re: Please help me with link to documentation ... (generics I think)

Posted by "Matthias J. Sax" <ma...@confluent.io>.
If it's about generics, see
https://stackoverflow.com/questions/5297978/calling-static-generic-methods


On 12/28/19 8:50 AM, Guozhang Wang wrote:
> 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 <as...@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
>>
>>
>>
>

Re: Please help me with link to documentation ... (generics I think)

Posted by Guozhang Wang <wa...@gmail.com>.
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 <as...@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