My pleasure~
还有一点, 对于Neo4j数据源,partition除了是spark的repartition参数外,还是 exchange读取neo4j时的分页size。
exchange内部读取neo4j是通过skip start limit (partition +1) 分页读取的
好的,明白了。
My pleasure~
还有一点, 对于Neo4j数据源,partition除了是spark的repartition参数外,还是 exchange读取neo4j时的分页size。
exchange内部读取neo4j是通过skip start limit (partition +1) 分页读取的
好的,明白了。