apache/beam

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

Geschlossen

#18.552 geöffnet am 03.06.2022

 (0 Kommentare) (0 Reaktionen) (0 zugewiesene Personen)Java (4.097 Forks)batch import
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.

Contributor Guide