We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
这一段提到 “比如 partition 99 里面只含有 9 个 records”。请问为什么 partition 99 里面有 9 个 records?
看前面提供的代码,在 flatMap 运行中进行初始化的时候,每个 partition 里应该是有 numKVPairs 个,也就是 10000 个 records.
这里说 9 个 records 是因为经过了 flatMap 操作后,可能只有 9 个 records 被分配到这个 partition 吗?
The text was updated successfully, but these errors were encountered:
这里没有说清楚,抱歉。 应该是 10,000 个 records,这里说 9 个只是画图方便,有空我会再改下,谢谢指出。
Sorry, something went wrong.
了解了。感谢回复!
No branches or pull requests
这一段提到 “比如 partition 99 里面只含有 9 个 records”。请问为什么 partition 99 里面有 9 个 records?
看前面提供的代码,在 flatMap 运行中进行初始化的时候,每个 partition 里应该是有 numKVPairs 个,也就是 10000 个 records.
这里说 9 个 records 是因为经过了 flatMap 操作后,可能只有 9 个 records 被分配到这个 partition 吗?
The text was updated successfully, but these errors were encountered: