javadoc/2.38.0/serialized-form.html - beam-site - Git at Google

 <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
 <!-- NewPage -->
 <html lang="en">
 <head>
 <!-- Generated by javadoc -->
 <title>Serialized Form (Apache Beam 2.38.0-SNAPSHOT)</title>
 <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
 <script type="text/javascript" src="script.js"></script>
 </head>
 <body>
 <script type="text/javascript"><!--
     try {
         if (location.href.indexOf('is-external=true') == -1) {
             parent.document.title="Serialized Form (Apache Beam 2.38.0-SNAPSHOT)";
         }
     }
     catch(err) {
     }
 //-->
 </script>
 <noscript>
 <div>JavaScript is disabled on your browser.</div>
 </noscript>
 <!-- ========= START OF TOP NAVBAR ======= -->
 <div class="topNav"><a name="navbar.top">
 <!--   -->
 </a>
 <div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
 <a name="navbar.top.firstrow">
 <!--   -->
 </a>
 <ul class="navList" title="Navigation">
 <li><a href="overview-summary.html">Overview</a></li>
 <li>Package</li>
 <li>Class</li>
 <li><a href="overview-tree.html">Tree</a></li>
 <li><a href="deprecated-list.html">Deprecated</a></li>
 <li><a href="index-all.html">Index</a></li>
 <li><a href="help-doc.html">Help</a></li>
 </ul>
 </div>
 <div class="subNav">
 <ul class="navList">
 <li>Prev</li>
 <li>Next</li>
 </ul>
 <ul class="navList">
 <li><a href="index.html?serialized-form.html" target="_top">Frames</a></li>
 <li><a href="serialized-form.html" target="_top">No&nbsp;Frames</a></li>
 </ul>
 <ul class="navList" id="allclasses_navbar_top">
 <li><a href="allclasses-noframe.html">All&nbsp;Classes</a></li>
 </ul>
 <div>
 <script type="text/javascript"><!--
   allClassesLink = document.getElementById("allclasses_navbar_top");
   if(window==top) {
     allClassesLink.style.display = "block";
   }
   else {
     allClassesLink.style.display = "none";
   }
   //-->
 </script>
 </div>
 <a name="skip.navbar.top">
 <!--   -->
 </a></div>
 <!-- ========= END OF TOP NAVBAR ========= -->
 <div class="header">
 <h1 title="Serialized Form" class="title">Serialized Form</h1>
 </div>
 <div class="serializedFormContainer">
 <ul class="blockList">
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.io.debezium</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.io.debezium.DebeziumIO.ConnectorConfiguration">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/io/debezium/DebeziumIO.ConnectorConfiguration.html" title="class in org.apache.beam.io.debezium">org.apache.beam.io.debezium.DebeziumIO.ConnectorConfiguration</a> extends java.lang.Object implements Serializable</h3>
 <dl class="nameValue">
 <dt>serialVersionUID:</dt>
 <dd>1L</dd>
 </dl>
 </li>
 <li class="blockList"><a name="org.apache.beam.io.debezium.DebeziumIO.Read">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/io/debezium/DebeziumIO.Read.html" title="class in org.apache.beam.io.debezium">org.apache.beam.io.debezium.DebeziumIO.Read</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PBegin.html" title="class in org.apache.beam.sdk.values">PBegin</a>,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/io/debezium/DebeziumIO.Read.html" title="type parameter in DebeziumIO.Read">T</a>&gt;&gt; implements Serializable</h3>
 <dl class="nameValue">
 <dt>serialVersionUID:</dt>
 <dd>1L</dd>
 </dl>
 </li>
 <li class="blockList"><a name="org.apache.beam.io.debezium.KafkaSourceConsumerFn">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/io/debezium/KafkaSourceConsumerFn.html" title="class in org.apache.beam.io.debezium">org.apache.beam.io.debezium.KafkaSourceConsumerFn</a> extends <a href="org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a>&lt;java.util.Map&lt;java.lang.String,java.lang.String&gt;,<a href="org/apache/beam/io/debezium/KafkaSourceConsumerFn.html" title="type parameter in KafkaSourceConsumerFn">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>connectorClass</h4>
 <pre>java.lang.Class&lt;T&gt; connectorClass</pre>
 </li>
 <li class="blockList">
 <h4>fn</h4>
 <pre><a href="org/apache/beam/io/debezium/SourceRecordMapper.html" title="interface in org.apache.beam.io.debezium">SourceRecordMapper</a>&lt;<a href="org/apache/beam/io/debezium/SourceRecordMapper.html" title="type parameter in SourceRecordMapper">T</a>&gt; fn</pre>
 </li>
 <li class="blockList">
 <h4>minutesToRun</h4>
 <pre>long minutesToRun</pre>
 </li>
 <li class="blockListLast">
 <h4>maxRecords</h4>
 <pre>java.lang.Integer maxRecords</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.io.debezium.SourceRecordJson.SourceRecordJsonMapper">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/io/debezium/SourceRecordJson.SourceRecordJsonMapper.html" title="class in org.apache.beam.io.debezium">org.apache.beam.io.debezium.SourceRecordJson.SourceRecordJsonMapper</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.dataflow</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.BatchStatefulParDoOverrides.BatchStatefulDoFn">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.BatchStatefulDoFn.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.BatchStatefulParDoOverrides.BatchStatefulDoFn</a> extends <a href="org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.BatchStatefulDoFn.html" title="type parameter in BatchStatefulParDoOverrides.BatchStatefulDoFn">K</a>,java.lang.Iterable&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a>,org.apache.beam.sdk.util.WindowedValue&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.BatchStatefulDoFn.html" title="type parameter in BatchStatefulParDoOverrides.BatchStatefulDoFn">K</a>,<a href="org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.BatchStatefulDoFn.html" title="type parameter in BatchStatefulParDoOverrides.BatchStatefulDoFn">V</a>&gt;&gt;&gt;&gt;&gt;,<a href="org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.BatchStatefulDoFn.html" title="type parameter in BatchStatefulParDoOverrides.BatchStatefulDoFn">OutputT</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>underlyingDoFn</h4>
 <pre><a href="org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a>&lt;<a href="org/apache/beam/sdk/transforms/DoFn.html" title="type parameter in DoFn">InputT</a>,<a href="org/apache/beam/sdk/transforms/DoFn.html" title="type parameter in DoFn">OutputT</a>&gt; underlyingDoFn</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.CreateDataflowView">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/CreateDataflowView.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.CreateDataflowView</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/runners/dataflow/CreateDataflowView.html" title="type parameter in CreateDataflowView">ElemT</a>&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/runners/dataflow/CreateDataflowView.html" title="type parameter in CreateDataflowView">ElemT</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>view</h4>
 <pre><a href="org/apache/beam/sdk/values/PCollectionView.html" title="interface in org.apache.beam.sdk.values">PCollectionView</a>&lt;<a href="org/apache/beam/sdk/values/PCollectionView.html" title="type parameter in PCollectionView">T</a>&gt; view</pre>
 </li>
 <li class="blockListLast">
 <h4>streaming</h4>
 <pre>boolean streaming</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.DataflowJobAlreadyExistsException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/DataflowJobAlreadyExistsException.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.DataflowJobAlreadyExistsException</a> extends <a href="org/apache/beam/runners/dataflow/DataflowJobException.html" title="class in org.apache.beam.runners.dataflow">DataflowJobException</a> implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.DataflowJobAlreadyUpdatedException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/DataflowJobAlreadyUpdatedException.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.DataflowJobAlreadyUpdatedException</a> extends <a href="org/apache/beam/runners/dataflow/DataflowJobException.html" title="class in org.apache.beam.runners.dataflow">DataflowJobException</a> implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.DataflowJobException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/DataflowJobException.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.DataflowJobException</a> extends java.lang.RuntimeException implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>job</h4>
 <pre><a href="org/apache/beam/runners/dataflow/DataflowPipelineJob.html" title="class in org.apache.beam.runners.dataflow">DataflowPipelineJob</a> job</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.DataflowRunner.StreamingPCollectionViewWriterFn">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/DataflowRunner.StreamingPCollectionViewWriterFn.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.DataflowRunner.StreamingPCollectionViewWriterFn</a> extends <a href="org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a>&lt;java.lang.Iterable&lt;<a href="org/apache/beam/runners/dataflow/DataflowRunner.StreamingPCollectionViewWriterFn.html" title="type parameter in DataflowRunner.StreamingPCollectionViewWriterFn">T</a>&gt;,<a href="org/apache/beam/runners/dataflow/DataflowRunner.StreamingPCollectionViewWriterFn.html" title="type parameter in DataflowRunner.StreamingPCollectionViewWriterFn">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>view</h4>
 <pre><a href="org/apache/beam/sdk/values/PCollectionView.html" title="interface in org.apache.beam.sdk.values">PCollectionView</a>&lt;<a href="org/apache/beam/sdk/values/PCollectionView.html" title="type parameter in PCollectionView">T</a>&gt; view</pre>
 </li>
 <li class="blockListLast">
 <h4>dataCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; dataCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.DataflowRunnerInfo">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/DataflowRunnerInfo.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.DataflowRunnerInfo</a> extends org.apache.beam.sdk.util.ReleaseInfo implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>properties</h4>
 <pre>java.util.Map&lt;K,V&gt; properties</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.DataflowServiceException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/DataflowServiceException.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.DataflowServiceException</a> extends <a href="org/apache/beam/runners/dataflow/DataflowJobException.html" title="class in org.apache.beam.runners.dataflow">DataflowJobException</a> implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.ParDoSingle.html" title="class in org.apache.beam.runners.dataflow">org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle</a> extends org.apache.beam.runners.core.construction.ForwardingPTransform&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;? extends <a href="org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.ParDoSingle.html" title="type parameter in PrimitiveParDoSingleFactory.ParDoSingle">InputT</a>&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.ParDoSingle.html" title="type parameter in PrimitiveParDoSingleFactory.ParDoSingle">OutputT</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>original</h4>
 <pre><a href="org/apache/beam/sdk/transforms/ParDo.SingleOutput.html" title="class in org.apache.beam.sdk.transforms">ParDo.SingleOutput</a>&lt;<a href="org/apache/beam/sdk/transforms/ParDo.SingleOutput.html" title="type parameter in ParDo.SingleOutput">InputT</a>,<a href="org/apache/beam/sdk/transforms/ParDo.SingleOutput.html" title="type parameter in ParDo.SingleOutput">OutputT</a>&gt; original</pre>
 </li>
 <li class="blockList">
 <h4>onlyOutputTag</h4>
 <pre><a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values">TupleTag</a>&lt;<a href="org/apache/beam/sdk/values/TupleTag.html" title="type parameter in TupleTag">V</a>&gt; onlyOutputTag</pre>
 </li>
 <li class="blockListLast">
 <h4>outputCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; outputCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.dataflow.options</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.options.DataflowProfilingOptions.DataflowProfilingAgentConfiguration">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/options/DataflowProfilingOptions.DataflowProfilingAgentConfiguration.html" title="class in org.apache.beam.runners.dataflow.options">org.apache.beam.runners.dataflow.options.DataflowProfilingOptions.DataflowProfilingAgentConfiguration</a> extends java.util.HashMap&lt;java.lang.String,java.lang.Object&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.WorkerLogLevelOverrides.html" title="class in org.apache.beam.runners.dataflow.options">org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides</a> extends java.util.HashMap&lt;java.lang.String,<a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.Level.html" title="enum in org.apache.beam.runners.dataflow.options">DataflowWorkerLoggingOptions.Level</a>&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.dataflow.util</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.util.MonitoringUtil.TimeStampComparator">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/util/MonitoringUtil.TimeStampComparator.html" title="class in org.apache.beam.runners.dataflow.util">org.apache.beam.runners.dataflow.util.MonitoringUtil.TimeStampComparator</a> extends java.lang.Object implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/util/RandomAccessData.RandomAccessDataCoder.html" title="class in org.apache.beam.runners.dataflow.util">org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;<a href="org/apache/beam/runners/dataflow/util/RandomAccessData.html" title="class in org.apache.beam.runners.dataflow.util">RandomAccessData</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.dataflow.util.RandomAccessData.UnsignedLexicographicalComparator">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/dataflow/util/RandomAccessData.UnsignedLexicographicalComparator.html" title="class in org.apache.beam.runners.dataflow.util">org.apache.beam.runners.dataflow.util.RandomAccessData.UnsignedLexicographicalComparator</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.flink</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.flink.CreateStreamingFlinkView.CreateFlinkPCollectionView">
 <!--   -->
 </a>
 <h3>Class org.apache.beam.runners.flink.CreateStreamingFlinkView.CreateFlinkPCollectionView extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.util.List&lt;ElemT&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.util.List&lt;ElemT&gt;&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>view</h4>
 <pre><a href="org/apache/beam/sdk/values/PCollectionView.html" title="interface in org.apache.beam.sdk.values">PCollectionView</a>&lt;<a href="org/apache/beam/sdk/values/PCollectionView.html" title="type parameter in PCollectionView">T</a>&gt; view</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.StripIdsMap">
 <!--   -->
 </a>
 <h3>Class org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.StripIdsMap extends org.apache.flink.api.common.functions.RichFlatMapFunction&lt;org.apache.beam.sdk.util.WindowedValue&lt;<a href="org/apache/beam/sdk/values/ValueWithRecordId.html" title="class in org.apache.beam.sdk.values">ValueWithRecordId</a>&lt;T&gt;&gt;,org.apache.beam.sdk.util.WindowedValue&lt;T&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>options</h4>
 <pre>org.apache.beam.runners.core.construction.SerializablePipelineOptions options</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.ToRawUnion">
 <!--   -->
 </a>
 <h3>Class org.apache.beam.runners.flink.FlinkStreamingTransformTranslators.ToRawUnion extends org.apache.flink.api.common.functions.RichMapFunction&lt;T,<a href="org/apache/beam/sdk/transforms/join/RawUnionValue.html" title="class in org.apache.beam.sdk.transforms.join">RawUnionValue</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>intTag</h4>
 <pre>int intTag</pre>
 </li>
 <li class="blockListLast">
 <h4>options</h4>
 <pre>org.apache.beam.runners.core.construction.SerializablePipelineOptions options</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.flink.metrics</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.flink.metrics.MetricsAccumulator">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/flink/metrics/MetricsAccumulator.html" title="class in org.apache.beam.runners.flink.metrics">org.apache.beam.runners.flink.metrics.MetricsAccumulator</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>metricsContainers</h4>
 <pre>org.apache.beam.runners.core.metrics.MetricsContainerStepMap metricsContainers</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.fnexecution.control</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.html" title="class in org.apache.beam.runners.fnexecution.control">org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>creator</h4>
 <pre><a href="org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.Creator.html" title="interface in org.apache.beam.runners.fnexecution.control">ReferenceCountingExecutableStageContextFactory.Creator</a> creator</pre>
 </li>
 <li class="blockListLast">
 <h4>isReleaseSynchronous</h4>
 <pre><a href="org/apache/beam/sdk/transforms/SerializableFunction.html" title="interface in org.apache.beam.sdk.transforms">SerializableFunction</a>&lt;<a href="org/apache/beam/sdk/transforms/SerializableFunction.html" title="type parameter in SerializableFunction">InputT</a>,<a href="org/apache/beam/sdk/transforms/SerializableFunction.html" title="type parameter in SerializableFunction">OutputT</a>&gt; isReleaseSynchronous</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.fnexecution.provisioning</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.fnexecution.provisioning.JobInfo">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/fnexecution/provisioning/JobInfo.html" title="class in org.apache.beam.runners.fnexecution.provisioning">org.apache.beam.runners.fnexecution.provisioning.JobInfo</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.fnexecution.wire</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.fnexecution.wire.ByteStringCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/fnexecution/wire/ByteStringCoder.html" title="class in org.apache.beam.runners.fnexecution.wire">org.apache.beam.runners.fnexecution.wire.ByteStringCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;org.apache.beam.vendor.grpc.v1p43p2.com.google.protobuf.ByteString&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.jet.metrics</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.jet.metrics.CounterImpl">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/jet/metrics/CounterImpl.html" title="class in org.apache.beam.runners.jet.metrics">org.apache.beam.runners.jet.metrics.CounterImpl</a> extends org.apache.beam.runners.jet.metrics.AbstractMetric&lt;java.lang.Long&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>count</h4>
 <pre>long count</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.jet.metrics.DistributionImpl">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/jet/metrics/DistributionImpl.html" title="class in org.apache.beam.runners.jet.metrics">org.apache.beam.runners.jet.metrics.DistributionImpl</a> extends org.apache.beam.runners.jet.metrics.AbstractMetric&lt;org.apache.beam.runners.core.metrics.DistributionData&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>distributionData</h4>
 <pre>org.apache.beam.runners.core.metrics.DistributionData distributionData</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.jet.metrics.GaugeImpl">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/jet/metrics/GaugeImpl.html" title="class in org.apache.beam.runners.jet.metrics">org.apache.beam.runners.jet.metrics.GaugeImpl</a> extends org.apache.beam.runners.jet.metrics.AbstractMetric&lt;org.apache.beam.runners.core.metrics.GaugeData&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>gaugeData</h4>
 <pre>org.apache.beam.runners.core.metrics.GaugeData gaugeData</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.jet.metrics.JetMetricsContainer">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/jet/metrics/JetMetricsContainer.html" title="class in org.apache.beam.runners.jet.metrics">org.apache.beam.runners.jet.metrics.JetMetricsContainer</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>stepName</h4>
 <pre>java.lang.String stepName</pre>
 </li>
 <li class="blockList">
 <h4>metricsKey</h4>
 <pre>java.lang.String metricsKey</pre>
 </li>
 <li class="blockList">
 <h4>counters</h4>
 <pre>java.util.Map&lt;K,V&gt; counters</pre>
 </li>
 <li class="blockList">
 <h4>distributions</h4>
 <pre>java.util.Map&lt;K,V&gt; distributions</pre>
 </li>
 <li class="blockList">
 <h4>gauges</h4>
 <pre>java.util.Map&lt;K,V&gt; gauges</pre>
 </li>
 <li class="blockListLast">
 <h4>accumulator</h4>
 <pre>com.hazelcast.map.IMap&lt;K,V&gt; accumulator</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.jet.processors</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.jet.processors.FlattenP.Supplier">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/jet/processors/FlattenP.Supplier.html" title="class in org.apache.beam.runners.jet.processors">org.apache.beam.runners.jet.processors.FlattenP.Supplier</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>inputCollectionCoders</h4>
 <pre>java.util.Map&lt;K,V&gt; inputCollectionCoders</pre>
 </li>
 <li class="blockList">
 <h4>outputCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; outputCoder</pre>
 </li>
 <li class="blockList">
 <h4>ownerId</h4>
 <pre>java.lang.String ownerId</pre>
 </li>
 <li class="blockListLast">
 <h4>inputOrdinalCoders</h4>
 <pre>java.util.Map&lt;K,V&gt; inputOrdinalCoders</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.jet.processors.ParDoP.Supplier">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/jet/processors/ParDoP.Supplier.html" title="class in org.apache.beam.runners.jet.processors">org.apache.beam.runners.jet.processors.ParDoP.Supplier</a> extends org.apache.beam.runners.jet.processors.AbstractParDoP.AbstractSupplier&lt;<a href="org/apache/beam/runners/jet/processors/ParDoP.Supplier.html" title="type parameter in ParDoP.Supplier">InputT</a>,<a href="org/apache/beam/runners/jet/processors/ParDoP.Supplier.html" title="type parameter in ParDoP.Supplier">OutputT</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.jet.processors.StatefulParDoP.Supplier">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/jet/processors/StatefulParDoP.Supplier.html" title="class in org.apache.beam.runners.jet.processors">org.apache.beam.runners.jet.processors.StatefulParDoP.Supplier</a> extends org.apache.beam.runners.jet.processors.AbstractParDoP.AbstractSupplier&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;?,?&gt;,<a href="org/apache/beam/runners/jet/processors/StatefulParDoP.Supplier.html" title="type parameter in StatefulParDoP.Supplier">OutputT</a>&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.portability</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.portability.CloseableResource.CloseException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/portability/CloseableResource.CloseException.html" title="class in org.apache.beam.runners.portability">org.apache.beam.runners.portability.CloseableResource.CloseException</a> extends java.lang.Exception implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.aggregators</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.aggregators.NamedAggregators">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.aggregators">org.apache.beam.runners.spark.aggregators.NamedAggregators</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>mNamedAggregators</h4>
 <pre>java.util.Map&lt;K,V&gt; mNamedAggregators</pre>
 <div class="block">Map from aggregator name to current state.</div>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.aggregators.NamedAggregatorsAccumulator">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/aggregators/NamedAggregatorsAccumulator.html" title="class in org.apache.beam.runners.spark.aggregators">org.apache.beam.runners.spark.aggregators.NamedAggregatorsAccumulator</a> extends org.apache.spark.util.AccumulatorV2&lt;<a href="org/apache/beam/runners/spark/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.aggregators">NamedAggregators</a>,<a href="org/apache/beam/runners/spark/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.aggregators">NamedAggregators</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>value</h4>
 <pre><a href="org/apache/beam/runners/spark/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.aggregators">NamedAggregators</a> value</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.coders</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.coders.CoderHelpers.FromByteFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/coders/CoderHelpers.FromByteFunction.html" title="class in org.apache.beam.runners.spark.coders">org.apache.beam.runners.spark.coders.CoderHelpers.FromByteFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>keyCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; keyCoder</pre>
 </li>
 <li class="blockListLast">
 <h4>valueCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; valueCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.io</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.io.ConsoleIO.Write.Unbound">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/io/ConsoleIO.Write.Unbound.html" title="class in org.apache.beam.runners.spark.io">org.apache.beam.runners.spark.io.ConsoleIO.Write.Unbound</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/runners/spark/io/ConsoleIO.Write.Unbound.html" title="type parameter in ConsoleIO.Write.Unbound">T</a>&gt;,<a href="org/apache/beam/sdk/values/PDone.html" title="class in org.apache.beam.sdk.values">PDone</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>num</h4>
 <pre>int num</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.io.CreateStream">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/io/CreateStream.html" title="class in org.apache.beam.runners.spark.io">org.apache.beam.runners.spark.io.CreateStream</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PBegin.html" title="class in org.apache.beam.sdk.values">PBegin</a>,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/runners/spark/io/CreateStream.html" title="type parameter in CreateStream">T</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>batchDuration</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Duration.html?is-external=true" title="class or interface in org.joda.time">Duration</a> batchDuration</pre>
 </li>
 <li class="blockList">
 <h4>batches</h4>
 <pre>java.util.Queue&lt;E&gt; batches</pre>
 </li>
 <li class="blockList">
 <h4>times</h4>
 <pre>java.util.Deque&lt;E&gt; times</pre>
 </li>
 <li class="blockList">
 <h4>coder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; coder</pre>
 </li>
 <li class="blockList">
 <h4>initialSystemTime</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a> initialSystemTime</pre>
 </li>
 <li class="blockList">
 <h4>forceWatermarkSync</h4>
 <pre>boolean forceWatermarkSync</pre>
 </li>
 <li class="blockListLast">
 <h4>lowWatermark</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a> lowWatermark</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.io.EmptyCheckpointMark">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/io/EmptyCheckpointMark.html" title="class in org.apache.beam.runners.spark.io">org.apache.beam.runners.spark.io.EmptyCheckpointMark</a> extends java.lang.Object implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.io.MicrobatchSource">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/io/MicrobatchSource.html" title="class in org.apache.beam.runners.spark.io">org.apache.beam.runners.spark.io.MicrobatchSource</a> extends <a href="org/apache/beam/sdk/io/Source.html" title="class in org.apache.beam.sdk.io">Source</a>&lt;<a href="org/apache/beam/runners/spark/io/MicrobatchSource.html" title="type parameter in MicrobatchSource">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>source</h4>
 <pre><a href="org/apache/beam/sdk/io/UnboundedSource.html" title="class in org.apache.beam.sdk.io">UnboundedSource</a>&lt;<a href="org/apache/beam/sdk/io/UnboundedSource.html" title="type parameter in UnboundedSource">OutputT</a>,<a href="org/apache/beam/sdk/io/UnboundedSource.html" title="type parameter in UnboundedSource">CheckpointMarkT</a> extends <a href="org/apache/beam/sdk/io/UnboundedSource.CheckpointMark.html" title="interface in org.apache.beam.sdk.io">UnboundedSource.CheckpointMark</a>&gt; source</pre>
 </li>
 <li class="blockList">
 <h4>maxReadTime</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Duration.html?is-external=true" title="class or interface in org.joda.time">Duration</a> maxReadTime</pre>
 </li>
 <li class="blockList">
 <h4>numInitialSplits</h4>
 <pre>int numInitialSplits</pre>
 </li>
 <li class="blockList">
 <h4>maxNumRecords</h4>
 <pre>long maxNumRecords</pre>
 </li>
 <li class="blockList">
 <h4>sourceId</h4>
 <pre>int sourceId</pre>
 </li>
 <li class="blockList">
 <h4>readerCacheInterval</h4>
 <pre>double readerCacheInterval</pre>
 </li>
 <li class="blockListLast">
 <h4>splitId</h4>
 <pre>int splitId</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.io.SourceRDD.Bounded">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/io/SourceRDD.Bounded.html" title="class in org.apache.beam.runners.spark.io">org.apache.beam.runners.spark.io.SourceRDD.Bounded</a> extends org.apache.spark.rdd.RDD&lt;org.apache.beam.sdk.util.WindowedValue&lt;<a href="org/apache/beam/runners/spark/io/SourceRDD.Bounded.html" title="type parameter in SourceRDD.Bounded">T</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>source</h4>
 <pre><a href="org/apache/beam/sdk/io/BoundedSource.html" title="class in org.apache.beam.sdk.io">BoundedSource</a>&lt;<a href="org/apache/beam/sdk/io/BoundedSource.html" title="type parameter in BoundedSource">T</a>&gt; source</pre>
 </li>
 <li class="blockList">
 <h4>options</h4>
 <pre>org.apache.beam.runners.core.construction.SerializablePipelineOptions options</pre>
 </li>
 <li class="blockList">
 <h4>numPartitions</h4>
 <pre>int numPartitions</pre>
 </li>
 <li class="blockList">
 <h4>bundleSize</h4>
 <pre>long bundleSize</pre>
 </li>
 <li class="blockList">
 <h4>stepName</h4>
 <pre>java.lang.String stepName</pre>
 </li>
 <li class="blockListLast">
 <h4>metricsAccum</h4>
 <pre><a href="org/apache/beam/runners/spark/metrics/MetricsContainerStepMapAccumulator.html" title="class in org.apache.beam.runners.spark.metrics">MetricsContainerStepMapAccumulator</a> metricsAccum</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.io.SourceRDD.Unbounded">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/io/SourceRDD.Unbounded.html" title="class in org.apache.beam.runners.spark.io">org.apache.beam.runners.spark.io.SourceRDD.Unbounded</a> extends org.apache.spark.rdd.RDD&lt;scala.Tuple2&lt;<a href="org/apache/beam/sdk/io/Source.html" title="class in org.apache.beam.sdk.io">Source</a>&lt;<a href="org/apache/beam/runners/spark/io/SourceRDD.Unbounded.html" title="type parameter in SourceRDD.Unbounded">T</a>&gt;,<a href="org/apache/beam/runners/spark/io/SourceRDD.Unbounded.html" title="type parameter in SourceRDD.Unbounded">CheckpointMarkT</a> extends <a href="org/apache/beam/sdk/io/UnboundedSource.CheckpointMark.html" title="interface in org.apache.beam.sdk.io">UnboundedSource.CheckpointMark</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>microbatchSource</h4>
 <pre><a href="org/apache/beam/runners/spark/io/MicrobatchSource.html" title="class in org.apache.beam.runners.spark.io">MicrobatchSource</a>&lt;<a href="org/apache/beam/runners/spark/io/MicrobatchSource.html" title="type parameter in MicrobatchSource">T</a>,<a href="org/apache/beam/runners/spark/io/MicrobatchSource.html" title="type parameter in MicrobatchSource">CheckpointMarkT</a> extends <a href="org/apache/beam/sdk/io/UnboundedSource.CheckpointMark.html" title="interface in org.apache.beam.sdk.io">UnboundedSource.CheckpointMark</a>&gt; microbatchSource</pre>
 </li>
 <li class="blockList">
 <h4>options</h4>
 <pre>org.apache.beam.runners.core.construction.SerializablePipelineOptions options</pre>
 </li>
 <li class="blockListLast">
 <h4>partitioner</h4>
 <pre>org.apache.spark.Partitioner partitioner</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.io.SparkUnboundedSource.Metadata">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/io/SparkUnboundedSource.Metadata.html" title="class in org.apache.beam.runners.spark.io">org.apache.beam.runners.spark.io.SparkUnboundedSource.Metadata</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>numRecords</h4>
 <pre>long numRecords</pre>
 </li>
 <li class="blockList">
 <h4>lowWatermark</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a> lowWatermark</pre>
 </li>
 <li class="blockList">
 <h4>highWatermark</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a> highWatermark</pre>
 </li>
 <li class="blockList">
 <h4>readDurationMillis</h4>
 <pre>long readDurationMillis</pre>
 </li>
 <li class="blockListLast">
 <h4>metricsContainers</h4>
 <pre>org.apache.beam.runners.core.metrics.MetricsContainerStepMap metricsContainers</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.metrics</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.metrics.MetricsContainerStepMapAccumulator">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/metrics/MetricsContainerStepMapAccumulator.html" title="class in org.apache.beam.runners.spark.metrics">org.apache.beam.runners.spark.metrics.MetricsContainerStepMapAccumulator</a> extends org.apache.spark.util.AccumulatorV2&lt;org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>value</h4>
 <pre>org.apache.beam.runners.core.metrics.MetricsContainerStepMap value</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.stateful</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.stateful.SparkGroupAlsoByWindowViaWindowSet">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.html" title="class in org.apache.beam.runners.spark.stateful">org.apache.beam.runners.spark.stateful.SparkGroupAlsoByWindowViaWindowSet</a> extends java.lang.Object implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.stateful.SparkGroupAlsoByWindowViaWindowSet.StateAndTimers">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.StateAndTimers.html" title="class in org.apache.beam.runners.spark.stateful">org.apache.beam.runners.spark.stateful.SparkGroupAlsoByWindowViaWindowSet.StateAndTimers</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>state</h4>
 <pre>org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Table&lt;R,C,V&gt; state</pre>
 </li>
 <li class="blockListLast">
 <h4>serTimers</h4>
 <pre>java.util.Collection&lt;E&gt; serTimers</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.structuredstreaming.aggregators</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.aggregators.NamedAggregators">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.structuredstreaming.aggregators">org.apache.beam.runners.spark.structuredstreaming.aggregators.NamedAggregators</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>mNamedAggregators</h4>
 <pre>java.util.Map&lt;K,V&gt; mNamedAggregators</pre>
 <div class="block">Map from aggregator name to current state.</div>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.aggregators.NamedAggregatorsAccumulator">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregatorsAccumulator.html" title="class in org.apache.beam.runners.spark.structuredstreaming.aggregators">org.apache.beam.runners.spark.structuredstreaming.aggregators.NamedAggregatorsAccumulator</a> extends org.apache.spark.util.AccumulatorV2&lt;<a href="org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.structuredstreaming.aggregators">NamedAggregators</a>,<a href="org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.structuredstreaming.aggregators">NamedAggregators</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>value</h4>
 <pre><a href="org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.structuredstreaming.aggregators">NamedAggregators</a> value</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.structuredstreaming.examples</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.examples.WordCount.CountWords">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/examples/WordCount.CountWords.html" title="class in org.apache.beam.runners.spark.structuredstreaming.examples">org.apache.beam.runners.spark.structuredstreaming.examples.WordCount.CountWords</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.lang.String&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,java.lang.Long&gt;&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.examples.WordCount.FormatAsTextFn">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/examples/WordCount.FormatAsTextFn.html" title="class in org.apache.beam.runners.spark.structuredstreaming.examples">org.apache.beam.runners.spark.structuredstreaming.examples.WordCount.FormatAsTextFn</a> extends <a href="org/apache/beam/sdk/transforms/SimpleFunction.html" title="class in org.apache.beam.sdk.transforms">SimpleFunction</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,java.lang.Long&gt;,java.lang.String&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.structuredstreaming.metrics</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.metrics.MetricsContainerStepMapAccumulator">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/metrics/MetricsContainerStepMapAccumulator.html" title="class in org.apache.beam.runners.spark.structuredstreaming.metrics">org.apache.beam.runners.spark.structuredstreaming.metrics.MetricsContainerStepMapAccumulator</a> extends org.apache.spark.util.AccumulatorV2&lt;org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>value</h4>
 <pre>org.apache.beam.runners.core.metrics.MetricsContainerStepMap value</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.structuredstreaming.translation</h2>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.structuredstreaming.translation.batch</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.translation.batch.DoFnFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnFunction.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.batch">org.apache.beam.runners.spark.structuredstreaming.translation.batch.DoFnFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>metricsAccum</h4>
 <pre><a href="org/apache/beam/runners/spark/structuredstreaming/metrics/MetricsContainerStepMapAccumulator.html" title="class in org.apache.beam.runners.spark.structuredstreaming.metrics">MetricsContainerStepMapAccumulator</a> metricsAccum</pre>
 </li>
 <li class="blockList">
 <h4>stepName</h4>
 <pre>java.lang.String stepName</pre>
 </li>
 <li class="blockList">
 <h4>doFn</h4>
 <pre><a href="org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a>&lt;<a href="org/apache/beam/sdk/transforms/DoFn.html" title="type parameter in DoFn">InputT</a>,<a href="org/apache/beam/sdk/transforms/DoFn.html" title="type parameter in DoFn">OutputT</a>&gt; doFn</pre>
 </li>
 <li class="blockList">
 <h4>windowingStrategy</h4>
 <pre><a href="org/apache/beam/sdk/values/WindowingStrategy.html" title="class in org.apache.beam.sdk.values">WindowingStrategy</a>&lt;<a href="org/apache/beam/sdk/values/WindowingStrategy.html" title="type parameter in WindowingStrategy">T</a>,<a href="org/apache/beam/sdk/values/WindowingStrategy.html" title="type parameter in WindowingStrategy">W</a> extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>&gt; windowingStrategy</pre>
 </li>
 <li class="blockList">
 <h4>sideInputs</h4>
 <pre>java.util.Map&lt;K,V&gt; sideInputs</pre>
 </li>
 <li class="blockList">
 <h4>serializableOptions</h4>
 <pre>org.apache.beam.runners.core.construction.SerializablePipelineOptions serializableOptions</pre>
 </li>
 <li class="blockList">
 <h4>additionalOutputTags</h4>
 <pre>java.util.List&lt;E&gt; additionalOutputTags</pre>
 </li>
 <li class="blockList">
 <h4>mainOutputTag</h4>
 <pre><a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values">TupleTag</a>&lt;<a href="org/apache/beam/sdk/values/TupleTag.html" title="type parameter in TupleTag">V</a>&gt; mainOutputTag</pre>
 </li>
 <li class="blockList">
 <h4>inputCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; inputCoder</pre>
 </li>
 <li class="blockList">
 <h4>outputCoderMap</h4>
 <pre>java.util.Map&lt;K,V&gt; outputCoderMap</pre>
 </li>
 <li class="blockList">
 <h4>broadcastStateData</h4>
 <pre><a href="org/apache/beam/runners/spark/structuredstreaming/translation/helpers/SideInputBroadcast.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.helpers">SideInputBroadcast</a> broadcastStateData</pre>
 </li>
 <li class="blockList">
 <h4>doFnSchemaInformation</h4>
 <pre><a href="org/apache/beam/sdk/transforms/DoFnSchemaInformation.html" title="class in org.apache.beam.sdk.transforms">DoFnSchemaInformation</a> doFnSchemaInformation</pre>
 </li>
 <li class="blockListLast">
 <h4>sideInputMapping</h4>
 <pre>java.util.Map&lt;K,V&gt; sideInputMapping</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.translation.batch.ImpulseTranslatorBatch">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/translation/batch/ImpulseTranslatorBatch.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.batch">org.apache.beam.runners.spark.structuredstreaming.translation.batch.ImpulseTranslatorBatch</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.GroupAlsoByWindowViaOutputBufferFn">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/GroupAlsoByWindowViaOutputBufferFn.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions">org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.GroupAlsoByWindowViaOutputBufferFn</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>windowingStrategy</h4>
 <pre><a href="org/apache/beam/sdk/values/WindowingStrategy.html" title="class in org.apache.beam.sdk.values">WindowingStrategy</a>&lt;<a href="org/apache/beam/sdk/values/WindowingStrategy.html" title="type parameter in WindowingStrategy">T</a>,<a href="org/apache/beam/sdk/values/WindowingStrategy.html" title="type parameter in WindowingStrategy">W</a> extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>&gt; windowingStrategy</pre>
 </li>
 <li class="blockList">
 <h4>stateInternalsFactory</h4>
 <pre>org.apache.beam.runners.core.StateInternalsFactory&lt;K&gt; stateInternalsFactory</pre>
 </li>
 <li class="blockList">
 <h4>reduceFn</h4>
 <pre>org.apache.beam.runners.core.SystemReduceFn&lt;K,InputT,AccumT,OutputT,W extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>&gt; reduceFn</pre>
 </li>
 <li class="blockListLast">
 <h4>options</h4>
 <pre>org.apache.beam.runners.core.construction.SerializablePipelineOptions options</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.structuredstreaming.translation.helpers</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.DecodeUsingBeamCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.DecodeUsingBeamCoder.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.helpers">org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.DecodeUsingBeamCoder</a> extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>child</h4>
 <pre>org.apache.spark.sql.catalyst.expressions.Expression child</pre>
 </li>
 <li class="blockList">
 <h4>classTag</h4>
 <pre>scala.reflect.ClassTag&lt;T&gt; classTag</pre>
 </li>
 <li class="blockListLast">
 <h4>coder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; coder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.EncodeUsingBeamCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.EncodeUsingBeamCoder.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.helpers">org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.EncodeUsingBeamCoder</a> extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>child</h4>
 <pre>org.apache.spark.sql.catalyst.expressions.Expression child</pre>
 </li>
 <li class="blockListLast">
 <h4>coder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; coder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.translation.helpers.MultiOutputCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/translation/helpers/MultiOutputCoder.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.helpers">org.apache.beam.runners.spark.structuredstreaming.translation.helpers.MultiOutputCoder</a> extends <a href="org/apache/beam/sdk/coders/CustomCoder.html" title="class in org.apache.beam.sdk.coders">CustomCoder</a>&lt;scala.Tuple2&lt;<a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values">TupleTag</a>&lt;<a href="org/apache/beam/runners/spark/structuredstreaming/translation/helpers/MultiOutputCoder.html" title="type parameter in MultiOutputCoder">T</a>&gt;,org.apache.beam.sdk.util.WindowedValue&lt;<a href="org/apache/beam/runners/spark/structuredstreaming/translation/helpers/MultiOutputCoder.html" title="type parameter in MultiOutputCoder">T</a>&gt;&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>tupleTagCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; tupleTagCoder</pre>
 </li>
 <li class="blockList">
 <h4>coderMap</h4>
 <pre>java.util.Map&lt;K,V&gt; coderMap</pre>
 </li>
 <li class="blockListLast">
 <h4>windowCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; windowCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.structuredstreaming.translation.helpers.SideInputBroadcast">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/structuredstreaming/translation/helpers/SideInputBroadcast.html" title="class in org.apache.beam.runners.spark.structuredstreaming.translation.helpers">org.apache.beam.runners.spark.structuredstreaming.translation.helpers.SideInputBroadcast</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>bcast</h4>
 <pre>java.util.Map&lt;K,V&gt; bcast</pre>
 </li>
 <li class="blockListLast">
 <h4>coder</h4>
 <pre>java.util.Map&lt;K,V&gt; coder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.spark.util</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.spark.util.ByteArray">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/util/ByteArray.html" title="class in org.apache.beam.runners.spark.util">org.apache.beam.runners.spark.util.ByteArray</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>value</h4>
 <pre>byte[] value</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.util.GlobalWatermarkHolder.SparkWatermarks">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/util/GlobalWatermarkHolder.SparkWatermarks.html" title="class in org.apache.beam.runners.spark.util">org.apache.beam.runners.spark.util.GlobalWatermarkHolder.SparkWatermarks</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>lowWatermark</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a> lowWatermark</pre>
 </li>
 <li class="blockList">
 <h4>highWatermark</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a> highWatermark</pre>
 </li>
 <li class="blockListLast">
 <h4>synchronizedProcessingTime</h4>
 <pre><a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a> synchronizedProcessingTime</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.spark.util.SideInputBroadcast">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/spark/util/SideInputBroadcast.html" title="class in org.apache.beam.runners.spark.util">org.apache.beam.runners.spark.util.SideInputBroadcast</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>bcast</h4>
 <pre>org.apache.spark.broadcast.Broadcast&lt;T&gt; bcast</pre>
 </li>
 <li class="blockListLast">
 <h4>coder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; coder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.twister2</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.twister2.BeamBatchWorker">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/BeamBatchWorker.html" title="class in org.apache.beam.runners.twister2">org.apache.beam.runners.twister2.BeamBatchWorker</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>sideInputDataSets</h4>
 <pre>java.util.HashMap&lt;K,V&gt; sideInputDataSets</pre>
 </li>
 <li class="blockListLast">
 <h4>leaves</h4>
 <pre>java.util.Set&lt;E&gt; leaves</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.twister2.translation.wrappers</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translation.wrappers.Twister2BoundedSource">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translation/wrappers/Twister2BoundedSource.html" title="class in org.apache.beam.runners.twister2.translation.wrappers">org.apache.beam.runners.twister2.translation.wrappers.Twister2BoundedSource</a> extends edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc&lt;org.apache.beam.sdk.util.WindowedValue&lt;<a href="org/apache/beam/runners/twister2/translation/wrappers/Twister2BoundedSource.html" title="type parameter in Twister2BoundedSource">T</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>numPartitions</h4>
 <pre>int numPartitions</pre>
 </li>
 <li class="blockList">
 <h4>splitSize</h4>
 <pre>long splitSize</pre>
 </li>
 <li class="blockList">
 <h4>partitionedSources</h4>
 <pre>java.util.List&lt;E&gt; partitionedSources</pre>
 </li>
 <li class="blockList">
 <h4>localPartition</h4>
 <pre><a href="org/apache/beam/sdk/io/Source.html" title="class in org.apache.beam.sdk.io">Source</a>&lt;<a href="org/apache/beam/sdk/io/Source.html" title="type parameter in Source">T</a>&gt; localPartition</pre>
 </li>
 <li class="blockList">
 <h4>serializedOptions</h4>
 <pre>java.lang.String serializedOptions</pre>
 </li>
 <li class="blockList">
 <h4>isInitialized</h4>
 <pre>boolean isInitialized</pre>
 </li>
 <li class="blockListLast">
 <h4>sourceBytes</h4>
 <pre>byte[] sourceBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translation.wrappers.Twister2EmptySource">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translation/wrappers/Twister2EmptySource.html" title="class in org.apache.beam.runners.twister2.translation.wrappers">org.apache.beam.runners.twister2.translation.wrappers.Twister2EmptySource</a> extends edu.iu.dsc.tws.api.tset.fn.BaseSourceFunc&lt;org.apache.beam.sdk.util.WindowedValue&lt;<a href="org/apache/beam/runners/twister2/translation/wrappers/Twister2EmptySource.html" title="type parameter in Twister2EmptySource">T</a>&gt;&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.twister2.translators.functions</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.AssignWindowsFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/AssignWindowsFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.AssignWindowsFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>windowFnBytes</h4>
 <pre>byte[] windowFnBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.ByteToElemFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/ByteToElemFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.ByteToElemFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>wvCoderBytes</h4>
 <pre>byte[] wvCoderBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/ByteToWindowFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>keyCoderBytes</h4>
 <pre>byte[] keyCoderBytes</pre>
 </li>
 <li class="blockListLast">
 <h4>wvCoderBytes</h4>
 <pre>byte[] wvCoderBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunctionPrimitive">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/ByteToWindowFunctionPrimitive.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunctionPrimitive</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>keyCoderBytes</h4>
 <pre>byte[] keyCoderBytes</pre>
 </li>
 <li class="blockListLast">
 <h4>wvCoderBytes</h4>
 <pre>byte[] wvCoderBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.DoFnFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/DoFnFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.DoFnFunction</a> extends java.lang.Object implements Serializable</h3>
 <dl class="nameValue">
 <dt>serialVersionUID:</dt>
 <dd>-5701440128544343353L</dd>
 </dl>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>stepcontext</h4>
 <pre>org.apache.beam.runners.core.StepContext stepcontext</pre>
 </li>
 <li class="blockList">
 <h4>doFnwithExBytes</h4>
 <pre>byte[] doFnwithExBytes</pre>
 </li>
 <li class="blockList">
 <h4>coderBytes</h4>
 <pre>byte[] coderBytes</pre>
 </li>
 <li class="blockList">
 <h4>outputCodersBytes</h4>
 <pre>java.util.Map&lt;K,V&gt; outputCodersBytes</pre>
 </li>
 <li class="blockList">
 <h4>windowBytes</h4>
 <pre>byte[] windowBytes</pre>
 </li>
 <li class="blockList">
 <h4>sideInputBytes</h4>
 <pre>java.util.Map&lt;K,V&gt; sideInputBytes</pre>
 </li>
 <li class="blockList">
 <h4>serializedOptions</h4>
 <pre>java.lang.String serializedOptions</pre>
 </li>
 <li class="blockList">
 <h4>serializedSideOutputs</h4>
 <pre>java.util.List&lt;E&gt; serializedSideOutputs</pre>
 </li>
 <li class="blockListLast">
 <h4>serializedOutputMap</h4>
 <pre>java.util.Map&lt;K,V&gt; serializedOutputMap</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.ElemToBytesFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/ElemToBytesFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.ElemToBytesFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>wvCoderBytes</h4>
 <pre>byte[] wvCoderBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.GroupByWindowFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/GroupByWindowFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.GroupByWindowFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>reduceFn</h4>
 <pre>org.apache.beam.runners.core.SystemReduceFn&lt;K,InputT,AccumT,OutputT,W extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>&gt; reduceFn</pre>
 </li>
 <li class="blockListLast">
 <h4>windowBytes</h4>
 <pre>byte[] windowBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.ImpulseSource">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/ImpulseSource.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.ImpulseSource</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>impulseEmitted</h4>
 <pre>boolean impulseEmitted</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.MapToTupleFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/MapToTupleFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.MapToTupleFunction</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>keyCoderBytes</h4>
 <pre>byte[] keyCoderBytes</pre>
 </li>
 <li class="blockListLast">
 <h4>wvCoderBytes</h4>
 <pre>byte[] wvCoderBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.OutputTagFilter">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/OutputTagFilter.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.OutputTagFilter</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>tag</h4>
 <pre>int tag</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.Twister2SinkFunction">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/Twister2SinkFunction.html" title="class in org.apache.beam.runners.twister2.translators.functions">org.apache.beam.runners.twister2.translators.functions.Twister2SinkFunction</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.twister2.translators.functions.internal</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.twister2.translators.functions.internal.SystemReduceFnBuffering">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/translators/functions/internal/SystemReduceFnBuffering.html" title="class in org.apache.beam.runners.twister2.translators.functions.internal">org.apache.beam.runners.twister2.translators.functions.internal.SystemReduceFnBuffering</a> extends org.apache.beam.runners.core.SystemReduceFn&lt;<a href="org/apache/beam/runners/twister2/translators/functions/internal/SystemReduceFnBuffering.html" title="type parameter in SystemReduceFnBuffering">K</a>,<a href="org/apache/beam/runners/twister2/translators/functions/internal/SystemReduceFnBuffering.html" title="type parameter in SystemReduceFnBuffering">T</a>,java.lang.Iterable&lt;<a href="org/apache/beam/runners/twister2/translators/functions/internal/SystemReduceFnBuffering.html" title="type parameter in SystemReduceFnBuffering">T</a>&gt;,java.lang.Iterable&lt;<a href="org/apache/beam/runners/twister2/translators/functions/internal/SystemReduceFnBuffering.html" title="type parameter in SystemReduceFnBuffering">T</a>&gt;,<a href="org/apache/beam/runners/twister2/translators/functions/internal/SystemReduceFnBuffering.html" title="type parameter in SystemReduceFnBuffering">W</a> extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>readResolve</h4>
 <pre>protected&nbsp;java.lang.Object&nbsp;readResolve()
                                 throws java.io.ObjectStreamException</pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
 <dd><code>java.io.ObjectStreamException</code></dd>
 </dl>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>coderBytes</h4>
 <pre>byte[] coderBytes</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.runners.twister2.utils</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.runners.twister2.utils.NoOpStepContext">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/runners/twister2/utils/NoOpStepContext.html" title="class in org.apache.beam.runners.twister2.utils">org.apache.beam.runners.twister2.utils.NoOpStepContext</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.Pipeline.PipelineExecutionException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/Pipeline.PipelineExecutionException.html" title="class in org.apache.beam.sdk">org.apache.beam.sdk.Pipeline.PipelineExecutionException</a> extends java.lang.RuntimeException implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.coders</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.coders.AtomicCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.AtomicCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="type parameter in AtomicCoder">T</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.AvroCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/AvroCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.AvroCoder</a> extends <a href="org/apache/beam/sdk/coders/CustomCoder.html" title="class in org.apache.beam.sdk.coders">CustomCoder</a>&lt;<a href="org/apache/beam/sdk/coders/AvroCoder.html" title="type parameter in AvroCoder">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>type</h4>
 <pre>java.lang.Class&lt;T&gt; type</pre>
 </li>
 <li class="blockList">
 <h4>useReflectApi</h4>
 <pre>boolean useReflectApi</pre>
 </li>
 <li class="blockList">
 <h4>schemaSupplier</h4>
 <pre>org.apache.beam.sdk.coders.AvroCoder.SerializableSchemaSupplier schemaSupplier</pre>
 </li>
 <li class="blockList">
 <h4>typeDescriptor</h4>
 <pre><a href="org/apache/beam/sdk/values/TypeDescriptor.html" title="class in org.apache.beam.sdk.values">TypeDescriptor</a>&lt;<a href="org/apache/beam/sdk/values/TypeDescriptor.html" title="type parameter in TypeDescriptor">T</a>&gt; typeDescriptor</pre>
 </li>
 <li class="blockList">
 <h4>nonDeterministicReasons</h4>
 <pre>java.util.List&lt;E&gt; nonDeterministicReasons</pre>
 </li>
 <li class="blockList">
 <h4>decoder</h4>
 <pre>org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal&lt;T&gt; decoder</pre>
 </li>
 <li class="blockList">
 <h4>encoder</h4>
 <pre>org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal&lt;T&gt; encoder</pre>
 </li>
 <li class="blockList">
 <h4>writer</h4>
 <pre>org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal&lt;T&gt; writer</pre>
 </li>
 <li class="blockList">
 <h4>reader</h4>
 <pre>org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal&lt;T&gt; reader</pre>
 </li>
 <li class="blockListLast">
 <h4>reflectData</h4>
 <pre>org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Supplier&lt;T&gt; reflectData</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.AvroGenericCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/AvroGenericCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.AvroGenericCoder</a> extends <a href="org/apache/beam/sdk/coders/AvroCoder.html" title="class in org.apache.beam.sdk.coders">AvroCoder</a>&lt;<a href="https://static.javadoc.io/org.apache.avro/avro/1.8.2/org/apache/avro/generic/GenericRecord.html?is-external=true" title="class or interface in org.apache.avro.generic">GenericRecord</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.BigDecimalCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/BigDecimalCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.BigDecimalCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.math.BigDecimal&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.BigEndianIntegerCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/BigEndianIntegerCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.BigEndianIntegerCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Integer&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.BigEndianLongCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/BigEndianLongCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.BigEndianLongCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Long&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.BigEndianShortCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/BigEndianShortCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.BigEndianShortCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Short&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.BigIntegerCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/BigIntegerCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.BigIntegerCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.math.BigInteger&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.BitSetCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/BitSetCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.BitSetCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.util.BitSet&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.BooleanCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/BooleanCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.BooleanCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Boolean&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.ByteArrayCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/ByteArrayCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.ByteArrayCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;byte[]&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.ByteCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/ByteCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.ByteCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Byte&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.CannotProvideCoderException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/CannotProvideCoderException.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.CannotProvideCoderException</a> extends java.lang.Exception implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>reason</h4>
 <pre><a href="org/apache/beam/sdk/coders/CannotProvideCoderException.ReasonCode.html" title="enum in org.apache.beam.sdk.coders">CannotProvideCoderException.ReasonCode</a> reason</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.Coder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.Coder</a> extends java.lang.Object implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.Coder.NonDeterministicException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/Coder.NonDeterministicException.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.Coder.NonDeterministicException</a> extends java.lang.Exception implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>coder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; coder</pre>
 </li>
 <li class="blockListLast">
 <h4>reasons</h4>
 <pre>java.util.List&lt;E&gt; reasons</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.CoderException">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/CoderException.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.CoderException</a> extends java.io.IOException implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.CollectionCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/CollectionCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.CollectionCoder</a> extends <a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="class in org.apache.beam.sdk.coders">IterableLikeCoder</a>&lt;<a href="org/apache/beam/sdk/coders/CollectionCoder.html" title="type parameter in CollectionCoder">T</a>,java.util.Collection&lt;<a href="org/apache/beam/sdk/coders/CollectionCoder.html" title="type parameter in CollectionCoder">T</a>&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.CustomCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/CustomCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.CustomCoder</a> extends <a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/CustomCoder.html" title="type parameter in CustomCoder">T</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.DelegateCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/DelegateCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.DelegateCoder</a> extends <a href="org/apache/beam/sdk/coders/CustomCoder.html" title="class in org.apache.beam.sdk.coders">CustomCoder</a>&lt;<a href="org/apache/beam/sdk/coders/DelegateCoder.html" title="type parameter in DelegateCoder">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>coder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; coder</pre>
 </li>
 <li class="blockList">
 <h4>toFn</h4>
 <pre><a href="org/apache/beam/sdk/coders/DelegateCoder.CodingFunction.html" title="interface in org.apache.beam.sdk.coders">DelegateCoder.CodingFunction</a>&lt;<a href="org/apache/beam/sdk/coders/DelegateCoder.CodingFunction.html" title="type parameter in DelegateCoder.CodingFunction">InputT</a>,<a href="org/apache/beam/sdk/coders/DelegateCoder.CodingFunction.html" title="type parameter in DelegateCoder.CodingFunction">OutputT</a>&gt; toFn</pre>
 </li>
 <li class="blockList">
 <h4>fromFn</h4>
 <pre><a href="org/apache/beam/sdk/coders/DelegateCoder.CodingFunction.html" title="interface in org.apache.beam.sdk.coders">DelegateCoder.CodingFunction</a>&lt;<a href="org/apache/beam/sdk/coders/DelegateCoder.CodingFunction.html" title="type parameter in DelegateCoder.CodingFunction">InputT</a>,<a href="org/apache/beam/sdk/coders/DelegateCoder.CodingFunction.html" title="type parameter in DelegateCoder.CodingFunction">OutputT</a>&gt; fromFn</pre>
 </li>
 <li class="blockListLast">
 <h4>typeDescriptor</h4>
 <pre><a href="org/apache/beam/sdk/values/TypeDescriptor.html" title="class in org.apache.beam.sdk.values">TypeDescriptor</a>&lt;<a href="org/apache/beam/sdk/values/TypeDescriptor.html" title="type parameter in TypeDescriptor">T</a>&gt; typeDescriptor</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.DequeCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/DequeCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.DequeCoder</a> extends <a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="class in org.apache.beam.sdk.coders">IterableLikeCoder</a>&lt;<a href="org/apache/beam/sdk/coders/DequeCoder.html" title="type parameter in DequeCoder">T</a>,java.util.Deque&lt;<a href="org/apache/beam/sdk/coders/DequeCoder.html" title="type parameter in DequeCoder">T</a>&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.DoubleCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/DoubleCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.DoubleCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Double&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.DurationCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/DurationCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.DurationCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;<a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/ReadableDuration.html?is-external=true" title="class or interface in org.joda.time">ReadableDuration</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.FloatCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/FloatCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.FloatCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Float&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.InstantCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/InstantCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.InstantCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;<a href="https://static.javadoc.io/joda-time/joda-time/2.10.10/org/joda/time/Instant.html?is-external=true" title="class or interface in org.joda.time">Instant</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.IterableCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/IterableCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.IterableCoder</a> extends <a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="class in org.apache.beam.sdk.coders">IterableLikeCoder</a>&lt;<a href="org/apache/beam/sdk/coders/IterableCoder.html" title="type parameter in IterableCoder">T</a>,java.lang.Iterable&lt;<a href="org/apache/beam/sdk/coders/IterableCoder.html" title="type parameter in IterableCoder">T</a>&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.IterableLikeCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.IterableLikeCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="type parameter in IterableLikeCoder">IterableT</a> extends java.lang.Iterable&lt;<a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="type parameter in IterableLikeCoder">T</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>elementCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; elementCoder</pre>
 </li>
 <li class="blockListLast">
 <h4>iterableName</h4>
 <pre>java.lang.String iterableName</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.KvCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/KvCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.KvCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/coders/KvCoder.html" title="type parameter in KvCoder">K</a>,<a href="org/apache/beam/sdk/coders/KvCoder.html" title="type parameter in KvCoder">V</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>keyCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; keyCoder</pre>
 </li>
 <li class="blockListLast">
 <h4>valueCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; valueCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.LengthPrefixCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/LengthPrefixCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.LengthPrefixCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/coders/LengthPrefixCoder.html" title="type parameter in LengthPrefixCoder">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>valueCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; valueCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.ListCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/ListCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.ListCoder</a> extends <a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="class in org.apache.beam.sdk.coders">IterableLikeCoder</a>&lt;<a href="org/apache/beam/sdk/coders/ListCoder.html" title="type parameter in ListCoder">T</a>,java.util.List&lt;<a href="org/apache/beam/sdk/coders/ListCoder.html" title="type parameter in ListCoder">T</a>&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.MapCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/MapCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.MapCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;java.util.Map&lt;<a href="org/apache/beam/sdk/coders/MapCoder.html" title="type parameter in MapCoder">K</a>,<a href="org/apache/beam/sdk/coders/MapCoder.html" title="type parameter in MapCoder">V</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>keyCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; keyCoder</pre>
 </li>
 <li class="blockListLast">
 <h4>valueCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; valueCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.NullableCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/NullableCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.NullableCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/coders/NullableCoder.html" title="type parameter in NullableCoder">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>valueCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; valueCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.RowCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/RowCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.RowCoder</a> extends <a href="org/apache/beam/sdk/schemas/SchemaCoder.html" title="class in org.apache.beam.sdk.schemas">SchemaCoder</a>&lt;<a href="org/apache/beam/sdk/values/Row.html" title="class in org.apache.beam.sdk.values">Row</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.SerializableCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/SerializableCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.SerializableCoder</a> extends <a href="org/apache/beam/sdk/coders/CustomCoder.html" title="class in org.apache.beam.sdk.coders">CustomCoder</a>&lt;<a href="org/apache/beam/sdk/coders/SerializableCoder.html" title="type parameter in SerializableCoder">T</a> extends java.io.Serializable&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>type</h4>
 <pre>java.lang.Class&lt;T&gt; type</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.SetCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/SetCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.SetCoder</a> extends <a href="org/apache/beam/sdk/coders/IterableLikeCoder.html" title="class in org.apache.beam.sdk.coders">IterableLikeCoder</a>&lt;<a href="org/apache/beam/sdk/coders/SetCoder.html" title="type parameter in SetCoder">T</a>,java.util.Set&lt;<a href="org/apache/beam/sdk/coders/SetCoder.html" title="type parameter in SetCoder">T</a>&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.ShardedKeyCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/ShardedKeyCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.ShardedKeyCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/values/ShardedKey.html" title="class in org.apache.beam.sdk.values">ShardedKey</a>&lt;<a href="org/apache/beam/sdk/coders/ShardedKeyCoder.html" title="type parameter in ShardedKeyCoder">KeyT</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>keyCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; keyCoder</pre>
 </li>
 <li class="blockListLast">
 <h4>shardNumberCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/VarIntCoder.html" title="class in org.apache.beam.sdk.coders">VarIntCoder</a> shardNumberCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.SnappyCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/SnappyCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.SnappyCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/coders/SnappyCoder.html" title="type parameter in SnappyCoder">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>innerCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; innerCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.StringDelegateCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/StringDelegateCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.StringDelegateCoder</a> extends <a href="org/apache/beam/sdk/coders/CustomCoder.html" title="class in org.apache.beam.sdk.coders">CustomCoder</a>&lt;<a href="org/apache/beam/sdk/coders/StringDelegateCoder.html" title="type parameter in StringDelegateCoder">T</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>delegateCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/DelegateCoder.html" title="class in org.apache.beam.sdk.coders">DelegateCoder</a>&lt;<a href="org/apache/beam/sdk/coders/DelegateCoder.html" title="type parameter in DelegateCoder">T</a>,<a href="org/apache/beam/sdk/coders/DelegateCoder.html" title="type parameter in DelegateCoder">IntermediateT</a>&gt; delegateCoder</pre>
 </li>
 <li class="blockListLast">
 <h4>clazz</h4>
 <pre>java.lang.Class&lt;T&gt; clazz</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.StringUtf8Coder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/StringUtf8Coder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.StringUtf8Coder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.String&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.StructuredCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.StructuredCoder</a> extends <a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="type parameter in StructuredCoder">T</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.TextualIntegerCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/TextualIntegerCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.TextualIntegerCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Integer&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.TimestampPrefixingWindowCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/TimestampPrefixingWindowCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.TimestampPrefixingWindowCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;<a href="org/apache/beam/sdk/coders/TimestampPrefixingWindowCoder.html" title="type parameter in TimestampPrefixingWindowCoder">T</a> extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>windowCoder</h4>
 <pre><a href="org/apache/beam/sdk/coders/Coder.html" title="class in org.apache.beam.sdk.coders">Coder</a>&lt;<a href="org/apache/beam/sdk/coders/Coder.html" title="type parameter in Coder">T</a>&gt; windowCoder</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.VarIntCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/VarIntCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.VarIntCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Integer&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.VarLongCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/VarLongCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.VarLongCoder</a> extends <a href="org/apache/beam/sdk/coders/StructuredCoder.html" title="class in org.apache.beam.sdk.coders">StructuredCoder</a>&lt;java.lang.Long&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.coders.VoidCoder">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/coders/VoidCoder.html" title="class in org.apache.beam.sdk.coders">org.apache.beam.sdk.coders.VoidCoder</a> extends <a href="org/apache/beam/sdk/coders/AtomicCoder.html" title="class in org.apache.beam.sdk.coders">AtomicCoder</a>&lt;java.lang.Void&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.extensions.gcp.options</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/gcp/options/GoogleApiDebugOptions.GoogleApiTracer.html" title="class in org.apache.beam.sdk.extensions.gcp.options">org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer</a> extends java.util.HashMap&lt;java.lang.String,java.lang.String&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.extensions.gcp.storage</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.gcp.storage.GcsResourceId">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/gcp/storage/GcsResourceId.html" title="class in org.apache.beam.sdk.extensions.gcp.storage">org.apache.beam.sdk.extensions.gcp.storage.GcsResourceId</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>gcsPath</h4>
 <pre><a href="org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.html" title="class in org.apache.beam.sdk.extensions.gcp.util.gcsfs">GcsPath</a> gcsPath</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.extensions.gcp.util</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.gcp.util.CustomHttpErrors.MatcherAndError">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/gcp/util/CustomHttpErrors.MatcherAndError.html" title="class in org.apache.beam.sdk.extensions.gcp.util">org.apache.beam.sdk.extensions.gcp.util.CustomHttpErrors.MatcherAndError</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.extensions.gcp.util.gcsfs</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.gcp.util.gcsfs.GcsPath">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.html" title="class in org.apache.beam.sdk.extensions.gcp.util.gcsfs">org.apache.beam.sdk.extensions.gcp.util.gcsfs.GcsPath</a> extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>bucket</h4>
 <pre>java.lang.String bucket</pre>
 </li>
 <li class="blockListLast">
 <h4>object</h4>
 <pre>java.lang.String object</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.extensions.jackson</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.jackson.AsJsons">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/jackson/AsJsons.html" title="class in org.apache.beam.sdk.extensions.jackson">org.apache.beam.sdk.extensions.jackson.AsJsons</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/extensions/jackson/AsJsons.html" title="type parameter in AsJsons">InputT</a>&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.lang.String&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>inputClass</h4>
 <pre>java.lang.Class&lt;T&gt; inputClass</pre>
 </li>
 <li class="blockListLast">
 <h4>customMapper</h4>
 <pre><a href="https://static.javadoc.io/com.fasterxml.jackson.core/jackson-databind/2.13.0/com/fasterxml/jackson/databind/ObjectMapper.html?is-external=true" title="class or interface in com.fasterxml.jackson.databind">ObjectMapper</a> customMapper</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.jackson.AsJsons.AsJsonsWithFailures">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/jackson/AsJsons.AsJsonsWithFailures.html" title="class in org.apache.beam.sdk.extensions.jackson">org.apache.beam.sdk.extensions.jackson.AsJsons.AsJsonsWithFailures</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/extensions/jackson/AsJsons.html" title="type parameter in AsJsons">InputT</a>&gt;,<a href="org/apache/beam/sdk/transforms/WithFailures.Result.html" title="class in org.apache.beam.sdk.transforms">WithFailures.Result</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.lang.String&gt;,<a href="org/apache/beam/sdk/extensions/jackson/AsJsons.AsJsonsWithFailures.html" title="type parameter in AsJsons.AsJsonsWithFailures">FailureT</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>exceptionHandler</h4>
 <pre><a href="org/apache/beam/sdk/transforms/InferableFunction.html" title="class in org.apache.beam.sdk.transforms">InferableFunction</a>&lt;<a href="org/apache/beam/sdk/transforms/InferableFunction.html" title="type parameter in InferableFunction">InputT</a>,<a href="org/apache/beam/sdk/transforms/InferableFunction.html" title="type parameter in InferableFunction">OutputT</a>&gt; exceptionHandler</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.jackson.ParseJsons">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/jackson/ParseJsons.html" title="class in org.apache.beam.sdk.extensions.jackson">org.apache.beam.sdk.extensions.jackson.ParseJsons</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.lang.String&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/extensions/jackson/ParseJsons.html" title="type parameter in ParseJsons">OutputT</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>outputClass</h4>
 <pre>java.lang.Class&lt;T&gt; outputClass</pre>
 </li>
 <li class="blockListLast">
 <h4>customMapper</h4>
 <pre><a href="https://static.javadoc.io/com.fasterxml.jackson.core/jackson-databind/2.13.0/com/fasterxml/jackson/databind/ObjectMapper.html?is-external=true" title="class or interface in com.fasterxml.jackson.databind">ObjectMapper</a> customMapper</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.jackson.ParseJsons.ParseJsonsWithFailures">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/jackson/ParseJsons.ParseJsonsWithFailures.html" title="class in org.apache.beam.sdk.extensions.jackson">org.apache.beam.sdk.extensions.jackson.ParseJsons.ParseJsonsWithFailures</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.lang.String&gt;,<a href="org/apache/beam/sdk/transforms/WithFailures.Result.html" title="class in org.apache.beam.sdk.transforms">WithFailures.Result</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/extensions/jackson/ParseJsons.html" title="type parameter in ParseJsons">OutputT</a>&gt;,<a href="org/apache/beam/sdk/extensions/jackson/ParseJsons.ParseJsonsWithFailures.html" title="type parameter in ParseJsons.ParseJsonsWithFailures">FailureT</a>&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>exceptionHandler</h4>
 <pre><a href="org/apache/beam/sdk/transforms/InferableFunction.html" title="class in org.apache.beam.sdk.transforms">InferableFunction</a>&lt;<a href="org/apache/beam/sdk/transforms/InferableFunction.html" title="type parameter in InferableFunction">InputT</a>,<a href="org/apache/beam/sdk/transforms/InferableFunction.html" title="type parameter in InferableFunction">OutputT</a>&gt; exceptionHandler</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.extensions.joinlibrary</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.joinlibrary.Join.FullOuterJoin">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/joinlibrary/Join.FullOuterJoin.html" title="class in org.apache.beam.sdk.extensions.joinlibrary">org.apache.beam.sdk.extensions.joinlibrary.Join.FullOuterJoin</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.FullOuterJoin.html" title="type parameter in Join.FullOuterJoin">K</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.FullOuterJoin.html" title="type parameter in Join.FullOuterJoin">V1</a>&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.FullOuterJoin.html" title="type parameter in Join.FullOuterJoin">K</a>,<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.FullOuterJoin.html" title="type parameter in Join.FullOuterJoin">V1</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.FullOuterJoin.html" title="type parameter in Join.FullOuterJoin">V2</a>&gt;&gt;&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>leftNullValue</h4>
 <pre>java.lang.Object leftNullValue</pre>
 </li>
 <li class="blockListLast">
 <h4>rightNullValue</h4>
 <pre>java.lang.Object rightNullValue</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.joinlibrary.Join.InnerJoin">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/joinlibrary/Join.InnerJoin.html" title="class in org.apache.beam.sdk.extensions.joinlibrary">org.apache.beam.sdk.extensions.joinlibrary.Join.InnerJoin</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.InnerJoin.html" title="type parameter in Join.InnerJoin">K</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.InnerJoin.html" title="type parameter in Join.InnerJoin">V1</a>&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.InnerJoin.html" title="type parameter in Join.InnerJoin">K</a>,<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.InnerJoin.html" title="type parameter in Join.InnerJoin">V1</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.InnerJoin.html" title="type parameter in Join.InnerJoin">V2</a>&gt;&gt;&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.joinlibrary.Join.LeftOuterJoin">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/joinlibrary/Join.LeftOuterJoin.html" title="class in org.apache.beam.sdk.extensions.joinlibrary">org.apache.beam.sdk.extensions.joinlibrary.Join.LeftOuterJoin</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.LeftOuterJoin.html" title="type parameter in Join.LeftOuterJoin">K</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.LeftOuterJoin.html" title="type parameter in Join.LeftOuterJoin">V1</a>&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.LeftOuterJoin.html" title="type parameter in Join.LeftOuterJoin">K</a>,<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.LeftOuterJoin.html" title="type parameter in Join.LeftOuterJoin">V1</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.LeftOuterJoin.html" title="type parameter in Join.LeftOuterJoin">V2</a>&gt;&gt;&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>nullValue</h4>
 <pre>java.lang.Object nullValue</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.joinlibrary.Join.RightOuterJoin">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/joinlibrary/Join.RightOuterJoin.html" title="class in org.apache.beam.sdk.extensions.joinlibrary">org.apache.beam.sdk.extensions.joinlibrary.Join.RightOuterJoin</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.RightOuterJoin.html" title="type parameter in Join.RightOuterJoin">K</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.RightOuterJoin.html" title="type parameter in Join.RightOuterJoin">V1</a>&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.RightOuterJoin.html" title="type parameter in Join.RightOuterJoin">K</a>,<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.RightOuterJoin.html" title="type parameter in Join.RightOuterJoin">V1</a>,<a href="org/apache/beam/sdk/extensions/joinlibrary/Join.RightOuterJoin.html" title="type parameter in Join.RightOuterJoin">V2</a>&gt;&gt;&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>nullValue</h4>
 <pre>java.lang.Object nullValue</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.beam.sdk.extensions.ml</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.AnnotateImages.PerformImageAnnotation">
 <!--   -->
 </a>
 <h3>Class org.apache.beam.sdk.extensions.ml.AnnotateImages.PerformImageAnnotation extends <a href="org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.Integer,java.lang.Iterable&lt;com.google.cloud.vision.v1.AnnotateImageRequest&gt;&gt;,java.util.List&lt;com.google.cloud.vision.v1.AnnotateImageResponse&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.AnnotateText">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/AnnotateText.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.AnnotateText</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;com.google.cloud.language.v1.Document&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;com.google.cloud.language.v1.AnnotateTextResponse&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromBytes">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/CloudVision.AnnotateImagesFromBytes.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromBytes</a> extends org.apache.beam.sdk.extensions.ml.AnnotateImages&lt;<a href="https://static.javadoc.io/com.google.protobuf/protobuf-java/3.19.3/com/google/protobuf/ByteString.html?is-external=true" title="class or interface in com.google.protobuf">ByteString</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromBytesWithContext">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/CloudVision.AnnotateImagesFromBytesWithContext.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromBytesWithContext</a> extends org.apache.beam.sdk.extensions.ml.AnnotateImages&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="https://static.javadoc.io/com.google.protobuf/protobuf-java/3.19.3/com/google/protobuf/ByteString.html?is-external=true" title="class or interface in com.google.protobuf">ByteString</a>,com.google.cloud.vision.v1.ImageContext&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromGcsUri">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/CloudVision.AnnotateImagesFromGcsUri.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromGcsUri</a> extends org.apache.beam.sdk.extensions.ml.AnnotateImages&lt;java.lang.String&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromGcsUriWithContext">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/CloudVision.AnnotateImagesFromGcsUriWithContext.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromGcsUriWithContext</a> extends org.apache.beam.sdk.extensions.ml.AnnotateImages&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,com.google.cloud.vision.v1.ImageContext&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.DLPDeidentifyText">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/DLPDeidentifyText.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.DLPDeidentifyText</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,java.lang.String&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,com.google.privacy.dlp.v2.DeidentifyContentResponse&gt;&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.DLPInspectText">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/DLPInspectText.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.DLPInspectText</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,java.lang.String&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,com.google.privacy.dlp.v2.InspectContentResponse&gt;&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.DLPReidentifyText">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/DLPReidentifyText.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.DLPReidentifyText</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,java.lang.String&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,com.google.privacy.dlp.v2.ReidentifyContentResponse&gt;&gt;&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.RecommendationAICreateCatalogItem">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/RecommendationAICreateCatalogItem.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.RecommendationAICreateCatalogItem</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;com.google.api.client.json.GenericJson&gt;,<a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values">PCollectionTuple</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.RecommendationAIImportCatalogItems">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/RecommendationAIImportCatalogItems.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.RecommendationAIImportCatalogItems</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,com.google.api.client.json.GenericJson&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values">PCollectionTuple</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.RecommendationAIImportUserEvents">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/RecommendationAIImportUserEvents.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.RecommendationAIImportUserEvents</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;java.lang.String,com.google.api.client.json.GenericJson&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values">PCollectionTuple</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.RecommendationAIPredict">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/RecommendationAIPredict.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.RecommendationAIPredict</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;com.google.api.client.json.GenericJson&gt;,<a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values">PCollectionTuple</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.RecommendationAIWriteUserEvent">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/RecommendationAIWriteUserEvent.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.RecommendationAIWriteUserEvent</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;com.google.api.client.json.GenericJson&gt;,<a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values">PCollectionTuple</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromBytes">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/VideoIntelligence.AnnotateVideoFromBytes.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromBytes</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="https://static.javadoc.io/com.google.protobuf/protobuf-java/3.19.3/com/google/protobuf/ByteString.html?is-external=true" title="class or interface in com.google.protobuf">ByteString</a>&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.util.List&lt;com.google.cloud.videointelligence.v1.VideoAnnotationResults&gt;&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockList">
 <h4>contextSideInput</h4>
 <pre><a href="org/apache/beam/sdk/values/PCollectionView.html" title="interface in org.apache.beam.sdk.values">PCollectionView</a>&lt;<a href="org/apache/beam/sdk/values/PCollectionView.html" title="type parameter in PCollectionView">T</a>&gt; contextSideInput</pre>
 </li>
 <li class="blockListLast">
 <h4>featureList</h4>
 <pre>java.util.List&lt;E&gt; featureList</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromBytesWithContext">
 <!--   -->
 </a>
 <h3>Class <a href="org/apache/beam/sdk/extensions/ml/VideoIntelligence.AnnotateVideoFromBytesWithContext.html" title="class in org.apache.beam.sdk.extensions.ml">org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromBytesWithContext</a> extends <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a>&lt;<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;<a href="org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values">KV</a>&lt;<a href="https://static.javadoc.io/com.google.protobuf/protobuf-java/3.19.3/com/google/protobuf/ByteString.html?is-external=true" title="class or interface in com.google.protobuf">ByteString</a>,com.google.cloud.videointelligence.v1.VideoContext&gt;&gt;,<a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values">PCollection</a>&lt;java.util.List&lt;com.google.cloud.videointelligence.v1.VideoAnnotationResults&gt;&gt;&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialized Fields</h3>
 <ul class="blockList">
 <li class="blockListLast">
 <h4>featureList</h4>
 <pre>java.util.List&lt;E&gt; featureList</pre>
 </li>
 </ul>
 </li>
 </ul>
 </li>
 <li class="blockList"><a name="org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromUri">
 <!--   -->
</