5
Jaka jest różnica między JoinFunction i CoGroupFunction w Apache Flink? Czym różnią się semantyka i wykonanie?Czym różnią się funkcjaFunction i CoGroupFunction w Apache Flink?
A
Odpowiedz
11
Zarówno transformacje Join, jak i CoGroup łączą dwa wejścia w kluczowych polach. Różnice to, w jaki sposób funkcje użytkownika są nazywane:
- Dołącz transformacja wywołuje
JoinFunctionz pary pasujące rekordy z obu wejść, które mają te same wartości dla kluczowych dziedzin. To zachowanie jest bardzo podobne do wewnętrznego sprzężenia równości. - Transformacja CoGroup wywołuje iteratory
CoGroupFunctionz dla wszystkich rekordów obu wejść, które mają takie same wartości dla pól kluczowych. Jeśli dane wejściowe nie mają rekordów dla pewnej wartości klucza, przekazywany jest pusty iterator. Transformacja CoGroup może być używana, między innymi, do łączenia wewnętrznych i zewnętrznych równości. Jest więc bardziej ogólny niż transformacja Join.
Patrząc na strategiach wykonawczymi Dołącz i CoGroup, Dołącz mogą być wykonywane przy użyciu sort- i hash oparte dołączyć strategie gdzie jako CoGroup jest zawsze wykonywany przy użyciu strategii opartej sortowania. Stąd połączenia są często bardziej wydajne niż cogroups i powinny być preferowane, jeśli to możliwe.
Powiązane problemy
- 1. Czym różnią się Adobe PhoneGap i Apache Cordova?
- 2. Czym różnią się parametry memory_order_seq_cst i memory_order_acq_rel?
- 3. Czym różnią się 127.0.0.1, 0.0.0.0 i localhost?
- 4. Czym różnią się style.left i element.offsetLeft
- 5. Czym różnią się bcprov i bcprov-ext?
- 6. Czym różnią się os.getuid() i os.geteuid()?
- 7. Czym różnią się te funkcje?
- 8. Czym różnią się te warianty?
- 9. Czym różnią się narzędzia: tekst i android: tekst w Androidzie
- 10. Czym różnią się embedsMany i hasMany w pętli zwrotnej Strongloop
- 11. Czym różnią się abstrakcje od wirtualnych?
- 12. Czym różnią się Surfaceview od TextureView?
- 13. Czym różnią się HashMap od HashMultimap
- 14. Czym różnią się pliki dziennika MongoDB i oplog?
- 15. Czym różnią się graficzne bazy danych i obiektowe bazy danych?
- 16. Czym różnią się konfiguracje kompilacji "Dystrybucja" i "Wydanie"?
- 17. Czym różnią się ReSharper C++ i Visual Assist od
- 18. Czym różnią się układy między układami: "hbox" i układ: "kolumna"
- 19. Czym różnią się "pakiet mvn clean" i "mvn clean install"?
- 20. Apache Flink kontra Twitter Heron?
- 21. Czym różnią się odniesienia do obiektów w java?
- 22. Czym różnią się układy w stosy od stacked coroutines?
- 23. Czym różnią się odniesienia do projektu od zależności projektu?
- 24. Czym różnią się niektóre narzędzia "Android Development/SDK"?
- 25. Czym różnią się właściwości hosta od właściwości polimeru?
- 26. Czym różnią się NSURLConnection od żądania ASI-HTTP?
- 27. Czym różnią się te linie IL? (Zespół wyjściowy Fody)
- 28. Jakie są wszystkie sposoby przydzielania pamięci w C i czym się różnią?
- 29. czym różnią się funkcje stat fstat i lstat w węźle js
- 30. Połączyć dwa strumienie w Apache Flink niezależnie od czasu okna