0
我想建立flink连接到OrientDB数据库。我想处理数据局部性特征,在数据集中以并行方式加载所有数据的最佳方式是什么?我知道我必须处理OrientDB的数据读取方式,但在flink方面,wath是我必须处理这类任务的原则和最佳实践。构建apache flink连接器的最佳方式是什么?
我想建立flink连接到OrientDB数据库。我想处理数据局部性特征,在数据集中以并行方式加载所有数据的最佳方式是什么?我知道我必须处理OrientDB的数据读取方式,但在flink方面,wath是我必须处理这类任务的原则和最佳实践。构建apache flink连接器的最佳方式是什么?
可以参考弗林克-HBase的连接器下弗林克连接器在flink source。基本上,您必须实现名为的接口InputFormat或RichInputFormat如果您需要RuntimeContext。