| <!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 (1.8.0_181-google-v7) on Mon Jan 27 16:42:36 PST 2020 --> |
| <title>org.apache.beam.sdk.transforms (Apache Beam 2.20.0-SNAPSHOT)</title> |
| <meta name="date" content="2020-01-27"> |
| <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="org.apache.beam.sdk.transforms (Apache Beam 2.20.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 class="navBarCell1Rev">Package</li> |
| <li>Class</li> |
| <li><a href="package-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><a href="../../../../../org/apache/beam/sdk/testing/package-summary.html">Prev Package</a></li> |
| <li><a href="../../../../../org/apache/beam/sdk/transforms/display/package-summary.html">Next Package</a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../../../index.html?org/apache/beam/sdk/transforms/package-summary.html" target="_top">Frames</a></li> |
| <li><a href="package-summary.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_top"> |
| <li><a href="../../../../../allclasses-noframe.html">All 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"> |
| <p>@DefaultAnnotation(value=edu.umd.cs.findbugs.annotations.NonNull.class) |
| </p> |
| <h1 title="Package" class="title">Package org.apache.beam.sdk.transforms</h1> |
| <div class="docSummary"> |
| <div class="block">Defines <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a>s for transforming data in a pipeline.</div> |
| </div> |
| <p>See: <a href="#package.description">Description</a></p> |
| </div> |
| <div class="contentContainer"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Interface Summary table, listing interfaces, and an explanation"> |
| <caption><span>Interface Summary</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Interface</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tbody> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.Accumulator.html" title="interface in org.apache.beam.sdk.transforms">Combine.AccumulatingCombineFn.Accumulator</a><InputT,AccumT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">The type of mutable accumulator values used by this <code>AccumulatingCombineFn</code>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineFnBase.GlobalCombineFn.html" title="interface in org.apache.beam.sdk.transforms">CombineFnBase.GlobalCombineFn</a><InputT,AccumT,OutputT></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineWithContext.RequiresContextInternal.html" title="interface in org.apache.beam.sdk.transforms">CombineWithContext.RequiresContextInternal</a></td> |
| <td class="colLast"> |
| <div class="block">An internal interface for signaling that a <code>GloballyCombineFn</code> or a <code>PerKeyCombineFn</code> needs to access <code>CombineWithContext.Context</code>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Contextful.Fn.html" title="interface in org.apache.beam.sdk.transforms">Contextful.Fn</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A function from an input to an output that may additionally access <a href="../../../../../org/apache/beam/sdk/transforms/Contextful.Fn.Context.html" title="class in org.apache.beam.sdk.transforms"><code>Contextful.Fn.Context</code></a> when |
| computing the result.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.BundleFinalizer.html" title="interface in org.apache.beam.sdk.transforms">DoFn.BundleFinalizer</a></td> |
| <td class="colLast"> |
| <div class="block">A parameter that is accessible during <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.StartBundle.html" title="annotation in org.apache.beam.sdk.transforms"><code>@StartBundle</code></a>, <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessElement.html" title="annotation in org.apache.beam.sdk.transforms"><code>@ProcessElement</code></a> and <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.FinishBundle.html" title="annotation in org.apache.beam.sdk.transforms"><code>@FinishBundle</code></a> that allows the caller |
| to register a callback that will be invoked after the bundle has been successfully completed |
| and the runner has commit the output.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.BundleFinalizer.Callback.html" title="interface in org.apache.beam.sdk.transforms">DoFn.BundleFinalizer.Callback</a></td> |
| <td class="colLast"> |
| <div class="block">An instance of a function that will be invoked after bundle finalization.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.MultiOutputReceiver.html" title="interface in org.apache.beam.sdk.transforms">DoFn.MultiOutputReceiver</a></td> |
| <td class="colLast"> |
| <div class="block">Receives tagged output for a multi-output function.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.OutputReceiver.html" title="interface in org.apache.beam.sdk.transforms">DoFn.OutputReceiver</a><T></td> |
| <td class="colLast"> |
| <div class="block">Receives values of the given type.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ExternalTransformBuilder.html" title="interface in org.apache.beam.sdk.transforms">ExternalTransformBuilder</a><ConfigT,InputT extends <a href="../../../../../org/apache/beam/sdk/values/PInput.html" title="interface in org.apache.beam.sdk.values">PInput</a>,OutputT extends <a href="../../../../../org/apache/beam/sdk/values/POutput.html" title="interface in org.apache.beam.sdk.values">POutput</a>></td> |
| <td class="colLast"> |
| <div class="block">An interface for building a transform from an externally provided configuration.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Materialization.html" title="interface in org.apache.beam.sdk.transforms">Materialization</a><T></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Materializations.IterableView.html" title="interface in org.apache.beam.sdk.transforms">Materializations.IterableView</a><V></td> |
| <td class="colLast"> |
| <div class="block">Represents the <code>PrimitiveViewT</code> supplied to the <a href="../../../../../org/apache/beam/sdk/transforms/ViewFn.html" title="class in org.apache.beam.sdk.transforms"><code>ViewFn</code></a> when it declares to use |
| the <a href="../../../../../org/apache/beam/sdk/transforms/Materializations.html#ITERABLE_MATERIALIZATION_URN"><code>iterable materialization</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Materializations.MultimapView.html" title="interface in org.apache.beam.sdk.transforms">Materializations.MultimapView</a><K,V></td> |
| <td class="colLast"> |
| <div class="block">Represents the <code>PrimitiveViewT</code> supplied to the <a href="../../../../../org/apache/beam/sdk/transforms/ViewFn.html" title="class in org.apache.beam.sdk.transforms"><code>ViewFn</code></a> when it declares to use |
| the <a href="../../../../../org/apache/beam/sdk/transforms/Materializations.html#MULTIMAP_MATERIALIZATION_URN"><code>multimap materialization</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Partition.PartitionFn.html" title="interface in org.apache.beam.sdk.transforms">Partition.PartitionFn</a><T></td> |
| <td class="colLast"> |
| <div class="block">A function object that chooses an output partition for an element.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ProcessFunction.html" title="interface in org.apache.beam.sdk.transforms">ProcessFunction</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A function that computes an output value of type <code>OutputT</code> from an input value of type |
| <code>InputT</code> and is <code>Serializable</code>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/SerializableBiFunction.html" title="interface in org.apache.beam.sdk.transforms">SerializableBiFunction</a><FirstInputT,SecondInputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A union of the <code>BiFunction</code> and <code>Serializable</code> interfaces.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/SerializableComparator.html" title="interface in org.apache.beam.sdk.transforms">SerializableComparator</a><T></td> |
| <td class="colLast"> |
| <div class="block">A <code>Comparator</code> that is also <code>Serializable</code>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/SerializableFunction.html" title="interface in org.apache.beam.sdk.transforms">SerializableFunction</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A function that computes an output value of type <code>OutputT</code> from an input value of type |
| <code>InputT</code>, is <code>Serializable</code>, and does not allow checked exceptions to be declared.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Watch.Growth.TerminationCondition.html" title="interface in org.apache.beam.sdk.transforms">Watch.Growth.TerminationCondition</a><InputT,StateT></td> |
| <td class="colLast"> |
| <div class="block">A strategy for determining whether it is time to stop polling the current input regardless of |
| whether its output is complete or not.</div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </li> |
| <li class="blockList"> |
| <table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Class Summary table, listing classes, and an explanation"> |
| <caption><span>Class Summary</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Class</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tbody> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ApproximateQuantiles.html" title="class in org.apache.beam.sdk.transforms">ApproximateQuantiles</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for getting an idea of a <code>PCollection</code>'s data distribution using |
| approximate <code>N</code>-tiles (e.g.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ApproximateQuantiles.ApproximateQuantilesCombineFn.html" title="class in org.apache.beam.sdk.transforms">ApproximateQuantiles.ApproximateQuantilesCombineFn</a><T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable></td> |
| <td class="colLast"> |
| <div class="block">The <code>ApproximateQuantilesCombineFn</code> combiner gives an idea of the distribution of a |
| collection of values using approximate <code>N</code>-tiles.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ApproximateUnique.html" title="class in org.apache.beam.sdk.transforms">ApproximateUnique</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for estimating the number of distinct elements in a <code>PCollection</code>, or |
| the number of distinct values associated with each key in a <code>PCollection</code> of <code>KV</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ApproximateUnique.ApproximateUniqueCombineFn.html" title="class in org.apache.beam.sdk.transforms">ApproximateUnique.ApproximateUniqueCombineFn</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>CombineFn</code> that computes an estimate of the number of distinct values that were |
| combined.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique.html" title="class in org.apache.beam.sdk.transforms">ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique</a></td> |
| <td class="colLast"> |
| <div class="block">A heap utility class to efficiently track the largest added elements.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ApproximateUnique.Globally.html" title="class in org.apache.beam.sdk.transforms">ApproximateUnique.Globally</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code> for estimating the number of distinct elements in a <code>PCollection</code>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ApproximateUnique.PerKey.html" title="class in org.apache.beam.sdk.transforms">ApproximateUnique.PerKey</a><K,V></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code> for estimating the number of distinct values associated with each key in a |
| <code>PCollection</code> of <code>KV</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.html" title="class in org.apache.beam.sdk.transforms">Combine</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for combining <code>PCollection</code> elements globally and per-key.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.AccumulatingCombineFn</a><InputT,AccumT extends <a href="../../../../../org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.Accumulator.html" title="interface in org.apache.beam.sdk.transforms">Combine.AccumulatingCombineFn.Accumulator</a><InputT,AccumT,OutputT>,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A <code>CombineFn</code> that uses a subclass of <a href="../../../../../org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.Accumulator.html" title="interface in org.apache.beam.sdk.transforms"><code>Combine.AccumulatingCombineFn.Accumulator</code></a> as its |
| accumulator type.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.BinaryCombineDoubleFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineDoubleFn</a></td> |
| <td class="colLast"> |
| <div class="block">An abstract subclass of <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a> for implementing combiners that are more easily and |
| efficiently expressed as binary operations on <code>double</code>s.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.BinaryCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineFn</a><V></td> |
| <td class="colLast"> |
| <div class="block">An abstract subclass of <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a> for implementing combiners that are more easily |
| expressed as binary operations.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.BinaryCombineIntegerFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineIntegerFn</a></td> |
| <td class="colLast"> |
| <div class="block">An abstract subclass of <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a> for implementing combiners that are more easily and |
| efficiently expressed as binary operations on <code>int</code>s</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.BinaryCombineLongFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineLongFn</a></td> |
| <td class="colLast"> |
| <div class="block">An abstract subclass of <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a> for implementing combiners that are more easily and |
| efficiently expressed as binary operations on <code>long</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.CombineFn</a><InputT,AccumT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A <code>CombineFn<InputT, AccumT, OutputT></code> specifies how to combine a collection of input |
| values of type <code>InputT</code> into a single output value of type <code>OutputT</code>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.Globally.html" title="class in org.apache.beam.sdk.transforms">Combine.Globally</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block"><code>Combine.Globally<InputT, OutputT></code> takes a <code>PCollection<InputT></code> and returns a |
| <code>PCollection<OutputT></code> whose elements are the result of combining all the elements in |
| each window of the input <code>PCollection</code>, using a specified <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>CombineFn<InputT, AccumT, OutputT></code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.GloballyAsSingletonView.html" title="class in org.apache.beam.sdk.transforms">Combine.GloballyAsSingletonView</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block"><code>Combine.GloballyAsSingletonView<InputT, OutputT></code> takes a <code>PCollection<InputT></code> |
| and returns a <code>PCollectionView<OutputT></code> whose elements are the result of combining all |
| the elements in each window of the input <code>PCollection</code>, using a specified <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>CombineFn<InputT, AccumT, OutputT></code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.GroupedValues.html" title="class in org.apache.beam.sdk.transforms">Combine.GroupedValues</a><K,InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block"><code>GroupedValues<K, InputT, OutputT></code> takes a <code>PCollection<KV<K, Iterable<InputT>>></code>, |
| such as the result of <a href="../../../../../org/apache/beam/sdk/transforms/GroupByKey.html" title="class in org.apache.beam.sdk.transforms"><code>GroupByKey</code></a>, applies a specified <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>CombineFn<InputT, AccumT, OutputT></code></a> to each of the input <code>KV<K, Iterable<InputT>></code> |
| elements to produce a combined output <code>KV<K, OutputT></code> element, and returns a <code>PCollection<KV<K, OutputT>></code> containing all the combined output elements.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.Holder.html" title="class in org.apache.beam.sdk.transforms">Combine.Holder</a><V></td> |
| <td class="colLast"> |
| <div class="block">Holds a single value value of type <code>V</code> which may or may not be present.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.IterableCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.IterableCombineFn</a><V></td> |
| <td class="colLast"> |
| <div class="block">Converts a <a href="../../../../../org/apache/beam/sdk/transforms/SerializableFunction.html" title="interface in org.apache.beam.sdk.transforms"><code>SerializableFunction</code></a> from <code>Iterable<V></code>s to <code>V</code>s into a simple |
| <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a> over <code>V</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.PerKey.html" title="class in org.apache.beam.sdk.transforms">Combine.PerKey</a><K,InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block"><code>PerKey<K, InputT, OutputT></code> takes a <code>PCollection<KV<K, InputT>></code>, groups it by |
| key, applies a combining function to the <code>InputT</code> values associated with each key to |
| produce a combined <code>OutputT</code> value, and returns a <code>PCollection<KV<K, OutputT>></code> |
| representing a map from each distinct key of the input <code>PCollection</code> to the corresponding |
| combined value.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.PerKeyWithHotKeyFanout.html" title="class in org.apache.beam.sdk.transforms">Combine.PerKeyWithHotKeyFanout</a><K,InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">Like <a href="../../../../../org/apache/beam/sdk/transforms/Combine.PerKey.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.PerKey</code></a>, but sharding the combining of hot keys.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Combine.SimpleCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.SimpleCombineFn</a><V></td> |
| <td class="colLast">Deprecated</td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineFnBase.html" title="class in org.apache.beam.sdk.transforms">CombineFnBase</a></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineFns.html" title="class in org.apache.beam.sdk.transforms">CombineFns</a></td> |
| <td class="colLast"> |
| <div class="block">Static utility methods that create combine function instances.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineFns.CoCombineResult.html" title="class in org.apache.beam.sdk.transforms">CombineFns.CoCombineResult</a></td> |
| <td class="colLast"> |
| <div class="block">A tuple of outputs produced by a composed combine functions.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineFns.ComposeCombineFnBuilder.html" title="class in org.apache.beam.sdk.transforms">CombineFns.ComposeCombineFnBuilder</a></td> |
| <td class="colLast"> |
| <div class="block">A builder class to construct a composed <a href="../../../../../org/apache/beam/sdk/transforms/CombineFnBase.GlobalCombineFn.html" title="interface in org.apache.beam.sdk.transforms"><code>CombineFnBase.GlobalCombineFn</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineFns.ComposedCombineFn.html" title="class in org.apache.beam.sdk.transforms">CombineFns.ComposedCombineFn</a><DataT></td> |
| <td class="colLast"> |
| <div class="block">A composed <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a> that applies multiple <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>CombineFns</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineFns.ComposedCombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms">CombineFns.ComposedCombineFnWithContext</a><DataT></td> |
| <td class="colLast"> |
| <div class="block">A composed <a href="../../../../../org/apache/beam/sdk/transforms/CombineWithContext.CombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms"><code>CombineWithContext.CombineFnWithContext</code></a> that applies multiple <a href="../../../../../org/apache/beam/sdk/transforms/CombineWithContext.CombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms"><code>CombineFnWithContexts</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineWithContext.html" title="class in org.apache.beam.sdk.transforms">CombineWithContext</a></td> |
| <td class="colLast"> |
| <div class="block">This class contains combine functions that have access to <code>PipelineOptions</code> and side inputs |
| through <code>CombineWithContext.Context</code>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineWithContext.CombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms">CombineWithContext.CombineFnWithContext</a><InputT,AccumT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A combine function that has access to <code>PipelineOptions</code> and side inputs through <code>CombineWithContext.Context</code>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/CombineWithContext.Context.html" title="class in org.apache.beam.sdk.transforms">CombineWithContext.Context</a></td> |
| <td class="colLast"> |
| <div class="block">Information accessible to all methods in <code>CombineFnWithContext</code> and <code>KeyedCombineFnWithContext</code>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Contextful.html" title="class in org.apache.beam.sdk.transforms">Contextful</a><ClosureT></td> |
| <td class="colLast"> |
| <div class="block">Pair of a bit of user code (a "closure") and the <a href="../../../../../org/apache/beam/sdk/transforms/Requirements.html" title="class in org.apache.beam.sdk.transforms"><code>Requirements</code></a> needed to run it.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Contextful.Fn.Context.html" title="class in org.apache.beam.sdk.transforms">Contextful.Fn.Context</a></td> |
| <td class="colLast"> |
| <div class="block">An accessor for additional capabilities available in <a href="../../../../../org/apache/beam/sdk/transforms/Contextful.Fn.html#apply-InputT-org.apache.beam.sdk.transforms.Contextful.Fn.Context-"><code>Contextful.Fn.apply(InputT, org.apache.beam.sdk.transforms.Contextful.Fn.Context)</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Count.html" title="class in org.apache.beam.sdk.transforms">Count</a></td> |
| <td class="colLast"> |
| <div class="block"><a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransforms</code></a> to count the elements in a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Create.html" title="class in org.apache.beam.sdk.transforms">Create</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>Create<T></code> takes a collection of elements of type <code>T</code> known when the pipeline is |
| constructed and returns a <code>PCollection<T></code> containing the elements.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Create.OfValueProvider.html" title="class in org.apache.beam.sdk.transforms">Create.OfValueProvider</a><T></td> |
| <td class="colLast"> |
| <div class="block">Implementation of <a href="../../../../../org/apache/beam/sdk/transforms/Create.html#ofProvider-org.apache.beam.sdk.options.ValueProvider-org.apache.beam.sdk.coders.Coder-"><code>Create.ofProvider(org.apache.beam.sdk.options.ValueProvider<T>, org.apache.beam.sdk.coders.Coder<T>)</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Create.TimestampedValues.html" title="class in org.apache.beam.sdk.transforms">Create.TimestampedValues</a><T></td> |
| <td class="colLast"> |
| <div class="block">A <code>PTransform</code> that creates a <code>PCollection</code> whose elements have associated |
| timestamps.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Create.Values.html" title="class in org.apache.beam.sdk.transforms">Create.Values</a><T></td> |
| <td class="colLast"> |
| <div class="block">A <code>PTransform</code> that creates a <code>PCollection</code> from a set of in-memory objects.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Distinct.html" title="class in org.apache.beam.sdk.transforms">Distinct</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>Distinct<T></code> takes a <code>PCollection<T></code> and returns a <code>PCollection<T></code> that has |
| all distinct elements of the input.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Distinct.WithRepresentativeValues.html" title="class in org.apache.beam.sdk.transforms">Distinct.WithRepresentativeValues</a><T,IdT></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/Distinct.html" title="class in org.apache.beam.sdk.transforms"><code>Distinct</code></a> <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> that uses a <a href="../../../../../org/apache/beam/sdk/transforms/SerializableFunction.html" title="interface in org.apache.beam.sdk.transforms"><code>SerializableFunction</code></a> to obtain a |
| representative value for each input element.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">The argument to <a href="../../../../../org/apache/beam/sdk/transforms/ParDo.html" title="class in org.apache.beam.sdk.transforms"><code>ParDo</code></a> providing the code to use to process elements of the input <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessContinuation.html" title="class in org.apache.beam.sdk.transforms">DoFn.ProcessContinuation</a></td> |
| <td class="colLast"> |
| <div class="block">When used as a return value of <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessElement.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.ProcessElement</code></a>, indicates whether there is more work to |
| be done for the current element.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFnOutputReceivers.html" title="class in org.apache.beam.sdk.transforms">DoFnOutputReceivers</a></td> |
| <td class="colLast"> |
| <div class="block">Common <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.OutputReceiver.html" title="interface in org.apache.beam.sdk.transforms"><code>DoFn.OutputReceiver</code></a> and <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.MultiOutputReceiver.html" title="interface in org.apache.beam.sdk.transforms"><code>DoFn.MultiOutputReceiver</code></a> classes.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFnSchemaInformation.html" title="class in org.apache.beam.sdk.transforms">DoFnSchemaInformation</a></td> |
| <td class="colLast"> |
| <div class="block">Represents information about how a DoFn extracts schemas.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFnSchemaInformation.Builder.html" title="class in org.apache.beam.sdk.transforms">DoFnSchemaInformation.Builder</a></td> |
| <td class="colLast"> |
| <div class="block">The builder object.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFnTester.html" title="class in org.apache.beam.sdk.transforms">DoFnTester</a><InputT,OutputT></td> |
| <td class="colLast">Deprecated |
| <div class="block"><span class="deprecationComment">Use <a href="../../../../../org/apache/beam/sdk/testing/TestPipeline.html" title="class in org.apache.beam.sdk.testing"><code>TestPipeline</code></a> with the <code>DirectRunner</code>.</span></div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Filter.html" title="class in org.apache.beam.sdk.transforms">Filter</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for filtering from a <code>PCollection</code> the elements satisfying a predicate, |
| or satisfying an inequality with a given value based on the elements' natural ordering.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/FlatMapElements.html" title="class in org.apache.beam.sdk.transforms">FlatMapElements</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for mapping a simple function that returns iterables over the elements of a |
| <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> and merging the results.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/FlatMapElements.FlatMapWithFailures.html" title="class in org.apache.beam.sdk.transforms">FlatMapElements.FlatMapWithFailures</a><InputT,OutputT,FailureT></td> |
| <td class="colLast"> |
| <div class="block">A <code>PTransform</code> that adds exception handling to <a href="../../../../../org/apache/beam/sdk/transforms/FlatMapElements.html" title="class in org.apache.beam.sdk.transforms"><code>FlatMapElements</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Flatten.html" title="class in org.apache.beam.sdk.transforms">Flatten</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Flatten<T></code> takes multiple <code>PCollection<T></code>s bundled into a <code>PCollectionList<T></code> and returns a single <code>PCollection<T></code> containing all the elements in |
| all the input <code>PCollection</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Flatten.Iterables.html" title="class in org.apache.beam.sdk.transforms">Flatten.Iterables</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>FlattenIterables<T></code> takes a <code>PCollection<Iterable<T>></code> and returns a <code>PCollection<T></code> that contains all the elements from each iterable.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Flatten.PCollections.html" title="class in org.apache.beam.sdk.transforms">Flatten.PCollections</a><T></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> that flattens a <a href="../../../../../org/apache/beam/sdk/values/PCollectionList.html" title="class in org.apache.beam.sdk.values"><code>PCollectionList</code></a> into a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> |
| containing all the elements of all the <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>s in its input.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/GroupByKey.html" title="class in org.apache.beam.sdk.transforms">GroupByKey</a><K,V></td> |
| <td class="colLast"> |
| <div class="block"><code>GroupByKey<K, V></code> takes a <code>PCollection<KV<K, V>></code>, groups the values by key and |
| windows, and returns a <code>PCollection<KV<K, Iterable<V>>></code> representing a map from each |
| distinct key and window of the input <code>PCollection</code> to an <code>Iterable</code> over all the |
| values associated with that key in the input per window.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/GroupIntoBatches.html" title="class in org.apache.beam.sdk.transforms">GroupIntoBatches</a><K,InputT></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> that batches inputs to a desired batch size.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Impulse.html" title="class in org.apache.beam.sdk.transforms">Impulse</a></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/InferableFunction.html" title="class in org.apache.beam.sdk.transforms">InferableFunction</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/ProcessFunction.html" title="interface in org.apache.beam.sdk.transforms"><code>ProcessFunction</code></a> which is not a <i>functional interface</i>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/JsonToRow.html" title="class in org.apache.beam.sdk.transforms">JsonToRow</a></td> |
| <td class="colLast"> |
| <div class="block"><i>Experimental</i></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Keys.html" title="class in org.apache.beam.sdk.transforms">Keys</a><K></td> |
| <td class="colLast"> |
| <div class="block"><code>Keys<K></code> takes a <code>PCollection</code> of <code>KV<K, V></code>s and returns a <code>PCollection<K></code> of the keys.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/KvSwap.html" title="class in org.apache.beam.sdk.transforms">KvSwap</a><K,V></td> |
| <td class="colLast"> |
| <div class="block"><code>KvSwap<K, V></code> takes a <code>PCollection<KV<K, V>></code> and returns a <code>PCollection<KV<V, |
| K>></code>, where all the keys and values have been swapped.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Latest.html" title="class in org.apache.beam.sdk.transforms">Latest</a></td> |
| <td class="colLast"> |
| <div class="block"><a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> and <a href="../../../../../org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a> for computing the latest element in a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/MapElements.html" title="class in org.apache.beam.sdk.transforms">MapElements</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for mapping a simple function over the elements of a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/MapElements.MapWithFailures.html" title="class in org.apache.beam.sdk.transforms">MapElements.MapWithFailures</a><InputT,OutputT,FailureT></td> |
| <td class="colLast"> |
| <div class="block">A <code>PTransform</code> that adds exception handling to <a href="../../../../../org/apache/beam/sdk/transforms/MapElements.html" title="class in org.apache.beam.sdk.transforms"><code>MapElements</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Materializations.html" title="class in org.apache.beam.sdk.transforms">Materializations</a></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Max.html" title="class in org.apache.beam.sdk.transforms">Max</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for computing the maximum of the elements in a <code>PCollection</code>, or the |
| maximum of the values associated with each key in a <code>PCollection</code> of <code>KV</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Mean.html" title="class in org.apache.beam.sdk.transforms">Mean</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for computing the arithmetic mean (a.k.a.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Min.html" title="class in org.apache.beam.sdk.transforms">Min</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for computing the minimum of the elements in a <code>PCollection</code>, or the |
| minimum of the values associated with each key in a <code>PCollection</code> of <code>KV</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ParDo.html" title="class in org.apache.beam.sdk.transforms">ParDo</a></td> |
| <td class="colLast"> |
| <div class="block"><a href="../../../../../org/apache/beam/sdk/transforms/ParDo.html" title="class in org.apache.beam.sdk.transforms"><code>ParDo</code></a> is the core element-wise transform in Apache Beam, invoking a user-specified |
| function on each of the elements of the input <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> to produce zero or more output |
| elements, all of which are collected into the output <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ParDo.MultiOutput.html" title="class in org.apache.beam.sdk.transforms">ParDo.MultiOutput</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> that, when applied to a <code>PCollection<InputT></code>, invokes a |
| user-specified <code>DoFn<InputT, OutputT></code> on all its elements, which can emit elements to |
| any of the <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a>'s output <code>PCollection</code>s, which are bundled into a result |
| <code>PCollectionTuple</code>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ParDo.SingleOutput.html" title="class in org.apache.beam.sdk.transforms">ParDo.SingleOutput</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> that, when applied to a <code>PCollection<InputT></code>, invokes a |
| user-specified <code>DoFn<InputT, OutputT></code> on all its elements, with all its outputs |
| collected into an output <code>PCollection<OutputT></code>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Partition.html" title="class in org.apache.beam.sdk.transforms">Partition</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>Partition</code> takes a <code>PCollection<T></code> and a <code>PartitionFn</code>, uses the <code>PartitionFn</code> to split the elements of the input <code>PCollection</code> into <code>N</code> partitions, |
| and returns a <code>PCollectionList<T></code> that bundles <code>N</code> <code>PCollection<T></code>s |
| containing the split elements.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms">PTransform</a><InputT extends <a href="../../../../../org/apache/beam/sdk/values/PInput.html" title="interface in org.apache.beam.sdk.values">PInput</a>,OutputT extends <a href="../../../../../org/apache/beam/sdk/values/POutput.html" title="interface in org.apache.beam.sdk.values">POutput</a>></td> |
| <td class="colLast"> |
| <div class="block">A <code>PTransform<InputT, OutputT></code> is an operation that takes an <code>InputT</code> (some subtype |
| of <a href="../../../../../org/apache/beam/sdk/values/PInput.html" title="interface in org.apache.beam.sdk.values"><code>PInput</code></a>) and produces an <code>OutputT</code> (some subtype of <a href="../../../../../org/apache/beam/sdk/values/POutput.html" title="interface in org.apache.beam.sdk.values"><code>POutput</code></a>).</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.html" title="class in org.apache.beam.sdk.transforms">Regex</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransorm</code>s to use Regular Expressions to process elements in a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.AllMatches.html" title="class in org.apache.beam.sdk.transforms">Regex.AllMatches</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.MatchesName<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<List<String>></code> representing the value extracted from all the Regex groups of the |
| input <code>PCollection</code> to the number of times that element occurs in the input.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.Find.html" title="class in org.apache.beam.sdk.transforms">Regex.Find</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.Find<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<String></code> representing the value extracted from the Regex groups of the input <code>PCollection</code> to the number of times that element occurs in the input.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.FindAll.html" title="class in org.apache.beam.sdk.transforms">Regex.FindAll</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.Find<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<List<String>></code> representing the value extracted from the Regex groups of the input |
| <code>PCollection</code> to the number of times that element occurs in the input.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.FindKV.html" title="class in org.apache.beam.sdk.transforms">Regex.FindKV</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.MatchesKV<KV<String, String>></code> takes a <code>PCollection<String></code> and returns a |
| <code>PCollection<KV<String, String>></code> representing the key and value extracted from the Regex |
| groups of the input <code>PCollection</code> to the number of times that element occurs in the |
| input.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.FindName.html" title="class in org.apache.beam.sdk.transforms">Regex.FindName</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.Find<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<String></code> representing the value extracted from the Regex groups of the input <code>PCollection</code> to the number of times that element occurs in the input.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.FindNameKV.html" title="class in org.apache.beam.sdk.transforms">Regex.FindNameKV</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.MatchesKV<KV<String, String>></code> takes a <code>PCollection<String></code> and returns a |
| <code>PCollection<KV<String, String>></code> representing the key and value extracted from the Regex |
| groups of the input <code>PCollection</code> to the number of times that element occurs in the |
| input.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.Matches.html" title="class in org.apache.beam.sdk.transforms">Regex.Matches</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.Matches<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<String></code> representing the value extracted from the Regex groups of the input <code>PCollection</code> to the number of times that element occurs in the input.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.MatchesKV.html" title="class in org.apache.beam.sdk.transforms">Regex.MatchesKV</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.MatchesKV<KV<String, String>></code> takes a <code>PCollection<String></code> and returns a |
| <code>PCollection<KV<String, String>></code> representing the key and value extracted from the Regex |
| groups of the input <code>PCollection</code> to the number of times that element occurs in the |
| input.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.MatchesName.html" title="class in org.apache.beam.sdk.transforms">Regex.MatchesName</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.MatchesName<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<String></code> representing the value extracted from the Regex groups of the input <code>PCollection</code> to the number of times that element occurs in the input.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.MatchesNameKV.html" title="class in org.apache.beam.sdk.transforms">Regex.MatchesNameKV</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.MatchesNameKV<KV<String, String>></code> takes a <code>PCollection<String></code> and returns |
| a <code>PCollection<KV<String, String>></code> representing the key and value extracted from the |
| Regex groups of the input <code>PCollection</code> to the number of times that element occurs in the |
| input.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.ReplaceAll.html" title="class in org.apache.beam.sdk.transforms">Regex.ReplaceAll</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.ReplaceAll<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<String></code> with all Strings that matched the Regex being replaced with the |
| replacement string.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.ReplaceFirst.html" title="class in org.apache.beam.sdk.transforms">Regex.ReplaceFirst</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.ReplaceFirst<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<String></code> with the first Strings that matched the Regex being replaced with the |
| replacement string.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Regex.Split.html" title="class in org.apache.beam.sdk.transforms">Regex.Split</a></td> |
| <td class="colLast"> |
| <div class="block"><code>Regex.Split<String></code> takes a <code>PCollection<String></code> and returns a <code>PCollection<String></code> with the input string split into individual items in a list.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Reify.html" title="class in org.apache.beam.sdk.transforms">Reify</a></td> |
| <td class="colLast"> |
| <div class="block"><a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransforms</code></a> for converting between explicit and implicit form of various Beam |
| values.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Requirements.html" title="class in org.apache.beam.sdk.transforms">Requirements</a></td> |
| <td class="colLast"> |
| <div class="block">Describes the run-time requirements of a <a href="../../../../../org/apache/beam/sdk/transforms/Contextful.html" title="class in org.apache.beam.sdk.transforms"><code>Contextful</code></a>, such as access to side inputs.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Reshuffle.html" title="class in org.apache.beam.sdk.transforms">Reshuffle</a><K,V></td> |
| <td class="colLast">Deprecated |
| <div class="block"><span class="deprecationComment">this transform's intended side effects are not portable; it will likely be removed</span></div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Reshuffle.ViaRandomKey.html" title="class in org.apache.beam.sdk.transforms">Reshuffle.ViaRandomKey</a><T></td> |
| <td class="colLast"> |
| <div class="block">Implementation of <a href="../../../../../org/apache/beam/sdk/transforms/Reshuffle.html#viaRandomKey--"><code>Reshuffle.viaRandomKey()</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Sample.html" title="class in org.apache.beam.sdk.transforms">Sample</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for taking samples of the elements in a <code>PCollection</code>, or samples of |
| the values associated with each key in a <code>PCollection</code> of <code>KV</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Sample.FixedSizedSampleFn.html" title="class in org.apache.beam.sdk.transforms">Sample.FixedSizedSampleFn</a><T></td> |
| <td class="colLast"> |
| <div class="block"><code>CombineFn</code> that computes a fixed-size sample of a collection of values.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/SerializableFunctions.html" title="class in org.apache.beam.sdk.transforms">SerializableFunctions</a></td> |
| <td class="colLast"> |
| <div class="block">Useful <a href="../../../../../org/apache/beam/sdk/transforms/SerializableFunction.html" title="interface in org.apache.beam.sdk.transforms"><code>SerializableFunction</code></a> overrides.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/SimpleFunction.html" title="class in org.apache.beam.sdk.transforms">SimpleFunction</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/SerializableFunction.html" title="interface in org.apache.beam.sdk.transforms"><code>SerializableFunction</code></a> which is not a <i>functional interface</i>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Sum.html" title="class in org.apache.beam.sdk.transforms">Sum</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for computing the sum of the elements in a <code>PCollection</code>, or the sum of |
| the values associated with each key in a <code>PCollection</code> of <code>KV</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ToJson.html" title="class in org.apache.beam.sdk.transforms">ToJson</a><T></td> |
| <td class="colLast"> |
| <div class="block"><i>Experimental</i></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Top.html" title="class in org.apache.beam.sdk.transforms">Top</a></td> |
| <td class="colLast"> |
| <div class="block"><code>PTransform</code>s for finding the largest (or smallest) set of elements in a <code>PCollection</code>, or the largest (or smallest) set of values associated with each key in a <code>PCollection</code> of <code>KV</code>s.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Top.Largest.html" title="class in org.apache.beam.sdk.transforms">Top.Largest</a><T extends java.lang.Comparable<? super T>></td> |
| <td class="colLast">Deprecated |
| <div class="block"><span class="deprecationComment">use <a href="../../../../../org/apache/beam/sdk/transforms/Top.Natural.html" title="class in org.apache.beam.sdk.transforms"><code>Top.Natural</code></a> instead</span></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Top.Natural.html" title="class in org.apache.beam.sdk.transforms">Top.Natural</a><T extends java.lang.Comparable<? super T>></td> |
| <td class="colLast"> |
| <div class="block">A <code>Serializable</code> <code>Comparator</code> that that uses the compared elements' natural |
| ordering.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Top.Reversed.html" title="class in org.apache.beam.sdk.transforms">Top.Reversed</a><T extends java.lang.Comparable<? super T>></td> |
| <td class="colLast"> |
| <div class="block"><code>Serializable</code> <code>Comparator</code> that that uses the reverse of the compared elements' |
| natural ordering.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Top.Smallest.html" title="class in org.apache.beam.sdk.transforms">Top.Smallest</a><T extends java.lang.Comparable<? super T>></td> |
| <td class="colLast">Deprecated |
| <div class="block"><span class="deprecationComment">use <a href="../../../../../org/apache/beam/sdk/transforms/Top.Reversed.html" title="class in org.apache.beam.sdk.transforms"><code>Top.Reversed</code></a> instead</span></div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Top.TopCombineFn.html" title="class in org.apache.beam.sdk.transforms">Top.TopCombineFn</a><T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable></td> |
| <td class="colLast"> |
| <div class="block"><code>CombineFn</code> for <code>Top</code> transforms that combines a bunch of <code>T</code>s into a single |
| <code>count</code>-long <code>List<T></code>, using <code>compareFn</code> to choose the largest <code>T</code>s.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ToString.html" title="class in org.apache.beam.sdk.transforms">ToString</a></td> |
| <td class="colLast"> |
| <div class="block"><a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransforms</code></a> for converting a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection<?></code></a>, <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection<KV<?,?>></code></a>, or <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection<Iterable<?>></code></a> to a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection<String></code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Values.html" title="class in org.apache.beam.sdk.transforms">Values</a><V></td> |
| <td class="colLast"> |
| <div class="block"><code>Values<V></code> takes a <code>PCollection</code> of <code>KV<K, V></code>s and returns a <code>PCollection<V></code> of the values.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/View.html" title="class in org.apache.beam.sdk.transforms">View</a></td> |
| <td class="colLast"> |
| <div class="block">Transforms for creating <a href="../../../../../org/apache/beam/sdk/values/PCollectionView.html" title="interface in org.apache.beam.sdk.values"><code>PCollectionViews</code></a> from <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollections</code></a> (to read them as side inputs).</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/View.AsIterable.html" title="class in org.apache.beam.sdk.transforms">View.AsIterable</a><T></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/View.AsList.html" title="class in org.apache.beam.sdk.transforms">View.AsList</a><T></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/View.AsMap.html" title="class in org.apache.beam.sdk.transforms">View.AsMap</a><K,V></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/View.AsMultimap.html" title="class in org.apache.beam.sdk.transforms">View.AsMultimap</a><K,V></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/View.AsSingleton.html" title="class in org.apache.beam.sdk.transforms">View.AsSingleton</a><T></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/View.CreatePCollectionView.html" title="class in org.apache.beam.sdk.transforms">View.CreatePCollectionView</a><ElemT,ViewT></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/ViewFn.html" title="class in org.apache.beam.sdk.transforms">ViewFn</a><PrimitiveViewT,ViewT></td> |
| <td class="colLast"> |
| <div class="block"><b><i>For internal use only; no backwards-compatibility guarantees.</i></b></div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Wait.html" title="class in org.apache.beam.sdk.transforms">Wait</a></td> |
| <td class="colLast"> |
| <div class="block">Delays processing of each window in a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> until signaled.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Wait.OnSignal.html" title="class in org.apache.beam.sdk.transforms">Wait.OnSignal</a><T></td> |
| <td class="colLast"> |
| <div class="block">Implementation of <a href="../../../../../org/apache/beam/sdk/transforms/Wait.html#on-org.apache.beam.sdk.values.PCollection...-"><code>Wait.on(org.apache.beam.sdk.values.PCollection<?>...)</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Watch.html" title="class in org.apache.beam.sdk.transforms">Watch</a></td> |
| <td class="colLast"> |
| <div class="block">Given a "poll function" that produces a potentially growing set of outputs for an input, this |
| transform simultaneously continuously watches the growth of output sets of all inputs, until a |
| per-input termination condition is reached.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Watch.Growth.html" title="class in org.apache.beam.sdk.transforms">Watch.Growth</a><InputT,OutputT,KeyT></td> |
| <td class="colLast"> |
| <div class="block">Implementation of <a href="../../../../../org/apache/beam/sdk/transforms/Watch.html#growthOf-org.apache.beam.sdk.transforms.Watch.Growth.PollFn-org.apache.beam.sdk.transforms.Requirements-"><code>Watch.growthOf(org.apache.beam.sdk.transforms.Watch.Growth.PollFn<InputT, OutputT>, org.apache.beam.sdk.transforms.Requirements)</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Watch.Growth.PollFn.html" title="class in org.apache.beam.sdk.transforms">Watch.Growth.PollFn</a><InputT,OutputT></td> |
| <td class="colLast"> |
| <div class="block">A function that computes the current set of outputs for the given input, in the form of a |
| <a href="../../../../../org/apache/beam/sdk/transforms/Watch.Growth.PollResult.html" title="class in org.apache.beam.sdk.transforms"><code>Watch.Growth.PollResult</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/Watch.Growth.PollResult.html" title="class in org.apache.beam.sdk.transforms">Watch.Growth.PollResult</a><OutputT></td> |
| <td class="colLast"> |
| <div class="block">The result of a single invocation of a <a href="../../../../../org/apache/beam/sdk/transforms/Watch.Growth.PollFn.html" title="class in org.apache.beam.sdk.transforms"><code>Watch.Growth.PollFn</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/WithFailures.html" title="class in org.apache.beam.sdk.transforms">WithFailures</a></td> |
| <td class="colLast"> |
| <div class="block">A collection of utilities for writing transforms that can handle exceptions raised during |
| processing of elements.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/WithFailures.ExceptionAsMapHandler.html" title="class in org.apache.beam.sdk.transforms">WithFailures.ExceptionAsMapHandler</a><T></td> |
| <td class="colLast"> |
| <div class="block">A simple handler that extracts information from an exception to a <code>Map<String, String></code> |
| and returns a <a href="../../../../../org/apache/beam/sdk/values/KV.html" title="class in org.apache.beam.sdk.values"><code>KV</code></a> where the key is the input element that failed processing, and the |
| value is the map of exception attributes.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/WithFailures.ExceptionElement.html" title="class in org.apache.beam.sdk.transforms">WithFailures.ExceptionElement</a><T></td> |
| <td class="colLast"> |
| <div class="block">The value type passed as input to exception handlers.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/WithFailures.Result.html" title="class in org.apache.beam.sdk.transforms">WithFailures.Result</a><OutputT extends <a href="../../../../../org/apache/beam/sdk/values/POutput.html" title="interface in org.apache.beam.sdk.values">POutput</a>,FailureElementT></td> |
| <td class="colLast"> |
| <div class="block">An intermediate output type for PTransforms that allows an output collection to live alongside |
| a collection of elements that failed the transform.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/WithKeys.html" title="class in org.apache.beam.sdk.transforms">WithKeys</a><K,V></td> |
| <td class="colLast"> |
| <div class="block"><code>WithKeys<K, V></code> takes a <code>PCollection<V></code>, and either a constant key of type <code>K</code> or a function from <code>V</code> to <code>K</code>, and returns a <code>PCollection<KV<K, V>></code>, where |
| each of the values in the input <code>PCollection</code> has been paired with either the constant key |
| or a key computed from the value.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/WithTimestamps.html" title="class in org.apache.beam.sdk.transforms">WithTimestamps</a><T></td> |
| <td class="colLast"> |
| <div class="block">A <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> for assigning timestamps to all the elements of a <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </li> |
| <li class="blockList"> |
| <table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Enum Summary table, listing enums, and an explanation"> |
| <caption><span>Enum Summary</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Enum</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tbody> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFnTester.CloningBehavior.html" title="enum in org.apache.beam.sdk.transforms">DoFnTester.CloningBehavior</a></td> |
| <td class="colLast">Deprecated |
| <div class="block"><span class="deprecationComment">Use <a href="../../../../../org/apache/beam/sdk/testing/TestPipeline.html" title="class in org.apache.beam.sdk.testing"><code>TestPipeline</code></a> with the <code>DirectRunner</code>.</span></div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </li> |
| <li class="blockList"> |
| <table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Annotation Types Summary table, listing annotation types, and an explanation"> |
| <caption><span>Annotation Types Summary</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Annotation Type</th> |
| <th class="colLast" scope="col">Description</th> |
| </tr> |
| <tbody> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.BoundedPerElement.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.BoundedPerElement</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation on a <a href="https://s.apache.org/splittable-do-fn">splittable</a> <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a> |
| specifying that the <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a> performs a bounded amount of work per input element, so |
| applying it to a bounded <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> will produce also a bounded <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.Element.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.Element</a></td> |
| <td class="colLast"> |
| <div class="block">Parameter annotation for the input element for a <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessElement.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.ProcessElement</code></a> method.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.FieldAccess.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.FieldAccess</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for specifying specific fields that are accessed in a Schema PCollection.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.FinishBundle.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.FinishBundle</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method to use to finish processing a batch of elements.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.GetInitialRestriction.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.GetInitialRestriction</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method that maps an element to an initial restriction for a <a |
| href="https://s.apache.org/splittable-do-fn">splittable</a> <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.GetRestrictionCoder.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.GetRestrictionCoder</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method that returns the coder to use for the restriction of a <a |
| href="https://s.apache.org/splittable-do-fn">splittable</a> <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.GetSize.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.GetSize</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method that returns the corresponding size for an element and restriction |
| pair.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.NewTracker.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.NewTracker</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method that creates a new <a href="../../../../../org/apache/beam/sdk/transforms/splittabledofn/RestrictionTracker.html" title="class in org.apache.beam.sdk.transforms.splittabledofn"><code>RestrictionTracker</code></a> for the restriction of |
| a <a href="https://s.apache.org/splittable-do-fn">splittable</a> <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a>.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.OnTimer.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.OnTimer</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for registering a callback for a timer.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.OnTimerFamily.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.OnTimerFamily</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for registering a callback for a timerFamily.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.OnWindowExpiration.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.OnWindowExpiration</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method to use for performing actions on window expiration.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessElement.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.ProcessElement</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method to use for processing elements.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.RequiresStableInput.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.RequiresStableInput</a></td> |
| <td class="colLast"> |
| <div class="block"><b><i>Experimental - no backwards compatibility guarantees.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.Setup.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.Setup</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method to use to prepare an instance for processing bundles of elements.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.SideInput.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.SideInput</a></td> |
| <td class="colLast"> |
| <div class="block">Parameter annotation for the SideInput for a <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessElement.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.ProcessElement</code></a> method.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.SplitRestriction.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.SplitRestriction</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method that splits restriction of a <a |
| href="https://s.apache.org/splittable-do-fn">splittable</a> <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a> into multiple parts to |
| be processed in parallel.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.StartBundle.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.StartBundle</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method to use to prepare an instance for processing a batch of elements.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.StateId.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.StateId</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for declaring and dereferencing state cells.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.Teardown.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.Teardown</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for the method to use to clean up this instance before it is discarded.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.TimerFamily.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.TimerFamily</a></td> |
| <td class="colLast"> |
| <div class="block">Parameter annotation for the TimerMap for a <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessElement.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.ProcessElement</code></a> method.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.TimerId.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.TimerId</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation for declaring and dereferencing timers.</div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.Timestamp.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.Timestamp</a></td> |
| <td class="colLast"> |
| <div class="block">Parameter annotation for the input element timestamp for <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.ProcessElement.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.ProcessElement</code></a>, <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.GetInitialRestriction.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.GetInitialRestriction</code></a>, <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.SplitRestriction.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.SplitRestriction</code></a>, and <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.NewTracker.html" title="annotation in org.apache.beam.sdk.transforms"><code>DoFn.NewTracker</code></a> methods.</div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colFirst"><a href="../../../../../org/apache/beam/sdk/transforms/DoFn.UnboundedPerElement.html" title="annotation in org.apache.beam.sdk.transforms">DoFn.UnboundedPerElement</a></td> |
| <td class="colLast"> |
| <div class="block">Annotation on a <a href="https://s.apache.org/splittable-do-fn">splittable</a> <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a> |
| specifying that the <a href="../../../../../org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn</code></a> performs an unbounded amount of work per input element, so |
| applying it to a bounded <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> will produce an unbounded <a href="../../../../../org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a>.</div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </li> |
| </ul> |
| <a name="package.description"> |
| <!-- --> |
| </a> |
| <h2 title="Package org.apache.beam.sdk.transforms Description">Package org.apache.beam.sdk.transforms Description</h2> |
| <div class="block">Defines <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a>s for transforming data in a pipeline. |
| |
| <p>A <a href="../../../../../org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> is an operation that takes an <code>InputT</code> (some subtype of <a href="../../../../../org/apache/beam/sdk/values/PInput.html" title="interface in org.apache.beam.sdk.values"><code>PInput</code></a>) and produces an <code>OutputT</code> (some subtype of <a href="../../../../../org/apache/beam/sdk/values/POutput.html" title="interface in org.apache.beam.sdk.values"><code>POutput</code></a>). |
| |
| <p>Common PTransforms include root PTransforms like <a href="../../../../../org/apache/beam/sdk/io/TextIO.Read.html" title="class in org.apache.beam.sdk.io"><code>TextIO.Read</code></a> |
| and <a href="../../../../../org/apache/beam/sdk/transforms/Create.html" title="class in org.apache.beam.sdk.transforms"><code>Create</code></a>, processing and conversion operations like |
| <a href="../../../../../org/apache/beam/sdk/transforms/ParDo.html" title="class in org.apache.beam.sdk.transforms"><code>ParDo</code></a>, <a href="../../../../../org/apache/beam/sdk/transforms/GroupByKey.html" title="class in org.apache.beam.sdk.transforms"><code>GroupByKey</code></a>, |
| <a href="../../../../../org/apache/beam/sdk/transforms/join/CoGroupByKey.html" title="class in org.apache.beam.sdk.transforms.join"><code>CoGroupByKey</code></a>, <a href="../../../../../org/apache/beam/sdk/transforms/Combine.html" title="class in org.apache.beam.sdk.transforms"><code>Combine</code></a>, and <a href="../../../../../org/apache/beam/sdk/transforms/Count.html" title="class in org.apache.beam.sdk.transforms"><code>Count</code></a>, and |
| outputting PTransforms like <a href="../../../../../org/apache/beam/sdk/io/TextIO.Write.html" title="class in org.apache.beam.sdk.io"><code>TextIO.Write</code></a>. |
| |
| <p>New PTransforms can be created by composing existing PTransforms. Most PTransforms in this |
| package are composites, and users can also create composite PTransforms for their own |
| application-specific logic.</div> |
| </div> |
| <!-- ======= START OF BOTTOM NAVBAR ====== --> |
| <div class="bottomNav"><a name="navbar.bottom"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.bottom.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../../../overview-summary.html">Overview</a></li> |
| <li class="navBarCell1Rev">Package</li> |
| <li>Class</li> |
| <li><a href="package-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><a href="../../../../../org/apache/beam/sdk/testing/package-summary.html">Prev Package</a></li> |
| <li><a href="../../../../../org/apache/beam/sdk/transforms/display/package-summary.html">Next Package</a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../../../index.html?org/apache/beam/sdk/transforms/package-summary.html" target="_top">Frames</a></li> |
| <li><a href="package-summary.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_bottom"> |
| <li><a href="../../../../../allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_bottom"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <a name="skip.navbar.bottom"> |
| <!-- --> |
| </a></div> |
| <!-- ======== END OF BOTTOM NAVBAR ======= --> |
| </body> |
| </html> |
