apache_beam.io package

A package defining several input sources and output sinks.

Subpackages

• apache_beam.io.gcp package
  • Subpackages
    • apache_beam.io.gcp.datastore package
      • Subpackages
        • apache_beam.io.gcp.datastore.v1 package
          • Submodules
            • apache_beam.io.gcp.datastore.v1.adaptive_throttler module
            • apache_beam.io.gcp.datastore.v1.datastoreio module
            • apache_beam.io.gcp.datastore.v1.fake_datastore module
            • apache_beam.io.gcp.datastore.v1.helper module
            • apache_beam.io.gcp.datastore.v1.query_splitter module
            • apache_beam.io.gcp.datastore.v1.util module
  • Submodules
    • apache_beam.io.gcp.bigquery module
    • apache_beam.io.gcp.gcsfilesystem module
    • apache_beam.io.gcp.gcsio module
    • apache_beam.io.gcp.pubsub module

Submodules

• apache_beam.io.avroio module
• apache_beam.io.concat_source module
• apache_beam.io.filebasedsink module
• apache_beam.io.filebasedsource module
• apache_beam.io.filesystem module
• apache_beam.io.filesystems module
• apache_beam.io.iobase module
• apache_beam.io.localfilesystem module
• apache_beam.io.range_trackers module
• apache_beam.io.source_test_utils module
• apache_beam.io.textio module
• apache_beam.io.tfrecordio module