apache/beam
在 GitHub 查看No python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)?
Open
#18,552 创建于 2022年6月3日
P3coregood first issueimprovementpython
仓库指标
- Star
- (7,313 star)
- PR 合并指标
- (平均合并 6天) (30 天内合并 243 个 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.