apache/beam
No python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)?
Fermée
#18 552 ouverte le 3 juin 2022
P3coregood first issueimprovementpython
Métriques du dépôt
- Stars
- (7 313 étoiles)
- Métriques de merge PR
- (Métriques PR en attente)
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.