apache/beam
Auf GitHub ansehenNo python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)?
Open
#18.552 geöffnet am 3. Juni 2022
P3coregood first issueimprovementpython
Repository-Metriken
- Stars
- (7.313 Stars)
- PR-Merge-Metriken
- (Durchschn. Merge 6T) (243 gemergte PRs in 30 T)
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.