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.