directory github.com/apache/beam/sdks/go/pkg

v2.21.0+incompatible

Latest Go to latest

Published: May 14, 2020 | License: UNKNOWN | Module: github.com/apache/beam

Path	Synopsis
beam
beam/artifact
beam/artifact/gcsproxy
beam/core/funcx
beam/core/graph
beam/core/graph/coder
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/graphx
beam/core/runtime/graphx/v1
beam/core/runtime/harness
beam/core/runtime/harness/init
beam/core/runtime/harness/session
beam/core/runtime/pipelinex
beam/core/sdf
beam/core/typex
beam/core/util/dot
beam/core/util/hooks
beam/core/util/ioutilx
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/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/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