Back to godoc.org

Directory github.com/apache/beam/sdks/go/pkg/beam/io

v2.23.0+incompatible
Latest Go to latest

The latest major version is .

Published: Jul 22, 2020 | License: Apache-2.0 | Module: github.com/apache/beam
Path Synopsis
avroio Package avroio contains transforms for reading and writing avro files.
bigqueryio Package bigqueryio provides transformations and utilities to interact with Google BigQuery.
databaseio Package databaseio provides transformations and utilities to interact with generic database database/sql API.
datastoreio Package datastoreio provides transformations and utilities to interact with Google Datastore.
filesystem Package filesystem contains an extensible file system abstraction.
filesystem/gcs Package gcs contains a Google Cloud Storage (GCS) implementation of the Beam file system.
filesystem/local Package local contains a local file implementation of the Beam file system.
filesystem/memfs Package memfs contains a in-memory Beam filesystem.
pubsubio Package pubsubio provides access to PubSub on Dataflow streaming.
pubsubio/v1 Package v1 is a generated protocol buffer package.
rtrackers/offsetrange Package offsetrange defines a restriction and restriction tracker for offset ranges.
synthetic Package synthetic contains transforms for creating synthetic pipelines.
textio Package textio contains transforms for reading and writing text files.