Napotkałem pytanie z równoważeniem obciążenia w kafejce. Stworzyłem więc temat z 10 partycjami i utworzyłem 2 klientów. Dziesięć partycji zostało podzielonych i przypisanych do tych konsumentów (5 par
Biorąc pod uwagę elementy java.util.List z n i żądany rozmiar strony m, chcę przekształcić go na mapę zawierającą elementy n/m+n%m. Każdy element mapy powinien zawierać elementy m. Oto przykład z licz
Zastanawiam się, co różni się za pomocą iskier mapPartitions funkcjonalność vs przejściowy leniwy val. Ponieważ każda partycja działa w zasadzie na innym węźle, każda instancja przejściowego leniwego