Directories
¶
| Path | Synopsis |
|---|---|
|
Package avroio contains transforms for reading and writing avro files.
|
Package avroio contains transforms for reading and writing avro files. |
|
Package bigqueryio provides transformations and utilities to interact with Google BigQuery.
|
Package bigqueryio provides transformations and utilities to interact with Google BigQuery. |
|
Package databaseio provides transformations and utilities to interact with generic database database/sql API.
|
Package databaseio provides transformations and utilities to interact with generic database database/sql API. |
|
Package datastoreio provides transformations and utilities to interact with Google Datastore.
|
Package datastoreio provides transformations and utilities to interact with Google Datastore. |
|
Package filesystem contains an extensible file system abstraction.
|
Package filesystem contains an extensible file system abstraction. |
|
gcs
Package gcs contains a Google Cloud Storage (GCS) implementation of the Beam file system.
|
Package gcs contains a Google Cloud Storage (GCS) implementation of the Beam file system. |
|
local
Package local contains a local file implementation of the Beam file system.
|
Package local contains a local file implementation of the Beam file system. |
|
memfs
Package memfs contains a in-memory Beam filesystem.
|
Package memfs contains a in-memory Beam filesystem. |
|
Package pubsubio provides access to PubSub on Dataflow streaming.
|
Package pubsubio provides access to PubSub on Dataflow streaming. |
|
rtrackers
|
|
|
offsetrange
Package offsetrange defines a restriction and restriction tracker for offset ranges.
|
Package offsetrange defines a restriction and restriction tracker for offset ranges. |
|
Package synthetic contains transforms for creating synthetic pipelines.
|
Package synthetic contains transforms for creating synthetic pipelines. |
|
Package textio contains transforms for reading and writing text files.
|
Package textio contains transforms for reading and writing text files. |
|
xlang
|
|
|
kafkaio
Package kafkaio contains cross-language functionality for using Apache Kafka (http://kafka.apache.org/).
|
Package kafkaio contains cross-language functionality for using Apache Kafka (http://kafka.apache.org/). |
Click to show internal directories.
Click to hide internal directories.