apache/beam
No python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)?
Geschlossen
#18.552 geöffnet am 03.06.2022
P3coregood first issueimprovementpython
Repository-Metriken
- Stars
- (7.313 Sterne)
- PR-Merge-Metriken
- (PR-Metriken ausstehend)
Beschreibung
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.