FlinkでParallelDataSourceへの非パラレルデータソース

Question

Apache Flinkで非パラレルデータソースをパラレルデータソースに変換したいと考えています。私はそれがNOOPマップ機能を実装することによって行われましたが、私はよりエレガントな方法があると仮定し

int partitions = env.getParallelim(); 

DataSource<String> input = new CustomDataSource<String>(); 
DataSource<String> parallel = input.setParallelism(partitions).suffle(); 

：擬似コードでは、このようなものになるだろう。あなたがインターフェイスとしてParallelSourceFunctionの代わりSourceFunctionを使用することができます

おかげ

Answer 1

はCustomDataSourceに実装されます。

参照：https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/functions/source/ParallelSourceFunction.html