apache/beam

No python equivalent of org.apache.beam.sdk.transforms.Sample.any(100)?

Fermée

#18 552 ouverte le 3 juin 2022

 (0 commentaire) (0 réaction) (0 personne assignée)Java (4 097 forks)batch import
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.

Guide contributeur