apache/beam
Voir sur GitHubNo python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)?
Open
#18 552 ouverte le 3 juin 2022
P3coregood first issueimprovementpython
Métriques du dépôt
- Stars
- (7 313 stars)
- Métriques de merge PR
- (Merge moyen 6j) (243 PRs mergées en 30 j)
Description
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.