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