構建apache flink連接器的最佳方式是什麼？

Question

我想建立flink連接到OrientDB數據庫。我想處理數據局部性特徵，在數據集中以並行方式加載所有數據的最佳方式是什麼？我知道我必須處理OrientDB的數據讀取方式，但在flink方面，wath是我必須處理這類任務的原則和最佳實踐。

Answer 1

可以參考弗林克-HBase的連接器下弗林克連接器在flink source。基本上，您必須實現名爲的接口InputFormat或RichInputFormat如果您需要RuntimeContext。