beam

module

v2.30.0+incompatible Latest Latest Go to latest Published: May 28, 2021 License: UNKNOWN not legal advice

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

Directories ¶

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

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