Monday, July 17, 2023

Kafka Streams KStream.groupBy metodu

Örnek
Şöyle yaparız
stream.groupBy(new KeyValueMapper<String, String, String>() {
    @Override
    public String apply(String k, String v) {
        return k.toUpperCase();
    }
});
Örnek
Şöyle yaparız. value değerine göre gruplar. Grupları saymak için KGroupedStream.count() çağrılır. Bu çağrı bize bir KTable döndürür.
KStream<String, String> ks1 = ks0
.flatMapValues(v->Arrays.asList(v.toLowerCase().split(" ")));
KGroupedStream<String, String> ks2 = ks1.groupBy((k, v)->v);

KTable<String, Long> kt0=ks2.count(); kt0.toStream().print(Printed.toSysOut());
Açıklaması şöyle
groupBy() — is based on key value lambda function which groups the elements of same values and is counting the list based on values and returns the KGroupedStream.








No comments:

Post a Comment

Bufstream - Kafka Muadili

Giriş Açıklaması şöyle Bufstream was developed by Buf, a software company founded in 2020 to bring schema-driven development to the world...