0
Flinkでデータを書き込んだり読み込んだりするときに、FlinkのsinkFunction
でMySQLにデータを書き込んだり、読み込んだりするときに、データのサイズが小さくなります。しかし、同時に多くのsinkFuction
が呼び出されることがあります。低コストでこの問題を解決する良い方法があるかどうかを知りたいですか?Flinkデータベース接続
Flinkでデータを書き込んだり読み込んだりするときに、FlinkのsinkFunction
でMySQLにデータを書き込んだり、読み込んだりするときに、データのサイズが小さくなります。しかし、同時に多くのsinkFuction
が呼び出されることがあります。低コストでこの問題を解決する良い方法があるかどうかを知りたいですか?Flinkデータベース接続
RichSinkFunction
を使用して、open
とclose
のメソッドをオーバーライドして、MySQLへの接続を作成して破壊することができます。テーブルAPIを使用したテーブルAPIを使用している方が良い方法です(詳細はこちらをご覧ください:https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table/sourceSinks.html#define-a-tablesink)