go/

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

Directories ¶

Path	Synopsis
cmd
beamctl command
beamctl/cmd
specialize command
starcgen command
symtab command
container
examples
complete/autocomplete command
contains command
cookbook/combine command
cookbook/filter command
cookbook/join command
cookbook/max command
cookbook/tornadoes command
debugging_wordcount command
forest command
grades command
minimal_wordcount command
multiout command
pingpong command
readavro command
streaming_wordcap command
stringsplit command
windowed_wordcount command
wordcount command
xlang
xlang/cogroup_by command
xlang/combine command
xlang/combine_globally command
xlang/flatten command
xlang/group_by command
xlang/multi_input_output command
xlang/partition command
xlang/wordcount command
yatzy command
pkg
beam
beam/artifact
beam/artifact/gcsproxy
beam/core
beam/core/funcx
beam/core/graph
beam/core/graph/coder
beam/core/graph/coder/testutil
beam/core/graph/mtime
beam/core/graph/window
beam/core/metrics
beam/core/runtime
beam/core/runtime/coderx
beam/core/runtime/exec
beam/core/runtime/exec/optimized
beam/core/runtime/genx
beam/core/runtime/graphx
beam/core/runtime/graphx/schema
beam/core/runtime/graphx/v1
beam/core/runtime/harness
beam/core/runtime/harness/init
beam/core/runtime/harness/session
beam/core/runtime/metricsx
beam/core/runtime/pipelinex
beam/core/runtime/xlangx
beam/core/sdf
beam/core/typex
beam/core/util/dot
beam/core/util/hooks
beam/core/util/ioutilx
beam/core/util/jsonx
beam/core/util/protox
beam/core/util/reflectx
beam/core/util/stringx
beam/core/util/symtab
beam/internal/errors
beam/io/avroio
beam/io/bigqueryio
beam/io/databaseio
beam/io/datastoreio
beam/io/filesystem
beam/io/filesystem/gcs
beam/io/filesystem/local
beam/io/filesystem/memfs
beam/io/pubsubio
beam/io/pubsubio/v1
beam/io/rtrackers/offsetrange
beam/io/synthetic
beam/io/textio
beam/log
beam/model
beam/model/fnexecution_v1
beam/model/jobmanagement_v1
beam/model/pipeline_v1
beam/options/gcpopts
beam/options/jobopts
beam/provision
beam/runners/dataflow
beam/runners/dataflow/dataflowlib
beam/runners/direct
beam/runners/dot
beam/runners/flink
beam/runners/session
beam/runners/spark
beam/runners/universal
beam/runners/universal/extworker
beam/runners/universal/runnerlib
beam/runners/vet
beam/runners/vet/testpipeline
beam/testing/passert
beam/testing/ptest
beam/transforms/filter
beam/transforms/stats
beam/transforms/top
beam/util/errorx
beam/util/execx
beam/util/gcsx
beam/util/grpcx
beam/util/pubsubx
beam/util/shimx
beam/util/starcgenx
beam/util/syscallx
beam/x/beamx
beam/x/debug
beam/x/hooks/perf
test
integration
integration/driver command
integration/primitives
integration/synthetic
integration/wordcount
integration/xlang
load
load/cogbk command
load/combine command
load/group_by_key command
load/pardo command
load/sideinput command
regression
regression/coders/fromyaml command

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL