| |
| |
| <!DOCTYPE html> |
| <html class="writer-html5" lang="en" data-content_root="./"> |
| <head> |
| <meta charset="utf-8" /><meta name="viewport" content="width=device-width, initial-scale=1" /> |
| |
| <meta name="viewport" content="width=device-width, initial-scale=1.0" /> |
| <title>apache_beam.io package — Apache Beam 2.68.0 documentation</title> |
| <link rel="stylesheet" type="text/css" href="_static/pygments.css?v=b86133f3" /> |
| <link rel="stylesheet" type="text/css" href="_static/css/theme.css?v=e59714d7" /> |
| |
| |
| <script src="_static/jquery.js?v=5d32c60e"></script> |
| <script src="_static/_sphinx_javascript_frameworks_compat.js?v=2cd50e6c"></script> |
| <script src="_static/documentation_options.js?v=2388e03a"></script> |
| <script src="_static/doctools.js?v=9a2dae69"></script> |
| <script src="_static/sphinx_highlight.js?v=dc90522c"></script> |
| <script src="_static/js/theme.js"></script> |
| <link rel="index" title="Index" href="genindex.html" /> |
| <link rel="search" title="Search" href="search.html" /> |
| <link rel="next" title="apache_beam.io.aws package" href="apache_beam.io.aws.html" /> |
| <link rel="prev" title="apache_beam.dataframe.transforms module" href="apache_beam.dataframe.transforms.html" /> |
| </head> |
| |
| <body class="wy-body-for-nav"> |
| <div class="wy-grid-for-nav"> |
| <nav data-toggle="wy-nav-shift" class="wy-nav-side"> |
| <div class="wy-side-scroll"> |
| <div class="wy-side-nav-search" > |
| |
| |
| |
| <a href="index.html" class="icon icon-home"> |
| Apache Beam |
| </a> |
| <div role="search"> |
| <form id="rtd-search-form" class="wy-form" action="search.html" method="get"> |
| <input type="text" name="q" placeholder="Search docs" aria-label="Search docs" /> |
| <input type="hidden" name="check_keywords" value="yes" /> |
| <input type="hidden" name="area" value="default" /> |
| </form> |
| </div> |
| </div><div class="wy-menu wy-menu-vertical" data-spy="affix" role="navigation" aria-label="Navigation menu"> |
| <ul class="current"> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.coders.html">apache_beam.coders package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.dataframe.html">apache_beam.dataframe package</a></li> |
| <li class="toctree-l1 current"><a class="current reference internal" href="#">apache_beam.io package</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="#subpackages">Subpackages</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.aws.html">apache_beam.io.aws package</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.azure.html">apache_beam.io.azure package</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.components.html">apache_beam.io.components package</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.external.html">apache_beam.io.external package</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.flink.html">apache_beam.io.flink package</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.html">apache_beam.io.gcp package</a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="#submodules">Submodules</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html">apache_beam.io.avroio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html">apache_beam.io.concat_source module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.debezium.html">apache_beam.io.debezium module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html">apache_beam.io.filebasedsink module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html">apache_beam.io.filebasedsource module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html">apache_beam.io.fileio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html">apache_beam.io.filesystem module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html">apache_beam.io.filesystemio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html">apache_beam.io.filesystems module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html">apache_beam.io.hadoopfilesystem module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html">apache_beam.io.iobase module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.jdbc.html">apache_beam.io.jdbc module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html">apache_beam.io.kafka module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html">apache_beam.io.kinesis module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html">apache_beam.io.localfilesystem module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.mongodbio.html">apache_beam.io.mongodbio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html">apache_beam.io.parquetio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html">apache_beam.io.range_trackers module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html">apache_beam.io.requestresponse module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html">apache_beam.io.restriction_trackers module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html">apache_beam.io.snowflake module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.source_test_utils.html">apache_beam.io.source_test_utils module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.textio.html">apache_beam.io.textio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.tfrecordio.html">apache_beam.io.tfrecordio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.utils.html">apache_beam.io.utils module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html">apache_beam.io.watermark_estimators module</a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.metrics.html">apache_beam.metrics package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.ml.html">apache_beam.ml package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.options.html">apache_beam.options package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.portability.html">apache_beam.portability package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.runners.html">apache_beam.runners package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.testing.html">apache_beam.testing package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.transforms.html">apache_beam.transforms package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.typehints.html">apache_beam.typehints package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.utils.html">apache_beam.utils package</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.yaml.html">apache_beam.yaml package</a></li> |
| </ul> |
| <ul> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.error.html">apache_beam.error module</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.pipeline.html">apache_beam.pipeline module</a></li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.pvalue.html">apache_beam.pvalue module</a></li> |
| </ul> |
| |
| </div> |
| </div> |
| </nav> |
| |
| <section data-toggle="wy-nav-shift" class="wy-nav-content-wrap"><nav class="wy-nav-top" aria-label="Mobile navigation menu" > |
| <i data-toggle="wy-nav-top" class="fa fa-bars"></i> |
| <a href="index.html">Apache Beam</a> |
| </nav> |
| |
| <div class="wy-nav-content"> |
| <div class="rst-content"> |
| <div role="navigation" aria-label="Page navigation"> |
| <ul class="wy-breadcrumbs"> |
| <li><a href="index.html" class="icon icon-home" aria-label="Home"></a></li> |
| <li class="breadcrumb-item active">apache_beam.io package</li> |
| <li class="wy-breadcrumbs-aside"> |
| <a href="_sources/apache_beam.io.rst.txt" rel="nofollow"> View page source</a> |
| </li> |
| </ul> |
| <hr/> |
| </div> |
| <div role="main" class="document" itemscope="itemscope" itemtype="http://schema.org/Article"> |
| <div itemprop="articleBody"> |
| |
| <section id="module-apache_beam.io"> |
| <span id="apache-beam-io-package"></span><h1>apache_beam.io package<a class="headerlink" href="#module-apache_beam.io" title="Link to this heading"></a></h1> |
| <p>A package defining several input sources and output sinks.</p> |
| <section id="subpackages"> |
| <h2>Subpackages<a class="headerlink" href="#subpackages" title="Link to this heading"></a></h2> |
| <div class="toctree-wrapper compound"> |
| <ul> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.aws.html">apache_beam.io.aws package</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.aws.html#subpackages">Subpackages</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.aws.clients.html">apache_beam.io.aws.clients package</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.aws.clients.html#subpackages">Subpackages</a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.aws.html#submodules">Submodules</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.aws.s3filesystem.html">apache_beam.io.aws.s3filesystem module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.aws.s3filesystem.html#apache_beam.io.aws.s3filesystem.S3FileSystem"><code class="docutils literal notranslate"><span class="pre">S3FileSystem</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.aws.s3io.html">apache_beam.io.aws.s3io module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.aws.s3io.html#apache_beam.io.aws.s3io.parse_s3_path"><code class="docutils literal notranslate"><span class="pre">parse_s3_path()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.aws.s3io.html#apache_beam.io.aws.s3io.S3IO"><code class="docutils literal notranslate"><span class="pre">S3IO</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.aws.s3io.html#apache_beam.io.aws.s3io.S3Downloader"><code class="docutils literal notranslate"><span class="pre">S3Downloader</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.aws.s3io.html#apache_beam.io.aws.s3io.S3Uploader"><code class="docutils literal notranslate"><span class="pre">S3Uploader</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.azure.html">apache_beam.io.azure package</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.azure.html#submodules">Submodules</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.azure.blobstoragefilesystem.html">apache_beam.io.azure.blobstoragefilesystem module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstoragefilesystem.html#apache_beam.io.azure.blobstoragefilesystem.BlobStorageFileSystem"><code class="docutils literal notranslate"><span class="pre">BlobStorageFileSystem</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html">apache_beam.io.azure.blobstorageio module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.parse_azfs_path"><code class="docutils literal notranslate"><span class="pre">parse_azfs_path()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.get_azfs_url"><code class="docutils literal notranslate"><span class="pre">get_azfs_url()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.Blob"><code class="docutils literal notranslate"><span class="pre">Blob</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.BlobStorageIOError"><code class="docutils literal notranslate"><span class="pre">BlobStorageIOError</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.BlobStorageError"><code class="docutils literal notranslate"><span class="pre">BlobStorageError</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.BlobStorageIO"><code class="docutils literal notranslate"><span class="pre">BlobStorageIO</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.BlobStorageDownloader"><code class="docutils literal notranslate"><span class="pre">BlobStorageDownloader</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.azure.blobstorageio.html#apache_beam.io.azure.blobstorageio.BlobStorageUploader"><code class="docutils literal notranslate"><span class="pre">BlobStorageUploader</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.components.html">apache_beam.io.components package</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.components.html#submodules">Submodules</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.components.adaptive_throttler.html">apache_beam.io.components.adaptive_throttler module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.components.adaptive_throttler.html#apache_beam.io.components.adaptive_throttler.ThrottlingSignaler"><code class="docutils literal notranslate"><span class="pre">ThrottlingSignaler</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.components.adaptive_throttler.html#apache_beam.io.components.adaptive_throttler.AdaptiveThrottler"><code class="docutils literal notranslate"><span class="pre">AdaptiveThrottler</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.components.adaptive_throttler.html#apache_beam.io.components.adaptive_throttler.ReactiveThrottler"><code class="docutils literal notranslate"><span class="pre">ReactiveThrottler</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.components.util.html">apache_beam.io.components.util module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.components.util.html#apache_beam.io.components.util.MovingSum"><code class="docutils literal notranslate"><span class="pre">MovingSum</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.external.html">apache_beam.io.external package</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.external.html#subpackages">Subpackages</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.external.gcp.html">apache_beam.io.external.gcp package</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.external.gcp.html#submodules">Submodules</a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.external.html#submodules">Submodules</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.external.generate_sequence.html">apache_beam.io.external.generate_sequence module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.external.generate_sequence.html#apache_beam.io.external.generate_sequence.GenerateSequence"><code class="docutils literal notranslate"><span class="pre">GenerateSequence</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.external.kafka.html">apache_beam.io.external.kafka module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.external.snowflake.html">apache_beam.io.external.snowflake module</a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.flink.html">apache_beam.io.flink package</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.flink.html#submodules">Submodules</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.flink.flink_streaming_impulse_source.html">apache_beam.io.flink.flink_streaming_impulse_source module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.flink.flink_streaming_impulse_source.html#apache_beam.io.flink.flink_streaming_impulse_source.FlinkStreamingImpulseSource"><code class="docutils literal notranslate"><span class="pre">FlinkStreamingImpulseSource</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.gcp.html">apache_beam.io.gcp package</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.gcp.html#subpackages">Subpackages</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.datastore.html">apache_beam.io.gcp.datastore package</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.datastore.html#subpackages">Subpackages</a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.experimental.html">apache_beam.io.gcp.experimental package</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.experimental.html#submodules">Submodules</a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.healthcare.html">apache_beam.io.gcp.healthcare package</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.healthcare.html#submodules">Submodules</a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.pubsublite.html">apache_beam.io.gcp.pubsublite package</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsublite.html#apache_beam.io.gcp.pubsublite.ReadFromPubSubLite"><code class="docutils literal notranslate"><span class="pre">ReadFromPubSubLite</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsublite.html#apache_beam.io.gcp.pubsublite.WriteToPubSubLite"><code class="docutils literal notranslate"><span class="pre">WriteToPubSubLite</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsublite.html#submodules">Submodules</a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.gcp.html#submodules">Submodules</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.big_query_query_to_table_pipeline.html">apache_beam.io.gcp.big_query_query_to_table_pipeline module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.big_query_query_to_table_pipeline.html#apache_beam.io.gcp.big_query_query_to_table_pipeline.run_bq_pipeline"><code class="docutils literal notranslate"><span class="pre">run_bq_pipeline()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html">apache_beam.io.gcp.bigquery module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#readallfrombigquery">ReadAllFromBigQuery</a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#table-references">Table References</a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#schemas">Schemas</a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#additional-parameters-for-bigquery-tables">Additional Parameters for BigQuery Tables</a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#chaining-of-operations-after-writetobigquery">Chaining of operations after WriteToBigQuery</a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#writing-with-storage-write-api-using-cross-language">Writing with Storage Write API using Cross Language</a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.TableRowJsonCoder"><code class="docutils literal notranslate"><span class="pre">TableRowJsonCoder</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.BigQueryDisposition"><code class="docutils literal notranslate"><span class="pre">BigQueryDisposition</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.BigQuerySource"><code class="docutils literal notranslate"><span class="pre">BigQuerySource()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.BigQuerySink"><code class="docutils literal notranslate"><span class="pre">BigQuerySink()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.BigQueryQueryPriority"><code class="docutils literal notranslate"><span class="pre">BigQueryQueryPriority</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.WriteToBigQuery"><code class="docutils literal notranslate"><span class="pre">WriteToBigQuery</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.WriteResult"><code class="docutils literal notranslate"><span class="pre">WriteResult</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.ReadFromBigQuery"><code class="docutils literal notranslate"><span class="pre">ReadFromBigQuery</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.ReadFromBigQueryRequest"><code class="docutils literal notranslate"><span class="pre">ReadFromBigQueryRequest</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery.html#apache_beam.io.gcp.bigquery.ReadAllFromBigQuery"><code class="docutils literal notranslate"><span class="pre">ReadAllFromBigQuery</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery_avro_tools.html">apache_beam.io.gcp.bigquery_avro_tools module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_avro_tools.html#apache_beam.io.gcp.bigquery_avro_tools.get_record_schema_from_dict_table_schema"><code class="docutils literal notranslate"><span class="pre">get_record_schema_from_dict_table_schema()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_avro_tools.html#apache_beam.io.gcp.bigquery_avro_tools.table_field_to_avro_field"><code class="docutils literal notranslate"><span class="pre">table_field_to_avro_field()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html">apache_beam.io.gcp.bigquery_file_loads module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.file_prefix_generator"><code class="docutils literal notranslate"><span class="pre">file_prefix_generator()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.WriteRecordsToFile"><code class="docutils literal notranslate"><span class="pre">WriteRecordsToFile</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.WriteGroupedRecordsToFile"><code class="docutils literal notranslate"><span class="pre">WriteGroupedRecordsToFile</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.UpdateDestinationSchema"><code class="docutils literal notranslate"><span class="pre">UpdateDestinationSchema</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.TriggerCopyJobs"><code class="docutils literal notranslate"><span class="pre">TriggerCopyJobs</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.TriggerLoadJobs"><code class="docutils literal notranslate"><span class="pre">TriggerLoadJobs</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.PartitionFiles"><code class="docutils literal notranslate"><span class="pre">PartitionFiles</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.DeleteTablesFn"><code class="docutils literal notranslate"><span class="pre">DeleteTablesFn</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_file_loads.html#apache_beam.io.gcp.bigquery_file_loads.BigQueryBatchFileLoads"><code class="docutils literal notranslate"><span class="pre">BigQueryBatchFileLoads</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery_io_metadata.html">apache_beam.io.gcp.bigquery_io_metadata module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_io_metadata.html#apache_beam.io.gcp.bigquery_io_metadata.create_bigquery_io_metadata"><code class="docutils literal notranslate"><span class="pre">create_bigquery_io_metadata()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_io_metadata.html#apache_beam.io.gcp.bigquery_io_metadata.BigQueryIOMetadata"><code class="docutils literal notranslate"><span class="pre">BigQueryIOMetadata</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery_io_read_pipeline.html">apache_beam.io.gcp.bigquery_io_read_pipeline module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_io_read_pipeline.html#apache_beam.io.gcp.bigquery_io_read_pipeline.RowToStringWithSlowDown"><code class="docutils literal notranslate"><span class="pre">RowToStringWithSlowDown</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_io_read_pipeline.html#apache_beam.io.gcp.bigquery_io_read_pipeline.run"><code class="docutils literal notranslate"><span class="pre">run()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery_read_internal.html">apache_beam.io.gcp.bigquery_read_internal module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_read_internal.html#apache_beam.io.gcp.bigquery_read_internal.bigquery_export_destination_uri"><code class="docutils literal notranslate"><span class="pre">bigquery_export_destination_uri()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_read_internal.html#apache_beam.io.gcp.bigquery_read_internal.FieldSchema"><code class="docutils literal notranslate"><span class="pre">FieldSchema</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery_schema_tools.html">apache_beam.io.gcp.bigquery_schema_tools module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_schema_tools.html#apache_beam.io.gcp.bigquery_schema_tools.generate_user_type_from_bq_schema"><code class="docutils literal notranslate"><span class="pre">generate_user_type_from_bq_schema()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_schema_tools.html#apache_beam.io.gcp.bigquery_schema_tools.bq_field_to_type"><code class="docutils literal notranslate"><span class="pre">bq_field_to_type()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_schema_tools.html#apache_beam.io.gcp.bigquery_schema_tools.convert_to_usertype"><code class="docutils literal notranslate"><span class="pre">convert_to_usertype()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_schema_tools.html#apache_beam.io.gcp.bigquery_schema_tools.BeamSchemaConversionDoFn"><code class="docutils literal notranslate"><span class="pre">BeamSchemaConversionDoFn</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html">apache_beam.io.gcp.bigquery_tools module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.FileFormat"><code class="docutils literal notranslate"><span class="pre">FileFormat</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.ExportCompression"><code class="docutils literal notranslate"><span class="pre">ExportCompression</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.default_encoder"><code class="docutils literal notranslate"><span class="pre">default_encoder()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.get_hashable_destination"><code class="docutils literal notranslate"><span class="pre">get_hashable_destination()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.to_hashable_table_ref"><code class="docutils literal notranslate"><span class="pre">to_hashable_table_ref()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.parse_table_schema_from_json"><code class="docutils literal notranslate"><span class="pre">parse_table_schema_from_json()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.parse_table_reference"><code class="docutils literal notranslate"><span class="pre">parse_table_reference()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.BigQueryWrapper"><code class="docutils literal notranslate"><span class="pre">BigQueryWrapper</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.RowAsDictJsonCoder"><code class="docutils literal notranslate"><span class="pre">RowAsDictJsonCoder</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.JsonRowWriter"><code class="docutils literal notranslate"><span class="pre">JsonRowWriter</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.AvroRowWriter"><code class="docutils literal notranslate"><span class="pre">AvroRowWriter</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.RetryStrategy"><code class="docutils literal notranslate"><span class="pre">RetryStrategy</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.AppendDestinationsFn"><code class="docutils literal notranslate"><span class="pre">AppendDestinationsFn</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.beam_row_from_dict"><code class="docutils literal notranslate"><span class="pre">beam_row_from_dict()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.get_table_schema_from_string"><code class="docutils literal notranslate"><span class="pre">get_table_schema_from_string()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.table_schema_to_dict"><code class="docutils literal notranslate"><span class="pre">table_schema_to_dict()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.get_dict_table_schema"><code class="docutils literal notranslate"><span class="pre">get_dict_table_schema()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.get_bq_tableschema"><code class="docutils literal notranslate"><span class="pre">get_bq_tableschema()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.get_avro_schema_from_table_schema"><code class="docutils literal notranslate"><span class="pre">get_avro_schema_from_table_schema()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.get_beam_typehints_from_tableschema"><code class="docutils literal notranslate"><span class="pre">get_beam_typehints_from_tableschema()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.BigQueryJobTypes"><code class="docutils literal notranslate"><span class="pre">BigQueryJobTypes</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.generate_bq_job_name"><code class="docutils literal notranslate"><span class="pre">generate_bq_job_name()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigquery_tools.html#apache_beam.io.gcp.bigquery_tools.check_schema_equal"><code class="docutils literal notranslate"><span class="pre">check_schema_equal()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.bigtableio.html">apache_beam.io.gcp.bigtableio module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigtableio.html#apache_beam.io.gcp.bigtableio.WriteToBigTable"><code class="docutils literal notranslate"><span class="pre">WriteToBigTable</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.bigtableio.html#apache_beam.io.gcp.bigtableio.ReadFromBigtable"><code class="docutils literal notranslate"><span class="pre">ReadFromBigtable</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.dicomclient.html">apache_beam.io.gcp.dicomclient module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.dicomio.html">apache_beam.io.gcp.dicomio module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.gce_metadata_util.html">apache_beam.io.gcp.gce_metadata_util module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.gce_metadata_util.html#apache_beam.io.gcp.gce_metadata_util.fetch_dataflow_job_id"><code class="docutils literal notranslate"><span class="pre">fetch_dataflow_job_id()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.gcsfilesystem.html">apache_beam.io.gcp.gcsfilesystem module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.gcsfilesystem.html#apache_beam.io.gcp.gcsfilesystem.GCSFileSystem"><code class="docutils literal notranslate"><span class="pre">GCSFileSystem</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.gcsio.html">apache_beam.io.gcp.gcsio module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.gcsio.html#apache_beam.io.gcp.gcsio.GcsIO"><code class="docutils literal notranslate"><span class="pre">GcsIO</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.gcsio.html#apache_beam.io.gcp.gcsio.create_storage_client"><code class="docutils literal notranslate"><span class="pre">create_storage_client()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.gcsio_retry.html">apache_beam.io.gcp.gcsio_retry module</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html">apache_beam.io.gcp.pubsub module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html#apache_beam.io.gcp.pubsub.MultipleReadFromPubSub"><code class="docutils literal notranslate"><span class="pre">MultipleReadFromPubSub</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html#apache_beam.io.gcp.pubsub.PubsubMessage"><code class="docutils literal notranslate"><span class="pre">PubsubMessage</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html#apache_beam.io.gcp.pubsub.PubSubSourceDescriptor"><code class="docutils literal notranslate"><span class="pre">PubSubSourceDescriptor</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html#apache_beam.io.gcp.pubsub.ReadFromPubSub"><code class="docutils literal notranslate"><span class="pre">ReadFromPubSub</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html#apache_beam.io.gcp.pubsub.ReadStringsFromPubSub"><code class="docutils literal notranslate"><span class="pre">ReadStringsFromPubSub()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html#apache_beam.io.gcp.pubsub.WriteStringsToPubSub"><code class="docutils literal notranslate"><span class="pre">WriteStringsToPubSub()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub.html#apache_beam.io.gcp.pubsub.WriteToPubSub"><code class="docutils literal notranslate"><span class="pre">WriteToPubSub</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.pubsub_it_pipeline.html">apache_beam.io.gcp.pubsub_it_pipeline module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.pubsub_it_pipeline.html#apache_beam.io.gcp.pubsub_it_pipeline.run_pipeline"><code class="docutils literal notranslate"><span class="pre">run_pipeline()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.resource_identifiers.html">apache_beam.io.gcp.resource_identifiers module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.resource_identifiers.html#apache_beam.io.gcp.resource_identifiers.BigQueryTable"><code class="docutils literal notranslate"><span class="pre">BigQueryTable()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.resource_identifiers.html#apache_beam.io.gcp.resource_identifiers.GoogleCloudStorageBucket"><code class="docutils literal notranslate"><span class="pre">GoogleCloudStorageBucket()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.resource_identifiers.html#apache_beam.io.gcp.resource_identifiers.DatastoreNamespace"><code class="docutils literal notranslate"><span class="pre">DatastoreNamespace()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.resource_identifiers.html#apache_beam.io.gcp.resource_identifiers.SpannerTable"><code class="docutils literal notranslate"><span class="pre">SpannerTable()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.resource_identifiers.html#apache_beam.io.gcp.resource_identifiers.SpannerSqlQuery"><code class="docutils literal notranslate"><span class="pre">SpannerSqlQuery()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.resource_identifiers.html#apache_beam.io.gcp.resource_identifiers.BigtableTable"><code class="docutils literal notranslate"><span class="pre">BigtableTable()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.spanner.html">apache_beam.io.gcp.spanner module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.ReadFromSpanner"><code class="docutils literal notranslate"><span class="pre">ReadFromSpanner</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.SpannerDelete"><code class="docutils literal notranslate"><span class="pre">SpannerDelete</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.SpannerInsert"><code class="docutils literal notranslate"><span class="pre">SpannerInsert</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.SpannerInsertOrUpdate"><code class="docutils literal notranslate"><span class="pre">SpannerInsertOrUpdate</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.SpannerReplace"><code class="docutils literal notranslate"><span class="pre">SpannerReplace</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.SpannerUpdate"><code class="docutils literal notranslate"><span class="pre">SpannerUpdate</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.TimestampBoundMode"><code class="docutils literal notranslate"><span class="pre">TimestampBoundMode</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner.html#apache_beam.io.gcp.spanner.TimeUnit"><code class="docutils literal notranslate"><span class="pre">TimeUnit</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.gcp.spanner_wrapper.html">apache_beam.io.gcp.spanner_wrapper module</a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.gcp.spanner_wrapper.html#apache_beam.io.gcp.spanner_wrapper.SpannerWrapper"><code class="docutils literal notranslate"><span class="pre">SpannerWrapper</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </div> |
| </section> |
| <section id="submodules"> |
| <h2>Submodules<a class="headerlink" href="#submodules" title="Link to this heading"></a></h2> |
| <div class="toctree-wrapper compound"> |
| <ul> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.avroio.html">apache_beam.io.avroio module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadFromAvro"><code class="docutils literal notranslate"><span class="pre">ReadFromAvro</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadFromAvro.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromAvro.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadFromAvro.display_data"><code class="docutils literal notranslate"><span class="pre">ReadFromAvro.display_data()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadAllFromAvro"><code class="docutils literal notranslate"><span class="pre">ReadAllFromAvro</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadAllFromAvro.DEFAULT_DESIRED_BUNDLE_SIZE"><code class="docutils literal notranslate"><span class="pre">ReadAllFromAvro.DEFAULT_DESIRED_BUNDLE_SIZE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadAllFromAvro.expand"><code class="docutils literal notranslate"><span class="pre">ReadAllFromAvro.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadAllFromAvroContinuously"><code class="docutils literal notranslate"><span class="pre">ReadAllFromAvroContinuously</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.ReadAllFromAvroContinuously.expand"><code class="docutils literal notranslate"><span class="pre">ReadAllFromAvroContinuously.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.WriteToAvro"><code class="docutils literal notranslate"><span class="pre">WriteToAvro</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.WriteToAvro.expand"><code class="docutils literal notranslate"><span class="pre">WriteToAvro.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.avroio.html#apache_beam.io.avroio.WriteToAvro.display_data"><code class="docutils literal notranslate"><span class="pre">WriteToAvro.display_data()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.concat_source.html">apache_beam.io.concat_source module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatSource"><code class="docutils literal notranslate"><span class="pre">ConcatSource</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatSource.sources"><code class="docutils literal notranslate"><span class="pre">ConcatSource.sources</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatSource.estimate_size"><code class="docutils literal notranslate"><span class="pre">ConcatSource.estimate_size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatSource.split"><code class="docutils literal notranslate"><span class="pre">ConcatSource.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatSource.get_range_tracker"><code class="docutils literal notranslate"><span class="pre">ConcatSource.get_range_tracker()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatSource.read"><code class="docutils literal notranslate"><span class="pre">ConcatSource.read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatSource.default_output_coder"><code class="docutils literal notranslate"><span class="pre">ConcatSource.default_output_coder()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.start_position"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.start_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.stop_position"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.stop_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.try_claim"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.try_claim()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.try_split"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.try_split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.set_current_position"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.set_current_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.position_at_fraction"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.position_at_fraction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.fraction_consumed"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.fraction_consumed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.local_to_global"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.local_to_global()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.global_to_local"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.global_to_local()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.concat_source.html#apache_beam.io.concat_source.ConcatRangeTracker.sub_range_tracker"><code class="docutils literal notranslate"><span class="pre">ConcatRangeTracker.sub_range_tracker()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.debezium.html">apache_beam.io.debezium module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.ReadFromDebezium"><code class="docutils literal notranslate"><span class="pre">ReadFromDebezium</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.ReadFromDebezium.URN"><code class="docutils literal notranslate"><span class="pre">ReadFromDebezium.URN</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.ReadFromDebezium.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromDebezium.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.DriverClassName"><code class="docutils literal notranslate"><span class="pre">DriverClassName</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.DriverClassName.MYSQL"><code class="docutils literal notranslate"><span class="pre">DriverClassName.MYSQL</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.DriverClassName.POSTGRESQL"><code class="docutils literal notranslate"><span class="pre">DriverClassName.POSTGRESQL</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.DriverClassName.ORACLE"><code class="docutils literal notranslate"><span class="pre">DriverClassName.ORACLE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.debezium.html#apache_beam.io.debezium.DriverClassName.DB2"><code class="docutils literal notranslate"><span class="pre">DriverClassName.DB2</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.filebasedsink.html">apache_beam.io.filebasedsink module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink"><code class="docutils literal notranslate"><span class="pre">FileBasedSink</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.display_data"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.display_data()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.open"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.open()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.write_record"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.write_record()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.write_encoded_record"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.write_encoded_record()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.close"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.close()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.initialize_write"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.initialize_write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.open_writer"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.open_writer()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.pre_finalize"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.pre_finalize()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.pre_finalize_windowed"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.pre_finalize_windowed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.finalize_write"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.finalize_write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsink.html#apache_beam.io.filebasedsink.FileBasedSink.finalize_windowed_write"><code class="docutils literal notranslate"><span class="pre">FileBasedSink.finalize_windowed_write()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.filebasedsource.html">apache_beam.io.filebasedsource module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource"><code class="docutils literal notranslate"><span class="pre">FileBasedSource</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.MIN_NUMBER_OF_FILES_TO_STAT"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.MIN_NUMBER_OF_FILES_TO_STAT</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.MIN_FRACTION_OF_FILES_TO_STAT"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.MIN_FRACTION_OF_FILES_TO_STAT</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.display_data"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.display_data()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.open_file"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.open_file()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.split"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.estimate_size"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.estimate_size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.read"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.get_range_tracker"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.get_range_tracker()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.read_records"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.read_records()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filebasedsource.html#apache_beam.io.filebasedsource.FileBasedSource.splittable"><code class="docutils literal notranslate"><span class="pre">FileBasedSource.splittable</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.fileio.html">apache_beam.io.fileio module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#writing-to-files">Writing to Files</a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#file-naming">File Naming</a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#dynamic-destinations">Dynamic Destinations</a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.EmptyMatchTreatment"><code class="docutils literal notranslate"><span class="pre">EmptyMatchTreatment</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.EmptyMatchTreatment.ALLOW"><code class="docutils literal notranslate"><span class="pre">EmptyMatchTreatment.ALLOW</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.EmptyMatchTreatment.DISALLOW"><code class="docutils literal notranslate"><span class="pre">EmptyMatchTreatment.DISALLOW</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.EmptyMatchTreatment.ALLOW_IF_WILDCARD"><code class="docutils literal notranslate"><span class="pre">EmptyMatchTreatment.ALLOW_IF_WILDCARD</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.EmptyMatchTreatment.allow_empty_match"><code class="docutils literal notranslate"><span class="pre">EmptyMatchTreatment.allow_empty_match()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.MatchFiles"><code class="docutils literal notranslate"><span class="pre">MatchFiles</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.MatchFiles.expand"><code class="docutils literal notranslate"><span class="pre">MatchFiles.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.MatchAll"><code class="docutils literal notranslate"><span class="pre">MatchAll</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.MatchAll.expand"><code class="docutils literal notranslate"><span class="pre">MatchAll.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.MatchContinuously"><code class="docutils literal notranslate"><span class="pre">MatchContinuously</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.MatchContinuously.expand"><code class="docutils literal notranslate"><span class="pre">MatchContinuously.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.ReadableFile"><code class="docutils literal notranslate"><span class="pre">ReadableFile</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.ReadableFile.open"><code class="docutils literal notranslate"><span class="pre">ReadableFile.open()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.ReadableFile.read"><code class="docutils literal notranslate"><span class="pre">ReadableFile.read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.ReadableFile.read_utf8"><code class="docutils literal notranslate"><span class="pre">ReadableFile.read_utf8()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.ReadMatches"><code class="docutils literal notranslate"><span class="pre">ReadMatches</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.ReadMatches.expand"><code class="docutils literal notranslate"><span class="pre">ReadMatches.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.WriteToFiles"><code class="docutils literal notranslate"><span class="pre">WriteToFiles</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.WriteToFiles.MAX_NUM_WRITERS_PER_BUNDLE"><code class="docutils literal notranslate"><span class="pre">WriteToFiles.MAX_NUM_WRITERS_PER_BUNDLE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.WriteToFiles.DEFAULT_SHARDING"><code class="docutils literal notranslate"><span class="pre">WriteToFiles.DEFAULT_SHARDING</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.fileio.html#apache_beam.io.fileio.WriteToFiles.expand"><code class="docutils literal notranslate"><span class="pre">WriteToFiles.expand()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.filesystem.html">apache_beam.io.filesystem module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes"><code class="docutils literal notranslate"><span class="pre">CompressionTypes</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.AUTO"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.AUTO</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.BZIP2"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.BZIP2</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.DEFLATE"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.DEFLATE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.ZSTD"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.ZSTD</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.GZIP"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.GZIP</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.LZMA"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.LZMA</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.UNCOMPRESSED"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.UNCOMPRESSED</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.is_valid_compression_type"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.is_valid_compression_type()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.mime_type"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.mime_type()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressionTypes.detect_compression_type"><code class="docutils literal notranslate"><span class="pre">CompressionTypes.detect_compression_type()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile"><code class="docutils literal notranslate"><span class="pre">CompressedFile</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.readable"><code class="docutils literal notranslate"><span class="pre">CompressedFile.readable()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.writeable"><code class="docutils literal notranslate"><span class="pre">CompressedFile.writeable()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.write"><code class="docutils literal notranslate"><span class="pre">CompressedFile.write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.read"><code class="docutils literal notranslate"><span class="pre">CompressedFile.read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.readline"><code class="docutils literal notranslate"><span class="pre">CompressedFile.readline()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.closed"><code class="docutils literal notranslate"><span class="pre">CompressedFile.closed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.close"><code class="docutils literal notranslate"><span class="pre">CompressedFile.close()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.flush"><code class="docutils literal notranslate"><span class="pre">CompressedFile.flush()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.seekable"><code class="docutils literal notranslate"><span class="pre">CompressedFile.seekable</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.seek"><code class="docutils literal notranslate"><span class="pre">CompressedFile.seek()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.CompressedFile.tell"><code class="docutils literal notranslate"><span class="pre">CompressedFile.tell()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileMetadata"><code class="docutils literal notranslate"><span class="pre">FileMetadata</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem"><code class="docutils literal notranslate"><span class="pre">FileSystem</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.CHUNK_SIZE"><code class="docutils literal notranslate"><span class="pre">FileSystem.CHUNK_SIZE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.scheme"><code class="docutils literal notranslate"><span class="pre">FileSystem.scheme()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.join"><code class="docutils literal notranslate"><span class="pre">FileSystem.join()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.split"><code class="docutils literal notranslate"><span class="pre">FileSystem.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.mkdirs"><code class="docutils literal notranslate"><span class="pre">FileSystem.mkdirs()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.has_dirs"><code class="docutils literal notranslate"><span class="pre">FileSystem.has_dirs()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.match_files"><code class="docutils literal notranslate"><span class="pre">FileSystem.match_files()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.translate_pattern"><code class="docutils literal notranslate"><span class="pre">FileSystem.translate_pattern()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.match"><code class="docutils literal notranslate"><span class="pre">FileSystem.match()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.create"><code class="docutils literal notranslate"><span class="pre">FileSystem.create()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.open"><code class="docutils literal notranslate"><span class="pre">FileSystem.open()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.copy"><code class="docutils literal notranslate"><span class="pre">FileSystem.copy()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.rename"><code class="docutils literal notranslate"><span class="pre">FileSystem.rename()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.exists"><code class="docutils literal notranslate"><span class="pre">FileSystem.exists()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.size"><code class="docutils literal notranslate"><span class="pre">FileSystem.size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.last_updated"><code class="docutils literal notranslate"><span class="pre">FileSystem.last_updated()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.checksum"><code class="docutils literal notranslate"><span class="pre">FileSystem.checksum()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.metadata"><code class="docutils literal notranslate"><span class="pre">FileSystem.metadata()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.delete"><code class="docutils literal notranslate"><span class="pre">FileSystem.delete()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.FileSystem.report_lineage"><code class="docutils literal notranslate"><span class="pre">FileSystem.report_lineage()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystem.html#apache_beam.io.filesystem.MatchResult"><code class="docutils literal notranslate"><span class="pre">MatchResult</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.filesystemio.html">apache_beam.io.filesystemio module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.Downloader"><code class="docutils literal notranslate"><span class="pre">Downloader</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.Downloader.size"><code class="docutils literal notranslate"><span class="pre">Downloader.size</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.Downloader.get_range"><code class="docutils literal notranslate"><span class="pre">Downloader.get_range()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.Uploader"><code class="docutils literal notranslate"><span class="pre">Uploader</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.Uploader.put"><code class="docutils literal notranslate"><span class="pre">Uploader.put()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.Uploader.finish"><code class="docutils literal notranslate"><span class="pre">Uploader.finish()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.DownloaderStream"><code class="docutils literal notranslate"><span class="pre">DownloaderStream</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.DownloaderStream.readinto"><code class="docutils literal notranslate"><span class="pre">DownloaderStream.readinto()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.DownloaderStream.seek"><code class="docutils literal notranslate"><span class="pre">DownloaderStream.seek()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.DownloaderStream.tell"><code class="docutils literal notranslate"><span class="pre">DownloaderStream.tell()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.DownloaderStream.seekable"><code class="docutils literal notranslate"><span class="pre">DownloaderStream.seekable()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.DownloaderStream.readable"><code class="docutils literal notranslate"><span class="pre">DownloaderStream.readable()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.DownloaderStream.readall"><code class="docutils literal notranslate"><span class="pre">DownloaderStream.readall()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.UploaderStream"><code class="docutils literal notranslate"><span class="pre">UploaderStream</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.UploaderStream.tell"><code class="docutils literal notranslate"><span class="pre">UploaderStream.tell()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.UploaderStream.write"><code class="docutils literal notranslate"><span class="pre">UploaderStream.write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.UploaderStream.close"><code class="docutils literal notranslate"><span class="pre">UploaderStream.close()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.UploaderStream.writable"><code class="docutils literal notranslate"><span class="pre">UploaderStream.writable()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.PipeStream"><code class="docutils literal notranslate"><span class="pre">PipeStream</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.PipeStream.read"><code class="docutils literal notranslate"><span class="pre">PipeStream.read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.PipeStream.tell"><code class="docutils literal notranslate"><span class="pre">PipeStream.tell()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystemio.html#apache_beam.io.filesystemio.PipeStream.seek"><code class="docutils literal notranslate"><span class="pre">PipeStream.seek()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.filesystems.html">apache_beam.io.filesystems module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems"><code class="docutils literal notranslate"><span class="pre">FileSystems</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.URI_SCHEMA_PATTERN"><code class="docutils literal notranslate"><span class="pre">FileSystems.URI_SCHEMA_PATTERN</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.set_options"><code class="docutils literal notranslate"><span class="pre">FileSystems.set_options()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.get_scheme"><code class="docutils literal notranslate"><span class="pre">FileSystems.get_scheme()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.get_filesystem"><code class="docutils literal notranslate"><span class="pre">FileSystems.get_filesystem()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.join"><code class="docutils literal notranslate"><span class="pre">FileSystems.join()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.split"><code class="docutils literal notranslate"><span class="pre">FileSystems.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.mkdirs"><code class="docutils literal notranslate"><span class="pre">FileSystems.mkdirs()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.match"><code class="docutils literal notranslate"><span class="pre">FileSystems.match()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.create"><code class="docutils literal notranslate"><span class="pre">FileSystems.create()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.open"><code class="docutils literal notranslate"><span class="pre">FileSystems.open()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.copy"><code class="docutils literal notranslate"><span class="pre">FileSystems.copy()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.rename"><code class="docutils literal notranslate"><span class="pre">FileSystems.rename()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.exists"><code class="docutils literal notranslate"><span class="pre">FileSystems.exists()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.last_updated"><code class="docutils literal notranslate"><span class="pre">FileSystems.last_updated()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.checksum"><code class="docutils literal notranslate"><span class="pre">FileSystems.checksum()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.delete"><code class="docutils literal notranslate"><span class="pre">FileSystems.delete()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.get_chunk_size"><code class="docutils literal notranslate"><span class="pre">FileSystems.get_chunk_size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.report_source_lineage"><code class="docutils literal notranslate"><span class="pre">FileSystems.report_source_lineage()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.filesystems.html#apache_beam.io.filesystems.FileSystems.report_sink_lineage"><code class="docutils literal notranslate"><span class="pre">FileSystems.report_sink_lineage()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html">apache_beam.io.hadoopfilesystem module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.scheme"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.scheme()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.join"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.join()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.split"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.mkdirs"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.mkdirs()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.has_dirs"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.has_dirs()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.create"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.create()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.open"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.open()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.copy"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.copy()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.rename"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.rename()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.exists"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.exists()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.size"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.last_updated"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.last_updated()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.checksum"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.checksum()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.metadata"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.metadata()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.hadoopfilesystem.html#apache_beam.io.hadoopfilesystem.HadoopFileSystem.delete"><code class="docutils literal notranslate"><span class="pre">HadoopFileSystem.delete()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.iobase.html">apache_beam.io.iobase module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.BoundedSource"><code class="docutils literal notranslate"><span class="pre">BoundedSource</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.BoundedSource.estimate_size"><code class="docutils literal notranslate"><span class="pre">BoundedSource.estimate_size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.BoundedSource.split"><code class="docutils literal notranslate"><span class="pre">BoundedSource.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.BoundedSource.get_range_tracker"><code class="docutils literal notranslate"><span class="pre">BoundedSource.get_range_tracker()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.BoundedSource.read"><code class="docutils literal notranslate"><span class="pre">BoundedSource.read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.BoundedSource.default_output_coder"><code class="docutils literal notranslate"><span class="pre">BoundedSource.default_output_coder()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.BoundedSource.is_bounded"><code class="docutils literal notranslate"><span class="pre">BoundedSource.is_bounded()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker"><code class="docutils literal notranslate"><span class="pre">RangeTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.SPLIT_POINTS_UNKNOWN"><code class="docutils literal notranslate"><span class="pre">RangeTracker.SPLIT_POINTS_UNKNOWN</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.start_position"><code class="docutils literal notranslate"><span class="pre">RangeTracker.start_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.stop_position"><code class="docutils literal notranslate"><span class="pre">RangeTracker.stop_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.try_claim"><code class="docutils literal notranslate"><span class="pre">RangeTracker.try_claim()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.set_current_position"><code class="docutils literal notranslate"><span class="pre">RangeTracker.set_current_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.position_at_fraction"><code class="docutils literal notranslate"><span class="pre">RangeTracker.position_at_fraction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.try_split"><code class="docutils literal notranslate"><span class="pre">RangeTracker.try_split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.fraction_consumed"><code class="docutils literal notranslate"><span class="pre">RangeTracker.fraction_consumed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.split_points"><code class="docutils literal notranslate"><span class="pre">RangeTracker.split_points()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RangeTracker.set_split_points_unclaimed_callback"><code class="docutils literal notranslate"><span class="pre">RangeTracker.set_split_points_unclaimed_callback()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read"><code class="docutils literal notranslate"><span class="pre">Read</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext</span></code></a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.add_requirement"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.add_requirement()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.coder_id_from_element_type"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.coder_id_from_element_type()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.default_environment_id"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.default_environment_id()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.deterministic_coder"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.deterministic_coder()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.element_type_from_coder_id"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.element_type_from_coder_id()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.from_runner_api"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.from_runner_api()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.get_environment_id_for_resource_hints"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.get_environment_id_for_resource_hints()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.requirements"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.requirements()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.PipelineContext.to_runner_api"><code class="docutils literal notranslate"><span class="pre">Read.PipelineContext.to_runner_api()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.get_desired_chunk_size"><code class="docutils literal notranslate"><span class="pre">Read.get_desired_chunk_size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.expand"><code class="docutils literal notranslate"><span class="pre">Read.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.get_windowing"><code class="docutils literal notranslate"><span class="pre">Read.get_windowing()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.display_data"><code class="docutils literal notranslate"><span class="pre">Read.display_data()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.to_runner_api_parameter"><code class="docutils literal notranslate"><span class="pre">Read.to_runner_api_parameter()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Read.from_runner_api_parameter"><code class="docutils literal notranslate"><span class="pre">Read.from_runner_api_parameter()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionProgress"><code class="docutils literal notranslate"><span class="pre">RestrictionProgress</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionProgress.completed_work"><code class="docutils literal notranslate"><span class="pre">RestrictionProgress.completed_work</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionProgress.remaining_work"><code class="docutils literal notranslate"><span class="pre">RestrictionProgress.remaining_work</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionProgress.total_work"><code class="docutils literal notranslate"><span class="pre">RestrictionProgress.total_work</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionProgress.fraction_completed"><code class="docutils literal notranslate"><span class="pre">RestrictionProgress.fraction_completed</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionProgress.fraction_remaining"><code class="docutils literal notranslate"><span class="pre">RestrictionProgress.fraction_remaining</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionProgress.with_completed"><code class="docutils literal notranslate"><span class="pre">RestrictionProgress.with_completed()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionTracker"><code class="docutils literal notranslate"><span class="pre">RestrictionTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionTracker.current_restriction"><code class="docutils literal notranslate"><span class="pre">RestrictionTracker.current_restriction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionTracker.current_progress"><code class="docutils literal notranslate"><span class="pre">RestrictionTracker.current_progress()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionTracker.check_done"><code class="docutils literal notranslate"><span class="pre">RestrictionTracker.check_done()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionTracker.try_split"><code class="docutils literal notranslate"><span class="pre">RestrictionTracker.try_split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionTracker.try_claim"><code class="docutils literal notranslate"><span class="pre">RestrictionTracker.try_claim()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.RestrictionTracker.is_bounded"><code class="docutils literal notranslate"><span class="pre">RestrictionTracker.is_bounded()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.WatermarkEstimator"><code class="docutils literal notranslate"><span class="pre">WatermarkEstimator</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.WatermarkEstimator.get_estimator_state"><code class="docutils literal notranslate"><span class="pre">WatermarkEstimator.get_estimator_state()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.WatermarkEstimator.current_watermark"><code class="docutils literal notranslate"><span class="pre">WatermarkEstimator.current_watermark()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.WatermarkEstimator.observe_timestamp"><code class="docutils literal notranslate"><span class="pre">WatermarkEstimator.observe_timestamp()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink"><code class="docutils literal notranslate"><span class="pre">Sink</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.skip_if_empty"><code class="docutils literal notranslate"><span class="pre">Sink.skip_if_empty</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.triggering_frequency"><code class="docutils literal notranslate"><span class="pre">Sink.triggering_frequency</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.initialize_write"><code class="docutils literal notranslate"><span class="pre">Sink.initialize_write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.open_writer"><code class="docutils literal notranslate"><span class="pre">Sink.open_writer()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.pre_finalize"><code class="docutils literal notranslate"><span class="pre">Sink.pre_finalize()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.pre_finalize_windowed"><code class="docutils literal notranslate"><span class="pre">Sink.pre_finalize_windowed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.finalize_write"><code class="docutils literal notranslate"><span class="pre">Sink.finalize_write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Sink.finalize_windowed_write"><code class="docutils literal notranslate"><span class="pre">Sink.finalize_windowed_write()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write"><code class="docutils literal notranslate"><span class="pre">Write</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext</span></code></a><ul> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.add_requirement"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.add_requirement()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.coder_id_from_element_type"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.coder_id_from_element_type()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.default_environment_id"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.default_environment_id()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.deterministic_coder"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.deterministic_coder()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.element_type_from_coder_id"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.element_type_from_coder_id()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.from_runner_api"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.from_runner_api()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.get_environment_id_for_resource_hints"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.get_environment_id_for_resource_hints()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.requirements"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.requirements()</span></code></a></li> |
| <li class="toctree-l4"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.PipelineContext.to_runner_api"><code class="docutils literal notranslate"><span class="pre">Write.PipelineContext.to_runner_api()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.display_data"><code class="docutils literal notranslate"><span class="pre">Write.display_data()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.expand"><code class="docutils literal notranslate"><span class="pre">Write.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.to_runner_api_parameter"><code class="docutils literal notranslate"><span class="pre">Write.to_runner_api_parameter()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Write.from_runner_api_parameter"><code class="docutils literal notranslate"><span class="pre">Write.from_runner_api_parameter()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Writer"><code class="docutils literal notranslate"><span class="pre">Writer</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Writer.write"><code class="docutils literal notranslate"><span class="pre">Writer.write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Writer.close"><code class="docutils literal notranslate"><span class="pre">Writer.close()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.iobase.html#apache_beam.io.iobase.Writer.at_capacity"><code class="docutils literal notranslate"><span class="pre">Writer.at_capacity()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.jdbc.html">apache_beam.io.jdbc module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.jdbc.html#apache_beam.io.jdbc.WriteToJdbc"><code class="docutils literal notranslate"><span class="pre">WriteToJdbc</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.jdbc.html#apache_beam.io.jdbc.WriteToJdbc.URN"><code class="docutils literal notranslate"><span class="pre">WriteToJdbc.URN</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.jdbc.html#apache_beam.io.jdbc.ReadFromJdbc"><code class="docutils literal notranslate"><span class="pre">ReadFromJdbc</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.jdbc.html#apache_beam.io.jdbc.ReadFromJdbc.URN"><code class="docutils literal notranslate"><span class="pre">ReadFromJdbc.URN</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.kafka.html">apache_beam.io.kafka module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.allow_duplicates"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.allow_duplicates</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.commit_offset_in_finalize"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.commit_offset_in_finalize</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.consumer_config"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.consumer_config</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.consumer_polling_timeout"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.consumer_polling_timeout</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.dynamic_read_poll_interval_seconds"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.dynamic_read_poll_interval_seconds</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.key_deserializer"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.key_deserializer</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.max_num_records"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.max_num_records</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.max_read_time"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.max_read_time</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.redistribute"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.redistribute</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.redistribute_num_keys"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.redistribute_num_keys</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.start_read_time"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.start_read_time</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.timestamp_policy"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.timestamp_policy</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.topics"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.topics</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafkaSchema.value_deserializer"><code class="docutils literal notranslate"><span class="pre">ReadFromKafkaSchema.value_deserializer</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.default_io_expansion_service"><code class="docutils literal notranslate"><span class="pre">default_io_expansion_service()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafka"><code class="docutils literal notranslate"><span class="pre">ReadFromKafka</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafka.byte_array_deserializer"><code class="docutils literal notranslate"><span class="pre">ReadFromKafka.byte_array_deserializer</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafka.processing_time_policy"><code class="docutils literal notranslate"><span class="pre">ReadFromKafka.processing_time_policy</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafka.create_time_policy"><code class="docutils literal notranslate"><span class="pre">ReadFromKafka.create_time_policy</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafka.log_append_time"><code class="docutils literal notranslate"><span class="pre">ReadFromKafka.log_append_time</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafka.URN_WITH_METADATA"><code class="docutils literal notranslate"><span class="pre">ReadFromKafka.URN_WITH_METADATA</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.ReadFromKafka.URN_WITHOUT_METADATA"><code class="docutils literal notranslate"><span class="pre">ReadFromKafka.URN_WITHOUT_METADATA</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafkaSchema"><code class="docutils literal notranslate"><span class="pre">WriteToKafkaSchema</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafkaSchema.key_serializer"><code class="docutils literal notranslate"><span class="pre">WriteToKafkaSchema.key_serializer</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafkaSchema.producer_config"><code class="docutils literal notranslate"><span class="pre">WriteToKafkaSchema.producer_config</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafkaSchema.topic"><code class="docutils literal notranslate"><span class="pre">WriteToKafkaSchema.topic</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafkaSchema.value_serializer"><code class="docutils literal notranslate"><span class="pre">WriteToKafkaSchema.value_serializer</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafka"><code class="docutils literal notranslate"><span class="pre">WriteToKafka</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafka.byte_array_serializer"><code class="docutils literal notranslate"><span class="pre">WriteToKafka.byte_array_serializer</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kafka.html#apache_beam.io.kafka.WriteToKafka.URN"><code class="docutils literal notranslate"><span class="pre">WriteToKafka.URN</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.kinesis.html">apache_beam.io.kinesis module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.WriteToKinesis"><code class="docutils literal notranslate"><span class="pre">WriteToKinesis</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.WriteToKinesis.URN"><code class="docutils literal notranslate"><span class="pre">WriteToKinesis.URN</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.ReadDataFromKinesis"><code class="docutils literal notranslate"><span class="pre">ReadDataFromKinesis</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.ReadDataFromKinesis.URN"><code class="docutils literal notranslate"><span class="pre">ReadDataFromKinesis.URN</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.InitialPositionInStream"><code class="docutils literal notranslate"><span class="pre">InitialPositionInStream</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.InitialPositionInStream.LATEST"><code class="docutils literal notranslate"><span class="pre">InitialPositionInStream.LATEST</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.InitialPositionInStream.TRIM_HORIZON"><code class="docutils literal notranslate"><span class="pre">InitialPositionInStream.TRIM_HORIZON</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.InitialPositionInStream.AT_TIMESTAMP"><code class="docutils literal notranslate"><span class="pre">InitialPositionInStream.AT_TIMESTAMP</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.InitialPositionInStream.validate_param"><code class="docutils literal notranslate"><span class="pre">InitialPositionInStream.validate_param()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.WatermarkPolicy"><code class="docutils literal notranslate"><span class="pre">WatermarkPolicy</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.WatermarkPolicy.PROCESSING_TYPE"><code class="docutils literal notranslate"><span class="pre">WatermarkPolicy.PROCESSING_TYPE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.WatermarkPolicy.ARRIVAL_TIME"><code class="docutils literal notranslate"><span class="pre">WatermarkPolicy.ARRIVAL_TIME</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.kinesis.html#apache_beam.io.kinesis.WatermarkPolicy.validate_param"><code class="docutils literal notranslate"><span class="pre">WatermarkPolicy.validate_param()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.localfilesystem.html">apache_beam.io.localfilesystem module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.scheme"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.scheme()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.join"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.join()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.split"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.mkdirs"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.mkdirs()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.has_dirs"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.has_dirs()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.create"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.create()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.open"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.open()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.copy"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.copy()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.rename"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.rename()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.exists"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.exists()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.size"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.last_updated"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.last_updated()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.checksum"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.checksum()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.metadata"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.metadata()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.delete"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.delete()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.localfilesystem.html#apache_beam.io.localfilesystem.LocalFileSystem.report_lineage"><code class="docutils literal notranslate"><span class="pre">LocalFileSystem.report_lineage()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.mongodbio.html">apache_beam.io.mongodbio module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.mongodbio.html#read-from-mongodb">Read from MongoDB</a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.mongodbio.html#write-to-mongodb">Write to MongoDB:</a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.mongodbio.html#apache_beam.io.mongodbio.ReadFromMongoDB"><code class="docutils literal notranslate"><span class="pre">ReadFromMongoDB</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.mongodbio.html#apache_beam.io.mongodbio.ReadFromMongoDB.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromMongoDB.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.mongodbio.html#apache_beam.io.mongodbio.WriteToMongoDB"><code class="docutils literal notranslate"><span class="pre">WriteToMongoDB</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.mongodbio.html#apache_beam.io.mongodbio.WriteToMongoDB.expand"><code class="docutils literal notranslate"><span class="pre">WriteToMongoDB.expand()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.parquetio.html">apache_beam.io.parquetio module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadFromParquet"><code class="docutils literal notranslate"><span class="pre">ReadFromParquet</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadFromParquet.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromParquet.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadFromParquet.display_data"><code class="docutils literal notranslate"><span class="pre">ReadFromParquet.display_data()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadAllFromParquet"><code class="docutils literal notranslate"><span class="pre">ReadAllFromParquet</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadAllFromParquet.expand"><code class="docutils literal notranslate"><span class="pre">ReadAllFromParquet.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadFromParquetBatched"><code class="docutils literal notranslate"><span class="pre">ReadFromParquetBatched</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadFromParquetBatched.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromParquetBatched.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadFromParquetBatched.display_data"><code class="docutils literal notranslate"><span class="pre">ReadFromParquetBatched.display_data()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadAllFromParquetBatched"><code class="docutils literal notranslate"><span class="pre">ReadAllFromParquetBatched</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadAllFromParquetBatched.DEFAULT_DESIRED_BUNDLE_SIZE"><code class="docutils literal notranslate"><span class="pre">ReadAllFromParquetBatched.DEFAULT_DESIRED_BUNDLE_SIZE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.ReadAllFromParquetBatched.expand"><code class="docutils literal notranslate"><span class="pre">ReadAllFromParquetBatched.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.WriteToParquet"><code class="docutils literal notranslate"><span class="pre">WriteToParquet</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.WriteToParquet.expand"><code class="docutils literal notranslate"><span class="pre">WriteToParquet.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.WriteToParquet.display_data"><code class="docutils literal notranslate"><span class="pre">WriteToParquet.display_data()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.WriteToParquetBatched"><code class="docutils literal notranslate"><span class="pre">WriteToParquetBatched</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.WriteToParquetBatched.expand"><code class="docutils literal notranslate"><span class="pre">WriteToParquetBatched.expand()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.parquetio.html#apache_beam.io.parquetio.WriteToParquetBatched.display_data"><code class="docutils literal notranslate"><span class="pre">WriteToParquetBatched.display_data()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.range_trackers.html">apache_beam.io.range_trackers module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.OFFSET_INFINITY"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.OFFSET_INFINITY</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.start_position"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.start_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.stop_position"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.stop_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.last_record_start"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.last_record_start</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.last_attempted_record_start"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.last_attempted_record_start</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.try_claim"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.try_claim()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.set_current_position"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.set_current_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.try_split"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.try_split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.fraction_consumed"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.fraction_consumed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.position_to_fraction"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.position_to_fraction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.position_at_fraction"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.position_at_fraction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.split_points"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.split_points()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OffsetRangeTracker.set_split_points_unclaimed_callback"><code class="docutils literal notranslate"><span class="pre">OffsetRangeTracker.set_split_points_unclaimed_callback()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.LexicographicKeyRangeTracker"><code class="docutils literal notranslate"><span class="pre">LexicographicKeyRangeTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.LexicographicKeyRangeTracker.fraction_to_position"><code class="docutils literal notranslate"><span class="pre">LexicographicKeyRangeTracker.fraction_to_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.LexicographicKeyRangeTracker.position_to_fraction"><code class="docutils literal notranslate"><span class="pre">LexicographicKeyRangeTracker.position_to_fraction()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.UNSTARTED"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.UNSTARTED</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.start_position"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.start_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.stop_position"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.stop_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.try_claim"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.try_claim()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.position_at_fraction"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.position_at_fraction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.try_split"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.try_split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.fraction_consumed"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.fraction_consumed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.fraction_to_position"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.fraction_to_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.OrderedPositionRangeTracker.position_to_fraction"><code class="docutils literal notranslate"><span class="pre">OrderedPositionRangeTracker.position_to_fraction()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.start_position"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.start_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.stop_position"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.stop_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.position_at_fraction"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.position_at_fraction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.try_claim"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.try_claim()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.try_split"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.try_split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.set_current_position"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.set_current_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.fraction_consumed"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.fraction_consumed()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.split_points"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.split_points()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.range_trackers.html#apache_beam.io.range_trackers.UnsplittableRangeTracker.set_split_points_unclaimed_callback"><code class="docutils literal notranslate"><span class="pre">UnsplittableRangeTracker.set_split_points_unclaimed_callback()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.requestresponse.html">apache_beam.io.requestresponse module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.RequestResponseIO"><code class="docutils literal notranslate"><span class="pre">RequestResponseIO</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.RequestResponseIO.expand"><code class="docutils literal notranslate"><span class="pre">RequestResponseIO.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.ExponentialBackOffRepeater"><code class="docutils literal notranslate"><span class="pre">ExponentialBackOffRepeater</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.ExponentialBackOffRepeater.repeat"><code class="docutils literal notranslate"><span class="pre">ExponentialBackOffRepeater.repeat()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.DefaultThrottler"><code class="docutils literal notranslate"><span class="pre">DefaultThrottler</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.NoOpsRepeater"><code class="docutils literal notranslate"><span class="pre">NoOpsRepeater</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.NoOpsRepeater.repeat"><code class="docutils literal notranslate"><span class="pre">NoOpsRepeater.repeat()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.RedisCache"><code class="docutils literal notranslate"><span class="pre">RedisCache</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.RedisCache.get_read"><code class="docutils literal notranslate"><span class="pre">RedisCache.get_read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.RedisCache.get_write"><code class="docutils literal notranslate"><span class="pre">RedisCache.get_write()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.RedisCache.source_caller"><code class="docutils literal notranslate"><span class="pre">RedisCache.source_caller</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.requestresponse.html#apache_beam.io.requestresponse.RedisCache.request_coder"><code class="docutils literal notranslate"><span class="pre">RedisCache.request_coder</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.restriction_trackers.html">apache_beam.io.restriction_trackers module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRange"><code class="docutils literal notranslate"><span class="pre">OffsetRange</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRange.split"><code class="docutils literal notranslate"><span class="pre">OffsetRange.split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRange.split_at"><code class="docutils literal notranslate"><span class="pre">OffsetRange.split_at()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRange.new_tracker"><code class="docutils literal notranslate"><span class="pre">OffsetRange.new_tracker()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRange.size"><code class="docutils literal notranslate"><span class="pre">OffsetRange.size()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.check_done"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.check_done()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.current_restriction"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.current_restriction()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.current_progress"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.current_progress()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.start_position"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.start_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.stop_position"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.stop_position()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.try_claim"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.try_claim()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.try_split"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.try_split()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.OffsetRestrictionTracker.is_bounded"><code class="docutils literal notranslate"><span class="pre">OffsetRestrictionTracker.is_bounded()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.UnsplittableRestrictionTracker"><code class="docutils literal notranslate"><span class="pre">UnsplittableRestrictionTracker</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.restriction_trackers.html#apache_beam.io.restriction_trackers.UnsplittableRestrictionTracker.try_split"><code class="docutils literal notranslate"><span class="pre">UnsplittableRestrictionTracker.try_split()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.snowflake.html">apache_beam.io.snowflake module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.ReadFromSnowflake"><code class="docutils literal notranslate"><span class="pre">ReadFromSnowflake</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.ReadFromSnowflake.URN"><code class="docutils literal notranslate"><span class="pre">ReadFromSnowflake.URN</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.ReadFromSnowflake.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromSnowflake.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteToSnowflake"><code class="docutils literal notranslate"><span class="pre">WriteToSnowflake</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteToSnowflake.URN"><code class="docutils literal notranslate"><span class="pre">WriteToSnowflake.URN</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteToSnowflake.expand"><code class="docutils literal notranslate"><span class="pre">WriteToSnowflake.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteDisposition"><code class="docutils literal notranslate"><span class="pre">WriteDisposition</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteDisposition.APPEND"><code class="docutils literal notranslate"><span class="pre">WriteDisposition.APPEND</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteDisposition.EMPTY"><code class="docutils literal notranslate"><span class="pre">WriteDisposition.EMPTY</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteDisposition.TRUNCATE"><code class="docutils literal notranslate"><span class="pre">WriteDisposition.TRUNCATE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.WriteDisposition.VerifyParam"><code class="docutils literal notranslate"><span class="pre">WriteDisposition.VerifyParam()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.CreateDisposition"><code class="docutils literal notranslate"><span class="pre">CreateDisposition</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.CreateDisposition.CREATE_IF_NEEDED"><code class="docutils literal notranslate"><span class="pre">CreateDisposition.CREATE_IF_NEEDED</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.CreateDisposition.CREATE_NEVER"><code class="docutils literal notranslate"><span class="pre">CreateDisposition.CREATE_NEVER</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.snowflake.html#apache_beam.io.snowflake.CreateDisposition.VerifyParam"><code class="docutils literal notranslate"><span class="pre">CreateDisposition.VerifyParam()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.source_test_utils.html">apache_beam.io.source_test_utils module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.read_from_source"><code class="docutils literal notranslate"><span class="pre">read_from_source()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.assert_sources_equal_reference_source"><code class="docutils literal notranslate"><span class="pre">assert_sources_equal_reference_source()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.assert_reentrant_reads_succeed"><code class="docutils literal notranslate"><span class="pre">assert_reentrant_reads_succeed()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.assert_split_at_fraction_behavior"><code class="docutils literal notranslate"><span class="pre">assert_split_at_fraction_behavior()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.assert_split_at_fraction_binary"><code class="docutils literal notranslate"><span class="pre">assert_split_at_fraction_binary()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.assert_split_at_fraction_exhaustive"><code class="docutils literal notranslate"><span class="pre">assert_split_at_fraction_exhaustive()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.assert_split_at_fraction_fails"><code class="docutils literal notranslate"><span class="pre">assert_split_at_fraction_fails()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.source_test_utils.html#apache_beam.io.source_test_utils.assert_split_at_fraction_succeeds_and_consistent"><code class="docutils literal notranslate"><span class="pre">assert_split_at_fraction_succeeds_and_consistent()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.textio.html">apache_beam.io.textio module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadFromText"><code class="docutils literal notranslate"><span class="pre">ReadFromText</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadFromText.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromText.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadFromTextWithFilename"><code class="docutils literal notranslate"><span class="pre">ReadFromTextWithFilename</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadAllFromText"><code class="docutils literal notranslate"><span class="pre">ReadAllFromText</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadAllFromText.DEFAULT_DESIRED_BUNDLE_SIZE"><code class="docutils literal notranslate"><span class="pre">ReadAllFromText.DEFAULT_DESIRED_BUNDLE_SIZE</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadAllFromText.expand"><code class="docutils literal notranslate"><span class="pre">ReadAllFromText.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadAllFromTextContinuously"><code class="docutils literal notranslate"><span class="pre">ReadAllFromTextContinuously</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadAllFromTextContinuously.expand"><code class="docutils literal notranslate"><span class="pre">ReadAllFromTextContinuously.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.WriteToText"><code class="docutils literal notranslate"><span class="pre">WriteToText</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.WriteToText.expand"><code class="docutils literal notranslate"><span class="pre">WriteToText.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadFromCsv"><code class="docutils literal notranslate"><span class="pre">ReadFromCsv()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.WriteToCsv"><code class="docutils literal notranslate"><span class="pre">WriteToCsv()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.ReadFromJson"><code class="docutils literal notranslate"><span class="pre">ReadFromJson()</span></code></a></li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.textio.html#apache_beam.io.textio.WriteToJson"><code class="docutils literal notranslate"><span class="pre">WriteToJson()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.tfrecordio.html">apache_beam.io.tfrecordio module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.tfrecordio.html#apache_beam.io.tfrecordio.ReadFromTFRecord"><code class="docutils literal notranslate"><span class="pre">ReadFromTFRecord</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.tfrecordio.html#apache_beam.io.tfrecordio.ReadFromTFRecord.expand"><code class="docutils literal notranslate"><span class="pre">ReadFromTFRecord.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.tfrecordio.html#apache_beam.io.tfrecordio.ReadAllFromTFRecord"><code class="docutils literal notranslate"><span class="pre">ReadAllFromTFRecord</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.tfrecordio.html#apache_beam.io.tfrecordio.ReadAllFromTFRecord.expand"><code class="docutils literal notranslate"><span class="pre">ReadAllFromTFRecord.expand()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.tfrecordio.html#apache_beam.io.tfrecordio.WriteToTFRecord"><code class="docutils literal notranslate"><span class="pre">WriteToTFRecord</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.tfrecordio.html#apache_beam.io.tfrecordio.WriteToTFRecord.expand"><code class="docutils literal notranslate"><span class="pre">WriteToTFRecord.expand()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.utils.html">apache_beam.io.utils module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.utils.html#apache_beam.io.utils.CountingSource"><code class="docutils literal notranslate"><span class="pre">CountingSource</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.utils.html#apache_beam.io.utils.CountingSource.estimate_size"><code class="docutils literal notranslate"><span class="pre">CountingSource.estimate_size()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.utils.html#apache_beam.io.utils.CountingSource.get_range_tracker"><code class="docutils literal notranslate"><span class="pre">CountingSource.get_range_tracker()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.utils.html#apache_beam.io.utils.CountingSource.read"><code class="docutils literal notranslate"><span class="pre">CountingSource.read()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.utils.html#apache_beam.io.utils.CountingSource.split"><code class="docutils literal notranslate"><span class="pre">CountingSource.split()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="toctree-l1"><a class="reference internal" href="apache_beam.io.watermark_estimators.html">apache_beam.io.watermark_estimators module</a><ul> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.MonotonicWatermarkEstimator"><code class="docutils literal notranslate"><span class="pre">MonotonicWatermarkEstimator</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.MonotonicWatermarkEstimator.observe_timestamp"><code class="docutils literal notranslate"><span class="pre">MonotonicWatermarkEstimator.observe_timestamp()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.MonotonicWatermarkEstimator.current_watermark"><code class="docutils literal notranslate"><span class="pre">MonotonicWatermarkEstimator.current_watermark()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.MonotonicWatermarkEstimator.get_estimator_state"><code class="docutils literal notranslate"><span class="pre">MonotonicWatermarkEstimator.get_estimator_state()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.MonotonicWatermarkEstimator.default_provider"><code class="docutils literal notranslate"><span class="pre">MonotonicWatermarkEstimator.default_provider()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.WalltimeWatermarkEstimator"><code class="docutils literal notranslate"><span class="pre">WalltimeWatermarkEstimator</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.WalltimeWatermarkEstimator.observe_timestamp"><code class="docutils literal notranslate"><span class="pre">WalltimeWatermarkEstimator.observe_timestamp()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.WalltimeWatermarkEstimator.current_watermark"><code class="docutils literal notranslate"><span class="pre">WalltimeWatermarkEstimator.current_watermark()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.WalltimeWatermarkEstimator.get_estimator_state"><code class="docutils literal notranslate"><span class="pre">WalltimeWatermarkEstimator.get_estimator_state()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.WalltimeWatermarkEstimator.default_provider"><code class="docutils literal notranslate"><span class="pre">WalltimeWatermarkEstimator.default_provider()</span></code></a></li> |
| </ul> |
| </li> |
| <li class="toctree-l2"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.ManualWatermarkEstimator"><code class="docutils literal notranslate"><span class="pre">ManualWatermarkEstimator</span></code></a><ul> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.ManualWatermarkEstimator.observe_timestamp"><code class="docutils literal notranslate"><span class="pre">ManualWatermarkEstimator.observe_timestamp()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.ManualWatermarkEstimator.current_watermark"><code class="docutils literal notranslate"><span class="pre">ManualWatermarkEstimator.current_watermark()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.ManualWatermarkEstimator.get_estimator_state"><code class="docutils literal notranslate"><span class="pre">ManualWatermarkEstimator.get_estimator_state()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.ManualWatermarkEstimator.set_watermark"><code class="docutils literal notranslate"><span class="pre">ManualWatermarkEstimator.set_watermark()</span></code></a></li> |
| <li class="toctree-l3"><a class="reference internal" href="apache_beam.io.watermark_estimators.html#apache_beam.io.watermark_estimators.ManualWatermarkEstimator.default_provider"><code class="docutils literal notranslate"><span class="pre">ManualWatermarkEstimator.default_provider()</span></code></a></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </div> |
| </section> |
| </section> |
| |
| |
| </div> |
| </div> |
| <footer><div class="rst-footer-buttons" role="navigation" aria-label="Footer"> |
| <a href="apache_beam.dataframe.transforms.html" class="btn btn-neutral float-left" title="apache_beam.dataframe.transforms module" accesskey="p" rel="prev"><span class="fa fa-arrow-circle-left" aria-hidden="true"></span> Previous</a> |
| <a href="apache_beam.io.aws.html" class="btn btn-neutral float-right" title="apache_beam.io.aws package" accesskey="n" rel="next">Next <span class="fa fa-arrow-circle-right" aria-hidden="true"></span></a> |
| </div> |
| |
| <hr/> |
| |
| <div role="contentinfo"> |
| <p>© Copyright %Y, Apache Beam.</p> |
| </div> |
| |
| Built with <a href="https://www.sphinx-doc.org/">Sphinx</a> using a |
| <a href="https://github.com/readthedocs/sphinx_rtd_theme">theme</a> |
| provided by <a href="https://readthedocs.org">Read the Docs</a>. |
| |
| |
| </footer> |
| </div> |
| </div> |
| </section> |
| </div> |
| <script> |
| jQuery(function () { |
| SphinxRtdTheme.Navigation.enable(true); |
| }); |
| </script> |
| |
| </body> |
| </html> |
