ApacheのFlinkコネクタを構築する最も良い方法は何ですか？

Question

OriinkDBデータベースにflinkコネクタを構築します。私はデータのローカリティ特性を扱いたい、何がデータセット内のすべてのデータを並列にロードする最良の方法ですか？私はデータを読むためにOrientDBの方法を扱わなければならないことを知っていますが、フリンクの面では、この種の仕事を処理しなければならない原則とベストプラクティスがあります。

Answer 1

あなたはFLINK-コネクタflink sourceで下FLINK、HBaseのコネクタを参照することができます。基本的には、RuntimeContextが必要な場合は、InputFormatまたはRichInputFormatというインターフェイスを実装する必要があります。