0
當我想用Flink sinkFunction寫入或讀取一些數據到MySQL時，Flink數據庫連接出現問題。每次操作的數據量都很小。但同時可能會調用很多sinkFuction。我想知道是否有更好的方法來以低成本解決這個問題？Flink數據庫連接
A
回答
0
因此，您可以使用RichSinkFunction並覆蓋方法open和close來創建和銷燬與MySQL的連接。或者也許使用Table API與Table Sink是一種更好的方法（您可以在這裏找到更多信息：https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table/sourceSinks.html#define-a-tablesink）
相關問題
- 1. Flink Kafka連接器
- 2. 連接數據庫
- 3. 數據庫連接
- 4. 數據庫連接
- 5. 數據庫連接
- 6. 連接數據庫
- 7. 數據庫連接
- 8. 數據庫連接
- 9. 連接數據庫
- 10. 連接數據庫
- 11. 數據庫連接
- 12. 庫或數據庫連接
- 13. WCF數據庫連接：只有一個數據庫連接
- 14. 序列化跨數據庫連接的數據庫連接
- 15. 數據庫連接錯誤（3）：無法連接到數據庫'，
- 16. 數據庫連接，並與數據庫
- 17. DSNLess數據庫連接
- 18. 連接Xamarin數據庫
- 19. 用flex連接數據庫
- 20. HSDC數據庫連接
- 21. Java數據庫連接
- 22. 用Squeryl連接數據庫
- 23. munal連接數據庫笨
- 24. 關閉數據庫連接
- 25. PHP - MySQL數據庫連接
- 26. Asp.net mysql數據庫連接
- 27. asp.net數據庫連接
- 28. unix shellcripting連接數據庫
- 29. 錯誤連接數據庫
- 30. 連接到SQL數據庫