apache/beam
No python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)?
已关闭
#18,552 创建于 2022年6月3日
P3coregood first issueimprovementpython
仓库指标
- 星标
- (7,313 个星标)
- PR 合并指标
- (PR 指标待抓取)
描述
Java's org.apache.beam.sdk.transforms.Sample.any will return a PCollection with bounded size (filtering strategy). The closest python eqiuvalent is beam.Sample.FixedSizeGlobally(n) whover, this version uses a combiner strategy, returning a list with n elements; which does not scale if n is "bigger than what fits in memory".
Imported from Jira BEAM-3000. Original Jira may contain additional context. Reported by: rodrigob.