golang-github-apache-beam-2-devel-2.33.0~RC1-12.fc39 in Fedora 39
↵ Return to the main page of golang-github-apache-beam-2-devel
View build
Search for updates
Package Info
🠗 Changelog
🠗 Dependencies
🠗 Provides
🠗 Files
Changelog
| Date | Author | Change |
|---|---|---|
| 2021-09-17 | Robert-André Mauchin <zebob dot m at gmail dot com> 2.33.0~RC1-1 | - Uncommitted changes |
Dependencies
- go-filesystem
- golang-cloud-google-devel
- golang-github-google-cmp-devel
- golang-github-google-uuid-devel
- golang-github-linkedin-goavro-devel
- golang-github-protobuf-devel
- golang-github-spf13-cobra-devel
- golang-google-api-devel
- golang-google-genproto-devel
- golang-google-grpc-devel
- golang-google-protobuf-devel
- golang-gopkg-yaml-2-devel
- golang-x-net-devel
- golang-x-oauth2-devel
- golang-x-text-devel
Provides
- golang(github.com/apache/beam/sdks/go/cmd/beamctl/cmd)
- golang(github.com/apache/beam/sdks/go/pkg/beam)
- golang(github.com/apache/beam/sdks/go/pkg/beam/artifact)
- golang(github.com/apache/beam/sdks/go/pkg/beam/artifact/gcsproxy)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/funcx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/graph)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/graph/coder)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/graph/coder/testutil)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/graph/mtime)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/graph/window)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/metrics)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/coderx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec/optimized)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/genx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/graphx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/graphx/schema)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/graphx/v1)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/init)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/session)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/metricsx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/pipelinex)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/runtime/xlangx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/sdf)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/typex)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/dot)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/hooks)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/ioutilx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/jsonx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/protox)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/reflectx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/stringx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/core/util/symtab)
- golang(github.com/apache/beam/sdks/go/pkg/beam/internal/errors)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/avroio)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/bigqueryio)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/databaseio)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/datastoreio)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/filesystem)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/filesystem/gcs)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/filesystem/local)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/filesystem/memfs)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/pubsubio)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/rtrackers/offsetrange)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/synthetic)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/textio)
- golang(github.com/apache/beam/sdks/go/pkg/beam/io/xlang/kafkaio)
- golang(github.com/apache/beam/sdks/go/pkg/beam/log)
- golang(github.com/apache/beam/sdks/go/pkg/beam/model)
- golang(github.com/apache/beam/sdks/go/pkg/beam/model/fnexecution_v1)
- golang(github.com/apache/beam/sdks/go/pkg/beam/model/jobmanagement_v1)
- golang(github.com/apache/beam/sdks/go/pkg/beam/model/pipeline_v1)
- golang(github.com/apache/beam/sdks/go/pkg/beam/options/gcpopts)
- golang(github.com/apache/beam/sdks/go/pkg/beam/options/jobopts)
- golang(github.com/apache/beam/sdks/go/pkg/beam/provision)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/dataflow/dataflowlib)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/direct)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/dot)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/flink)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/samza)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/session)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/spark)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/universal)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/universal/extworker)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/universal/runnerlib)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/vet)
- golang(github.com/apache/beam/sdks/go/pkg/beam/runners/vet/testpipeline)
- golang(github.com/apache/beam/sdks/go/pkg/beam/testing/passert)
- golang(github.com/apache/beam/sdks/go/pkg/beam/testing/ptest)
- golang(github.com/apache/beam/sdks/go/pkg/beam/testing/teststream)
- golang(github.com/apache/beam/sdks/go/pkg/beam/transforms/filter)
- golang(github.com/apache/beam/sdks/go/pkg/beam/transforms/stats)
- golang(github.com/apache/beam/sdks/go/pkg/beam/transforms/top)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/errorx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/execx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/gcsx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/grpcx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/pubsubx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/shimx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/starcgenx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/util/syscallx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/x/beamx)
- golang(github.com/apache/beam/sdks/go/pkg/beam/x/debug)
- golang(github.com/apache/beam/sdks/go/pkg/beam/x/hooks/perf)
- golang(github.com/apache/beam/sdks/go/test/integration)
- golang(github.com/apache/beam/sdks/go/test/integration/io/xlang/kafka)
- golang(github.com/apache/beam/sdks/go/test/integration/primitives)
- golang(github.com/apache/beam/sdks/go/test/integration/synthetic)
- golang(github.com/apache/beam/sdks/go/test/integration/wordcount)
- golang(github.com/apache/beam/sdks/go/test/integration/xlang)
- golang(github.com/apache/beam/sdks/go/test/load)
- golang(github.com/apache/beam/sdks/go/test/regression)
- golang(github.com/apache/beam/sdks/v2/go/cmd/beamctl/cmd)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/artifact)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/artifact/gcsproxy)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/funcx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/graph)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/graph/coder)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/graph/coder/testutil)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/graph/mtime)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/graph/window)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/metrics)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/coderx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec/optimized)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/genx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/graphx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/graphx/schema)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/graphx/v1)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness/init)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness/session)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/metricsx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/pipelinex)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/xlangx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/sdf)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/typex)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/dot)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/hooks)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/ioutilx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/jsonx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/protox)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/reflectx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/stringx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/symtab)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/internal/errors)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/avroio)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/bigqueryio)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/databaseio)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/datastoreio)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/filesystem)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/filesystem/gcs)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/filesystem/local)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/filesystem/memfs)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/pubsubio)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/rtrackers/offsetrange)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/synthetic)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/textio)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/io/xlang/kafkaio)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/log)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/model)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/model/fnexecution_v1)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/model/jobmanagement_v1)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/model/pipeline_v1)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/options/gcpopts)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/options/jobopts)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/provision)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/dataflow)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/dataflow/dataflowlib)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/direct)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/dot)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/flink)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/samza)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/session)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/spark)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/universal)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/universal/extworker)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/universal/runnerlib)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/vet)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/runners/vet/testpipeline)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/testing/passert)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/testing/ptest)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/testing/teststream)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/filter)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/stats)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/transforms/top)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/errorx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/execx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/gcsx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/grpcx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/pubsubx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/shimx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/starcgenx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/util/syscallx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/x/beamx)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/x/debug)
- golang(github.com/apache/beam/sdks/v2/go/pkg/beam/x/hooks/perf)
- golang(github.com/apache/beam/sdks/v2/go/test/integration)
- golang(github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka)
- golang(github.com/apache/beam/sdks/v2/go/test/integration/primitives)
- golang(github.com/apache/beam/sdks/v2/go/test/integration/synthetic)
- golang(github.com/apache/beam/sdks/v2/go/test/integration/wordcount)
- golang(github.com/apache/beam/sdks/v2/go/test/integration/xlang)
- golang(github.com/apache/beam/sdks/v2/go/test/load)
- golang(github.com/apache/beam/sdks/v2/go/test/regression)
- golang-github-apache-beam-2-devel
- golang-ipath(github.com/apache/beam)
- golang-symlink(github.com/apache/beam/sdks/v2)
Files
- usr/
- share/
- doc/
- golang-github-apache-beam-2-devel/
- CHANGES.md
- OWNERS
- README.md
- golang-github-apache-beam-2-devel/
- gocode/
- src/
- github.com/
- apache/
- beam/
- .goipath
- CHANGES.md
- CI.md
- README.md
- sdks/
- go/
- BUILD.md
- README.md
- cmd/
- beamctl/
- cmd/
- artifact.go
- provision.go
- root.go
- main.go
- cmd/
- specialize/
- main.go
- starcgen/
- starcgen.go
- starcgen_test.go
- symtab/
- main.go
- beamctl/
- container/
- boot.go
- pkg/
- beam/
- artifact/
- gcsproxy/
- retrieval.go
- staging.go
- materialize.go
- materialize_test.go
- server_test.go
- stage.go
- stage_test.go
- gcsproxy/
- beam.shims.go
- coder.go
- coder_test.go
- combine.go
- combine_test.go
- core/
- core.go
- funcx/
- doc.go
- fn.go
- fn_test.go
- output.go
- output_test.go
- sideinput.go
- sideinput_test.go
- signature.go
- signature_test.go
- graph/
- bind.go
- bind_test.go
- coder/
- bool.go
- bool_test.go
- bytes.go
- bytes_test.go
- coder.go
- coder_test.go
- double.go
- double_test.go
- int.go
- int_test.go
- iterable.go
- iterable_test.go
- map.go
- map_test.go
- panes.go
- registry.go
- registry_test.go
- row.go
- row_decoder.go
- row_encoder.go
- row_test.go
- stringutf8.go
- stringutf8_test.go
- testutil/
- testutil.go
- testutil_test.go
- time.go
- time_test.go
- varint.go
- varint_test.go
- windows.go
- doc.go
- edge.go
- fn.go
- fn_test.go
- graph.go
- graph_test.go
- mtime/
- time.go
- node.go
- scope.go
- window/
- fn.go
- strategy.go
- trigger.go
- windows.go
- xlang.go
- xlang_test.go
- metrics/
- dumper.go
- metrics.go
- metrics_test.go
- store.go
- runtime/
- coderx/
- coderx.shims.go
- doc.go
- float.go
- float_test.go
- int.go
- string.go
- string_test.go
- varint.go
- varint_test.go
- exec/
- coder.go
- coder_test.go
- cogbk.go
- combine.go
- combine_test.go
- data.go
- datasink.go
- datasource.go
- datasource_test.go
- decode.go
- discard.go
- dynsplit_test.go
- emit.go
- encode.go
- flatten.go
- flatten_test.go
- fn.go
- fn_arity.go
- fn_test.go
- fullvalue.go
- fullvalue_test.go
- hash.go
- hash_test.go
- input.go
- multiplex.go
- multiplex_test.go
- optimized/
- callers.go
- decoders.go
- emitters.go
- encoders.go
- gen.go
- inputs.go
- pardo.go
- pardo_test.go
- pcollection.go
- pcollection_test.go
- plan.go
- reshuffle.go
- sdf.go
- sdf_invokers.go
- sdf_invokers_test.go
- sdf_test.go
- sideinput.go
- status.go
- translate.go
- translate_test.go
- unit.go
- unit_test.go
- util.go
- util_test.go
- window.go
- window_test.go
- genx/
- genx.go
- genx_test.go
- graphx/
- coder.go
- coder_test.go
- cogbk.go
- dataflow.go
- doc.go
- schema/
- logicaltypes.go
- schema.go
- schema_test.go
- serialize.go
- serialize_test.go
- translate.go
- translate_test.go
- tree.go
- user.go
- v1/
- gen.go
- v1.pb.go
- v1.proto
- xlang.go
- xlang_test.go
- harness/
- datamgr.go
- datamgr_test.go
- gen.go
- harness.go
- harness_test.go
- init/
- init.go
- logging.go
- logging_test.go
- monitoring.go
- monitoring_test.go
- session/
- session.pb.go
- session.go
- session.proto
- statemgr.go
- statemgr_test.go
- init.go
- metricsx/
- metricsx.go
- metricsx_test.go
- urns.go
- options.go
- options_test.go
- pipelinex/
- clone.go
- clone_test.go
- replace.go
- replace_test.go
- util.go
- util_test.go
- symbols.go
- types.go
- types_test.go
- xlangx/
- expand.go
- namespace.go
- namespace_test.go
- payload.go
- resolve.go
- coderx/
- sdf/
- lock.go
- sdf.go
- typex/
- class.go
- class_test.go
- fulltype.go
- fulltype_test.go
- special.go
- util/
- dot/
- dot.go
- hooks/
- hooks.go
- hooks_test.go
- ioutilx/
- read.go
- write.go
- jsonx/
- jsonx.go
- protox/
- any.go
- any_test.go
- base64.go
- protox.go
- reflectx/
- call.go
- calls.go
- functions.go
- functions_test.go
- structs.go
- tags.go
- types.go
- util.go
- util_test.go
- stringx/
- bytes.go
- map.go
- symtab/
- symtab.go
- symtab_test.go
- dot/
- create.go
- create_test.go
- doc.go
- doc_test.go
- encoding.go
- encoding_test.go
- example_schema_test.go
- external.go
- external_test.go
- flatten.go
- forward.go
- gbk.go
- impulse.go
- internal/
- errors/
- errors.go
- errors_test.go
- errors/
- io/
- avroio/
- avroio.go
- bigqueryio/
- bigquery.go
- bigquery_test.go
- databaseio/
- database.go
- loader.go
- mapper.go
- util.go
- util_test.go
- writer.go
- datastoreio/
- datastore.go
- datastore_test.go
- filesystem/
- filesystem.go
- gcs/
- gcs.go
- local/
- local.go
- memfs/
- memory.go
- memory_test.go
- util.go
- pubsubio/
- pubsubio.go
- rtrackers/
- offsetrange/
- offsetrange.go
- offsetrange_test.go
- offsetrange/
- synthetic/
- rand.go
- source.go
- source_test.go
- step.go
- step_test.go
- textio/
- sdf.go
- sdf_test.go
- textio.go
- textio_test.go
- xlang/
- kafkaio/
- kafka.go
- kafkaio/
- avroio/
- log/
- log.go
- standard.go
- metrics.go
- metrics_test.go
- model/
- PROTOBUF.md
- fnexecution_v1/
- beam_fn_api.pb.go
- beam_fn_api_grpc.pb.go
- beam_provision_api.pb.go
- beam_provision_api_grpc.pb.go
- gen.go
- jobmanagement_v1/
- beam_artifact_api.pb.go
- beam_artifact_api_grpc.pb.go
- beam_expansion_api.pb.go
- beam_expansion_api_grpc.pb.go
- beam_job_api.pb.go
- beam_job_api_grpc.pb.go
- pipeline_v1/
- beam_runner_api.pb.go
- beam_runner_api_grpc.pb.go
- endpoints.pb.go
- external_transforms.pb.go
- metrics.pb.go
- schema.pb.go
- standard_window_fns.pb.go
- option.go
- options/
- gcpopts/
- options.go
- jobopts/
- options.go
- stringSlice.go
- gcpopts/
- pardo.go
- pardo_test.go
- partition.go
- partition_test.go
- pcollection.go
- pipeline.go
- provision/
- provision.go
- provision_test.go
- runner.go
- runners/
- dataflow/
- dataflow.go
- dataflow_test.go
- dataflowlib/
- execute.go
- fixup.go
- job.go
- job_test.go
- messages.go
- metrics.go
- metrics_test.go
- stage.go
- translate.go
- direct/
- buffer.go
- direct.go
- gbk.go
- gbk_test.go
- impulse.go
- dot/
- dot.go
- flink/
- flink.go
- samza/
- samza.go
- session/
- session.go
- spark/
- spark.go
- universal/
- extworker/
- extworker.go
- extworker_test.go
- runnerlib/
- compile.go
- execute.go
- job.go
- stage.go
- universal.go
- extworker/
- vet/
- testpipeline/
- functions.go
- testpipeline.go
- testpipeline.shims.go
- vet.go
- vet_test.go
- testpipeline/
- dataflow/
- schema.go
- testing/
- passert/
- count.go
- count_test.go
- equals.go
- equals_test.go
- floats.go
- floats_test.go
- hash.go
- passert.go
- passert.shims.go
- passert_test.go
- sum.go
- sum_test.go
- ptest/
- ptest.go
- teststream/
- teststream.go
- teststream_test.go
- passert/
- transforms/
- filter/
- distinct.go
- distinct_test.go
- filter.go
- filter.shims.go
- filter_test.go
- stats/
- count.go
- count_test.go
- max.go
- max_switch.go
- max_test.go
- mean.go
- mean_test.go
- min.go
- min_switch.go
- min_test.go
- quantiles.go
- quantiles_test.go
- stats.shims.go
- sum.go
- sum_switch.go
- sum_test.go
- util.go
- util_gen.go
- top/
- top.go
- top.shims.go
- top_test.go
- filter/
- util/
- errorx/
- guarded.go
- execx/
- exec.go
- gcsx/
- gcs.go
- gcs_test.go
- grpcx/
- dial.go
- hook.go
- metadata.go
- pubsubx/
- pubsub.go
- shimx/
- generate.go
- generate_test.go
- starcgenx/
- starcgenx.go
- starcgenx_test.go
- syscallx/
- syscall.go
- syscall_default.go
- syscall_linux.go
- errorx/
- util.go
- validate.go
- windowing.go
- x/
- beamx/
- run.go
- debug/
- debug.shims.go
- doc.go
- head.go
- print.go
- hooks/
- perf/
- perf.go
- perf/
- beamx/
- xlang.go
- artifact/
- beam/
- test/
- integration/
- driver/
- driver.go
- flags.go
- integration.go
- io/
- xlang/
- kafka/
- jar.go
- kafka.go
- kafka_test.go
- kafka/
- xlang/
- primitives/
- cogbk.go
- cogbk_test.go
- flatten.go
- flatten_test.go
- pardo.go
- pardo_test.go
- primitives_test.go
- teststream.go
- teststream_test.go
- windowinto.go
- windowinto_test.go
- synthetic/
- synthetic.go
- synthetic_test.go
- wordcount/
- wordcount.go
- wordcount_test.go
- xlang/
- xlang.go
- xlang_test.go
- driver/
- load/
- cogbk/
- cogbk.go
- combine/
- combine.go
- group_by_key/
- group_by_key.go
- pardo/
- pardo.go
- sideinput/
- sideinput.go
- util.go
- cogbk/
- regression/
- coders/
- fromyaml/
- fromyaml.go
- fromyaml_test.go
- fromyaml/
- lperror.go
- lperror_test.go
- pardo.go
- pardo_test.go
- regression_test.go
- coders/
- integration/
- v2/
- go/
- BUILD.md
- README.md
- cmd/
- beamctl/
- cmd/
- artifact.go
- provision.go
- root.go
- main.go
- cmd/
- specialize/
- main.go
- starcgen/
- starcgen.go
- starcgen_test.go
- symtab/
- main.go
- beamctl/
- container/
- pkg/
- beam/
- artifact/
- gcsproxy/
- retrieval.go
- staging.go
- materialize.go
- materialize_test.go
- server_test.go
- stage.go
- stage_test.go
- gcsproxy/
- beam.shims.go
- coder.go
- coder_test.go
- combine.go
- combine_test.go
- core/
- core.go
- funcx/
- doc.go
- fn.go
- fn_test.go
- output.go
- output_test.go
- sideinput.go
- sideinput_test.go
- signature.go
- signature_test.go
- graph/
- coder/
- bool.go
- bool_test.go
- bytes.go
- bytes_test.go
- coder.go
- coder_test.go
- double.go
- double_test.go
- int.go
- int_test.go
- iterable.go
- iterable_test.go
- map.go
- map_test.go
- panes.go
- registry.go
- registry_test.go
- row.go
- row_decoder.go
- row_encoder.go
- row_test.go
- stringutf8.go
- stringutf8_test.go
- testutil/
- testutil.go
- testutil_test.go
- time.go
- time_test.go
- varint.go
- varint_test.go
- windows.go
- mtime/
- time.go
- window/
- fn.go
- strategy.go
- trigger.go
- windows.go
- coder/
- metrics/
- dumper.go
- metrics.go
- metrics_test.go
- store.go
- runtime/
- coderx/
- coderx.shims.go
- doc.go
- float.go
- float_test.go
- int.go
- string.go
- string_test.go
- varint.go
- varint_test.go
- exec/
- coder.go
- coder_test.go
- cogbk.go
- combine.go
- combine_test.go
- data.go
- datasink.go
- datasource.go
- datasource_test.go
- decode.go
- discard.go
- dynsplit_test.go
- emit.go
- encode.go
- flatten.go
- flatten_test.go
- fn.go
- fn_arity.go
- fn_test.go
- fullvalue.go
- fullvalue_test.go
- hash.go
- hash_test.go
- input.go
- multiplex.go
- multiplex_test.go
- optimized/
- pardo.go
- pardo_test.go
- pcollection.go
- pcollection_test.go
- plan.go
- reshuffle.go
- sdf.go
- sdf_invokers.go
- sdf_invokers_test.go
- sdf_test.go
- sideinput.go
- status.go
- translate.go
- translate_test.go
- unit.go
- unit_test.go
- util.go
- util_test.go
- window.go
- window_test.go
- genx/
- graphx/
- coder.go
- coder_test.go
- cogbk.go
- dataflow.go
- doc.go
- schema/
- logicaltypes.go
- schema.go
- schema_test.go
- serialize.go
- serialize_test.go
- translate.go
- translate_test.go
- tree.go
- user.go
- v1/
- gen.go
- v1.pb.go
- v1.proto
- xlang.go
- xlang_test.go
- harness/
- datamgr.go
- datamgr_test.go
- gen.go
- harness.go
- harness_test.go
- init/
- init.go
- logging.go
- logging_test.go
- monitoring.go
- monitoring_test.go
- session/
- session.pb.go
- session.go
- session.proto
- statemgr.go
- statemgr_test.go
- init.go
- metricsx/
- metricsx.go
- metricsx_test.go
- urns.go
- options.go
- options_test.go
- pipelinex/
- clone.go
- clone_test.go
- replace.go
- replace_test.go
- util.go
- util_test.go
- symbols.go
- types.go
- types_test.go
- xlangx/
- expand.go
- namespace.go
- namespace_test.go
- payload.go
- resolve.go
- coderx/
- sdf/
- lock.go
- sdf.go
- typex/
- class.go
- class_test.go
- fulltype.go
- fulltype_test.go
- special.go
- util/
- dot/
- dot.go
- hooks/
- hooks.go
- hooks_test.go
- ioutilx/
- read.go
- write.go
- jsonx/
- jsonx.go
- protox/
- any.go
- any_test.go
- base64.go
- protox.go
- reflectx/
- call.go
- calls.go
- functions.go
- functions_test.go
- structs.go
- tags.go
- types.go
- util.go
- util_test.go
- stringx/
- bytes.go
- map.go
- symtab/
- symtab.go
- symtab_test.go
- dot/
- create.go
- create_test.go
- doc.go
- doc_test.go
- encoding.go
- encoding_test.go
- example_schema_test.go
- external.go
- external_test.go
- flatten.go
- forward.go
- gbk.go
- impulse.go
- internal/
- errors/
- errors.go
- errors_test.go
- errors/
- io/
- avroio/
- avroio.go
- bigqueryio/
- bigquery.go
- bigquery_test.go
- databaseio/
- database.go
- loader.go
- mapper.go
- util.go
- util_test.go
- writer.go
- filesystem/
- filesystem.go
- gcs/
- gcs.go
- local/
- memfs/
- memory.go
- memory_test.go
- util.go
- pubsubio/
- pubsubio.go
- rtrackers/
- offsetrange/
- offsetrange.go
- offsetrange_test.go
- offsetrange/
- synthetic/
- rand.go
- source.go
- source_test.go
- step.go
- step_test.go
- textio/
- sdf.go
- sdf_test.go
- textio.go
- textio_test.go
- xlang/
- kafkaio/
- kafka.go
- kafkaio/
- avroio/
- log/
- log.go
- standard.go
- metrics.go
- metrics_test.go
- model/
- PROTOBUF.md
- fnexecution_v1/
- beam_fn_api.pb.go
- beam_fn_api_grpc.pb.go
- beam_provision_api.pb.go
- beam_provision_api_grpc.pb.go
- gen.go
- jobmanagement_v1/
- beam_artifact_api.pb.go
- beam_artifact_api_grpc.pb.go
- beam_expansion_api.pb.go
- beam_expansion_api_grpc.pb.go
- beam_job_api.pb.go
- beam_job_api_grpc.pb.go
- pipeline_v1/
- beam_runner_api.pb.go
- beam_runner_api_grpc.pb.go
- endpoints.pb.go
- external_transforms.pb.go
- metrics.pb.go
- schema.pb.go
- standard_window_fns.pb.go
- option.go
- options/
- gcpopts/
- options.go
- jobopts/
- options.go
- stringSlice.go
- gcpopts/
- pardo.go
- pardo_test.go
- partition.go
- partition_test.go
- pcollection.go
- pipeline.go
- provision/
- provision.go
- provision_test.go
- runner.go
- runners/
- dataflow/
- dataflow.go
- dataflow_test.go
- dataflowlib/
- execute.go
- fixup.go
- job.go
- job_test.go
- messages.go
- metrics.go
- metrics_test.go
- stage.go
- translate.go
- direct/
- buffer.go
- direct.go
- gbk.go
- gbk_test.go
- impulse.go
- dot/
- dot.go
- flink/
- flink.go
- samza/
- samza.go
- session/
- session.go
- spark/
- spark.go
- universal/
- extworker/
- extworker.go
- extworker_test.go
- runnerlib/
- compile.go
- execute.go
- job.go
- stage.go
- universal.go
- extworker/
- vet/
- testpipeline/
- functions.go
- testpipeline.go
- testpipeline.shims.go
- vet.go
- vet_test.go
- testpipeline/
- dataflow/
- schema.go
- testing/
- passert/
- count.go
- count_test.go
- equals.go
- equals_test.go
- floats.go
- floats_test.go
- hash.go
- passert.go
- passert.shims.go
- passert_test.go
- sum.go
- sum_test.go
- ptest/
- ptest.go
- teststream/
- teststream.go
- teststream_test.go
- passert/
- transforms/
- filter/
- distinct.go
- distinct_test.go
- filter.go
- filter.shims.go
- filter_test.go
- stats/
- count.go
- count_test.go
- max.go
- max_switch.go
- max_test.go
- mean.go
- mean_test.go
- min.go
- min_switch.go
- min_test.go
- quantiles.go
- quantiles_test.go
- stats.shims.go
- sum.go
- sum_switch.go
- sum_test.go
- util.go
- util_gen.go
- top/
- top.go
- top.shims.go
- top_test.go
- filter/
- util/
- errorx/
- guarded.go
- execx/
- exec.go
- gcsx/
- gcs.go
- gcs_test.go
- grpcx/
- pubsubx/
- pubsub.go
- shimx/
- generate.go
- generate_test.go
- starcgenx/
- starcgenx.go
- starcgenx_test.go
- syscallx/
- syscall.go
- syscall_default.go
- syscall_linux.go
- errorx/
- util.go
- validate.go
- windowing.go
- x/
- beamx/
- run.go
- debug/
- debug.shims.go
- doc.go
- head.go
- print.go
- hooks/
- perf/
- perf.go
- perf/
- beamx/
- xlang.go
- artifact/
- beam/
- test/
- integration/
- driver/
- driver.go
- flags.go
- integration.go
- io/
- xlang/
- kafka/
- jar.go
- kafka.go
- kafka_test.go
- kafka/
- xlang/
- primitives/
- cogbk.go
- cogbk_test.go
- flatten.go
- flatten_test.go
- pardo.go
- pardo_test.go
- primitives_test.go
- teststream.go
- teststream_test.go
- windowinto.go
- windowinto_test.go
- synthetic/
- synthetic.go
- synthetic_test.go
- wordcount/
- wordcount.go
- wordcount_test.go
- xlang/
- xlang.go
- xlang_test.go
- driver/
- load/
- cogbk/
- cogbk.go
- combine/
- combine.go
- group_by_key/
- group_by_key.go
- pardo/
- sideinput/
- sideinput.go
- util.go
- cogbk/
- regression/
- coders/
- fromyaml/
- fromyaml.go
- fromyaml_test.go
- fromyaml/
- lperror.go
- lperror_test.go
- pardo.go
- pardo_test.go
- regression_test.go
- coders/
- integration/
- go/
- go/
- beam/
- apache/
- github.com/
- src/
- licenses/
- golang-github-apache-beam-2-devel/
- LICENSE
- NOTICE
- golang-github-apache-beam-2-devel/
- doc/
- share/
Sources on Pagure