You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Guozhang Wang <wa...@gmail.com> on 2019/12/28 16:50:54 UTC
Re: Please help me with link to documentation ... (generics I think)
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
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
>>
>>
>>
>