构建apache flink连接器的最佳方式是什么？

Question

我想建立flink连接到OrientDB数据库。我想处理数据局部性特征，在数据集中以并行方式加载所有数据的最佳方式是什么？我知道我必须处理OrientDB的数据读取方式，但在flink方面，wath是我必须处理这类任务的原则和最佳实践。

Answer 1

可以参考弗林克-HBase的连接器下弗林克连接器在flink source。基本上，您必须实现名为的接口InputFormat或RichInputFormat如果您需要RuntimeContext。