Documentation
¶
Index ¶
- func Largest[T any](s beam.Scope, c gleam.PCollection[T], n int, fn func(a, b T) bool) gleam.PCollection[T]
- func LargestPerKey[K, V any](s beam.Scope, c gleam.PCollection[gleam.KV[K, V]], n int, fn func(a, b V) bool) gleam.PCollection[gleam.KV[K, []V]]
- func Smallest[T any](s beam.Scope, c gleam.PCollection[T], n int, fn func(a, b T) bool) gleam.PCollection[T]
- func SmallestPerKey[K, V any](s beam.Scope, c gleam.PCollection[gleam.KV[K, V]], n int, fn func(a, b V) bool) gleam.PCollection[gleam.KV[K, []V]]
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Largest ¶
func Largest[T any](s beam.Scope, c gleam.PCollection[T], n int, fn func(a, b T) bool) gleam.PCollection[T]
func LargestPerKey ¶
func Smallest ¶
func Smallest[T any](s beam.Scope, c gleam.PCollection[T], n int, fn func(a, b T) bool) gleam.PCollection[T]
func SmallestPerKey ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.