Ich möchte Flink-Connector zur OrientDB-Datenbank bauen. Ich will Daten Lokalität Merkmal behandeln, was ist der beste Weg, alle Daten parallel in einem Datensatz zu laden? Ich weiß, dass ich mit der OrientDB-Methode zum Lesen von Daten umgehen muss, aber auf der anderen Seite sind die Prinzipien und Best Practices, mit denen ich diese Art von Aufgabe bewältigen muss.Was ist der beste Weg, um einen Apache Flink Stecker zu bauen?
0
A
Antwort
0
können Sie beziehen sich auf flink-hbase Stecker unter flink-Anschlüsse in flink source. Grundsätzlich müssen Sie die Schnittstelle InputFormat oder RichInputFormat implementieren, wenn Sie die RuntimeContext benötigen.
Verwandte Themen
- 1. Was ist der beste Weg, um einen Datenrahmen zu umgehen?
- 2. Was ist der beste Weg, um einen ByteArrayOutputStream zu schließen?
- 3. Was ist der beste Weg, um einen "Timer" zu implementieren?
- 4. Was ist der beste Weg, um einen InputStream zu überwachen?
- 5. Was ist der beste Weg, um einen angularJS Audio Player zu bauen?
- 6. Was ist der beste Weg, um einen Stream um
- 7. Was ist der beste Weg, um einen Nutch Index aufzufrischen?
- 8. Was ist der beste Weg, um eine Tabelle zu deduplizieren?
- 9. Was ist der beste Weg, um eine Animation zu fahren?
- 10. Was ist der beste Weg, um eine Liste zu kopieren?
- 11. Was ist der beste Weg, um mehrere Aktionen zu behandeln?
- 12. Was ist der beste Weg, um vorberechnete Daten zu implementieren?
- 13. Was ist der beste Weg, um mehrere Suchoptionen zu behandeln?
- 14. Was ist der beste Weg, um mit OSGI zu beginnen?
- 15. Was ist der beste Weg, um ein Verzeichnis zu leeren?
- 16. bash - Was ist der beste Weg, um Ergebnisse zu zählen?
- 17. Was ist der beste Weg, um ähnliche Strings zu bearbeiten?
- 18. Was ist der beste Weg, um eine Eigenschaft zu deklarieren?
- 19. Was ist der beste Weg, um in C++ zu casten?
- 20. Was ist der beste Weg, um jQuery zu lernen?
- 21. Was ist der beste Weg, um innere Produkte zu bilden?
- 22. Was ist der beste Weg, um JavaScript-Funktionen zu trennen?
- 23. Was ist der beste Weg, um REST-Webdienste zu nutzen?
- 24. Was ist der beste Weg, um eine IllegalArgumentException zu fangen
- 25. Was ist der beste Weg, um Code zu organisieren?
- 26. Was ist der beste Weg, um mit NHibernate zu beginnen?
- 27. Was ist der beste Weg, um eine Sitemap zu erstellen?
- 28. Was ist der beste Weg, um srand() zu säen?
- 29. Was ist der beste Weg, um eine Enumeration zu erhöhen?
- 30. Was ist der beste Weg, um Flags Enum zu vergleichen?