beam: Index | Files

package primitives

import ""


Package Files

cogbk.go flatten.go pardo.go

func CoGBK Uses

func CoGBK() *beam.Pipeline

CoGBK tests CoGBK.

func Flatten Uses

func Flatten() *beam.Pipeline

Flatten tests flatten.

func FlattenDup Uses

func FlattenDup() *beam.Pipeline

FlattenDups tests flatten with the same input multiple times.

func ParDoKVSideInput Uses

func ParDoKVSideInput() *beam.Pipeline

ParDoKVSideInput computes the sum of ints using a KV side input.

func ParDoMultiOutput Uses

func ParDoMultiOutput() *beam.Pipeline

ParDoMultiOutput test a DoFn with multiple output.

func ParDoSideInput Uses

func ParDoSideInput() *beam.Pipeline

ParDoSideInput computes the sum of ints using a side input.

func Reshuffle Uses

func Reshuffle() *beam.Pipeline

Reshuffle tests Reshuffle.

func ReshuffleKV Uses

func ReshuffleKV() *beam.Pipeline

ReshuffleKV tests Reshuffle with KV PCollections.

Package primitives imports 3 packages (graph) and is imported by 1 packages. Updated 2021-01-28. Refresh now. Tools for package owners.