http://git-wip-us.apache.org/repos/asf/beam-site/blob/de6a0417/content/documentation/sdks/javadoc/0.4.0/index-all.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.4.0/index-all.html b/content/documentation/sdks/javadoc/0.4.0/index-all.html new file mode 100644 index 0000000..c3ed2ab --- /dev/null +++ b/content/documentation/sdks/javadoc/0.4.0/index-all.html @@ -0,0 +1,21330 @@ +<!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_111) on Thu Dec 29 08:19:11 CET 2016 --> +<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> +<title>Index (Apache Beam SDK for Java, version 0.4.0)</title> +<meta name="date" content="2016-12-29"> +<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="Index (Apache Beam SDK for Java, version 0.4.0)"; + } + } + catch(err) { + } +//--> +</script> +<noscript> +<div>JavaScript is disabled on your browser.</div> +</noscript> +<!-- ========= START OF TOP NAVBAR ======= --> +<div class="topNav"><a name="navbar.top"> +<!-- --> +</a> +<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> +<a name="navbar.top.firstrow"> +<!-- --> +</a> +<ul class="navList" title="Navigation"> +<li><a href="overview-summary.html">Overview</a></li> +<li>Package</li> +<li>Class</li> +<li>Use</li> +<li><a href="overview-tree.html">Tree</a></li> +<li><a href="deprecated-list.html">Deprecated</a></li> +<li class="navBarCell1Rev">Index</li> +<li><a href="help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li>Prev</li> +<li>Next</li> +</ul> +<ul class="navList"> +<li><a href="index.html?index-all.html" target="_top">Frames</a></li> +<li><a href="index-all.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="contentContainer"><a href="#I:A">A</a> <a href="#I:B">B</a> <a href="#I:C">C</a> <a href="#I:D">D</a> <a href="#I:E">E</a> <a href="#I:F">F</a> <a href="#I:G">G</a> <a href="#I:H">H</a> <a href="#I:I">I</a> <a href="#I:J">J</a> <a href="#I:K">K</a> <a href="#I:L">L</a> <a href="#I:M">M</a> <a href="#I:N">N</a> <a href="#I:O">O</a> <a href="#I:P">P</a> <a href="#I:Q">Q</a> <a href="#I:R">R</a> <a href="#I:S">S</a> <a href="#I:T">T</a> <a href="#I:U">U</a> <a href="#I:V">V</a> <a href="#I:W">W</a> <a href="#I:X">X</a> <a href="#I:Y">Y</a> <a href="#I:Z">Z</a> <a name="I:A"> +<!-- --> +</a> +<h2 class="title">A</h2> +<dl> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/display/DisplayData.Path.html#absolute-java.lang.String-java.lang.String...-">absolute(String, String...)</a></span> - Static method in class org.apache.beam.sdk.transforms.display.<a href="org/apache/beam/sdk/transforms/display/DisplayData.Path.html" title="class in org.apache.beam.sdk.transforms.display">DisplayData.Path</a></dt> +<dd> +<div class="block">Construct a path from an absolute component path hierarchy.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/StateAccessor.html#access-org.apache.beam.sdk.util.state.StateTag-">access(StateTag<? super K, StateT>)</a></span> - Method in interface org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a></dt> +<dd> +<div class="block">Access the storage for the given <code>address</code> in the current window.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/MergingStateAccessor.html#accessInEachMergingWindow-org.apache.beam.sdk.util.state.StateTag-">accessInEachMergingWindow(StateTag<? super K, StateT>)</a></span> - Method in interface org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/MergingStateAccessor.html" title="interface in org.apache.beam.sdk.util.state">MergingStateAccessor</a></dt> +<dd> +<div class="block">Analogous to <a href="org/apache/beam/sdk/util/state/StateAccessor.html#access-org.apache.beam.sdk.util.state.StateTag-"><code>StateAccessor.access(org.apache.beam.sdk.util.state.StateTag<? super K, StateT>)</code></a>, but returned as a map from each window which is + about to be merged to the corresponding state.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.html#AccumulatingCombineFn--">AccumulatingCombineFn()</a></span> - Constructor for class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.AccumulatingCombineFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/Window.html#accumulatingFiredPanes--">accumulatingFiredPanes()</a></span> - Static method in class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/Window.html" title="class in org.apache.beam.sdk.transforms.windowing">Window</a></dt> +<dd> +<div class="block">Returns a new <code>Window</code> <code>PTransform</code> that uses the registered WindowFn and + Triggering behavior, and that accumulates elements in a pane after they are triggered.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/Window.Bound.html#accumulatingFiredPanes--">accumulatingFiredPanes()</a></span> - Method in class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/Window.Bound.html" title="class in org.apache.beam.sdk.transforms.windowing">Window.Bound</a></dt> +<dd> +<div class="block">Returns a new <code>Window</code> <code>PTransform</code> that uses the registered WindowFn and + Triggering behavior, and that accumulates elements in a pane after they are triggered.</div> +</dd> +<dt><a href="org/apache/beam/sdk/util/state/AccumulatorCombiningState.html" title="interface in org.apache.beam.sdk.util.state"><span class="typeNameLink">AccumulatorCombiningState</span></a><<a href="org/apache/beam/sdk/util/state/AccumulatorCombiningState.html" title="type parameter in AccumulatorCombiningState">InputT</a>,<a href="org/apache/beam/sdk/util/state/AccumulatorCombiningState.html" title="type parameter in AccumulatorCombiningState">AccumT</a>,<a href="org/apache/beam/sdk/util/state/AccumulatorCombiningState.html" title="type parameter in AccumulatorCombiningState">OutputT</a>> - Interface in <a href="org/apache/beam/sdk/util/state/package-summary.html">org.apache.beam.sdk.util.state</a></dt> +<dd> +<div class="block">State for a single value that is managed by a <a href="org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms"><code>Combine.CombineFn</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubClient.html#ackDeadlineSeconds-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-">ackDeadlineSeconds(PubsubClient.SubscriptionPath)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubClient.html" title="class in org.apache.beam.sdk.util">PubsubClient</a></dt> +<dd> +<div class="block">Return the ack deadline, in seconds, for <code>subscription</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubGrpcClient.html#ackDeadlineSeconds-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-">ackDeadlineSeconds(PubsubClient.SubscriptionPath)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubGrpcClient.html" title="class in org.apache.beam.sdk.util">PubsubGrpcClient</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubJsonClient.html#ackDeadlineSeconds-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-">ackDeadlineSeconds(PubsubClient.SubscriptionPath)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubJsonClient.html" title="class in org.apache.beam.sdk.util">PubsubJsonClient</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubTestClient.html#ackDeadlineSeconds-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-">ackDeadlineSeconds(PubsubClient.SubscriptionPath)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubTestClient.html" title="class in org.apache.beam.sdk.util">PubsubTestClient</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubClient.IncomingMessage.html#ackId">ackId</a></span> - Variable in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubClient.IncomingMessage.html" title="class in org.apache.beam.sdk.util">PubsubClient.IncomingMessage</a></dt> +<dd> +<div class="block">Id to pass back to Pubsub to acknowledge receipt of this message.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubClient.html#acknowledge-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-java.util.List-">acknowledge(PubsubClient.SubscriptionPath, List<String>)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubClient.html" title="class in org.apache.beam.sdk.util">PubsubClient</a></dt> +<dd> +<div class="block">Acknowldege messages from <code>subscription</code> with <code>ackIds</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubGrpcClient.html#acknowledge-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-java.util.List-">acknowledge(PubsubClient.SubscriptionPath, List<String>)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubGrpcClient.html" title="class in org.apache.beam.sdk.util">PubsubGrpcClient</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubJsonClient.html#acknowledge-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-java.util.List-">acknowledge(PubsubClient.SubscriptionPath, List<String>)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubJsonClient.html" title="class in org.apache.beam.sdk.util">PubsubJsonClient</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubTestClient.html#acknowledge-org.apache.beam.sdk.util.PubsubClient.SubscriptionPath-java.util.List-">acknowledge(PubsubClient.SubscriptionPath, List<String>)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubTestClient.html" title="class in org.apache.beam.sdk.util">PubsubTestClient</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/util/ActiveWindowSet.html" title="interface in org.apache.beam.sdk.util"><span class="typeNameLink">ActiveWindowSet</span></a><<a href="org/apache/beam/sdk/util/ActiveWindowSet.html" title="type parameter in ActiveWindowSet">W</a> extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>> - Interface in <a href="org/apache/beam/sdk/util/package-summary.html">org.apache.beam.sdk.util</a></dt> +<dd> +<div class="block">Track which windows are <i>active</i>, and the <i>state address window(s)</i> under which their + state is stored.</div> +</dd> +<dt><a href="org/apache/beam/sdk/util/ActiveWindowSet.MergeCallback.html" title="interface in org.apache.beam.sdk.util"><span class="typeNameLink">ActiveWindowSet.MergeCallback</span></a><<a href="org/apache/beam/sdk/util/ActiveWindowSet.MergeCallback.html" title="type parameter in ActiveWindowSet.MergeCallback">W</a> extends <a href="org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>> - Interface in <a href="org/apache/beam/sdk/util/package-summary.html">org.apache.beam.sdk.util</a></dt> +<dd> +<div class="block">Callback for <a href="org/apache/beam/sdk/util/ActiveWindowSet.html#merge-org.apache.beam.sdk.util.ActiveWindowSet.MergeCallback-"><code>ActiveWindowSet.merge(org.apache.beam.sdk.util.ActiveWindowSet.MergeCallback<W>)</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/DoFnAdapters.html#adaptContext-org.apache.beam.sdk.transforms.OldDoFn-org.apache.beam.sdk.transforms.DoFn.Context-">adaptContext(OldDoFn<InputT, OutputT>, DoFn<InputT, OutputT>.Context)</a></span> - Static method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/DoFnAdapters.html" title="class in org.apache.beam.sdk.transforms">DoFnAdapters</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span></div> +<div class="block">Creates a <a href="org/apache/beam/sdk/transforms/OldDoFn.ProcessContext.html" title="class in org.apache.beam.sdk.transforms"><code>OldDoFn.ProcessContext</code></a> from a <a href="org/apache/beam/sdk/transforms/DoFn.ProcessContext.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn.ProcessContext</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/DoFnAdapters.html#adaptProcessContext-org.apache.beam.sdk.transforms.OldDoFn-org.apache.beam.sdk.transforms.DoFn.ProcessContext-org.apache.beam.sdk.transforms.reflect.DoFnInvoker.ArgumentProvider-">adaptProcessContext(OldDoFn<InputT, OutputT>, DoFn<InputT, OutputT>.ProcessContext, DoFnInvoker.ArgumentProvider<InputT, OutputT>)</a></span> - Static method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/DoFnAdapters.html" title="class in org.apache.beam.sdk.transforms">DoFnAdapters</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span></div> +<div class="block">Creates a <a href="org/apache/beam/sdk/transforms/OldDoFn.ProcessContext.html" title="class in org.apache.beam.sdk.transforms"><code>OldDoFn.ProcessContext</code></a> from a <a href="org/apache/beam/sdk/transforms/DoFn.ProcessContext.html" title="class in org.apache.beam.sdk.transforms"><code>DoFn.ProcessContext</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/StateSpecs.html#adaptTagBinder-org.apache.beam.sdk.util.state.StateTag.StateBinder-">adaptTagBinder(StateTag.StateBinder<K>)</a></span> - Static method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/StateSpecs.html" title="class in org.apache.beam.sdk.util.state">StateSpecs</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">for migration purposes only</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/extensions/sorter/BufferedExternalSorter.html#add-org.apache.beam.sdk.values.KV-">add(KV<byte[], byte[]>)</a></span> - Method in class org.apache.beam.sdk.extensions.sorter.<a href="org/apache/beam/sdk/extensions/sorter/BufferedExternalSorter.html" title="class in org.apache.beam.sdk.extensions.sorter">BufferedExternalSorter</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique.html#add-java.lang.Long-">add(Long)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique.html" title="class in org.apache.beam.sdk.transforms">ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique</a></dt> +<dd> +<div class="block">Adds a value to the heap, returning whether the value is (large enough + to be) in the heap.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/display/DisplayData.Builder.html#add-org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec-">add(DisplayData.ItemSpec<?>)</a></span> - Method in interface org.apache.beam.sdk.transforms.display.<a href="org/apache/beam/sdk/transforms/display/DisplayData.Builder.html" title="interface in org.apache.beam.sdk.transforms.display">DisplayData.Builder</a></dt> +<dd> +<div class="block">Register the given display item.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/BucketingFunction.html#add-long-long-">add(long, long)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/BucketingFunction.html" title="class in org.apache.beam.sdk.util">BucketingFunction</a></dt> +<dd> +<div class="block">Add one sample of <code>value</code> (to bucket) at <code>timeMsSinceEpoch</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/MovingFunction.html#add-long-long-">add(long, long)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/MovingFunction.html" title="class in org.apache.beam.sdk.util">MovingFunction</a></dt> +<dd> +<div class="block">Add <code>value</code> at <code>nowMsSinceEpoch</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/CombiningState.html#add-InputT-">add(InputT)</a></span> - Method in interface org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/CombiningState.html" title="interface in org.apache.beam.sdk.util.state">CombiningState</a></dt> +<dd> +<div class="block">Add a value to the buffer.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryBag.html#add-T-">add(T)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryBag.html" title="class in org.apache.beam.sdk.util.state">InMemoryStateInternals.InMemoryBag</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryCombiningValue.html#add-InputT-">add(InputT)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryCombiningValue.html" title="class in org.apache.beam.sdk.util.state">InMemoryStateInternals.InMemoryCombiningValue</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryWatermarkHold.html#add-org.joda.time.Instant-">add(Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryWatermarkHold.html" title="class in org.apache.beam.sdk.util.state">InMemoryStateInternals.InMemoryWatermarkHold</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/AccumulatorCombiningState.html#addAccum-AccumT-">addAccum(AccumT)</a></span> - Method in interface org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/AccumulatorCombiningState.html" title="interface in org.apache.beam.sdk.util.state">AccumulatorCombiningState</a></dt> +<dd> +<div class="block">Add an accumulator to this combining value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryCombiningValue.html#addAccum-AccumT-">addAccum(AccumT)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryStateInternals.InMemoryCombiningValue.html" title="class in org.apache.beam.sdk.util.state">InMemoryStateInternals.InMemoryCombiningValue</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/spark/aggregators/AggAccumParam.html#addAccumulator-org.apache.beam.runners.spark.aggregators.NamedAggregators-org.apache.beam.runners.spark.aggregators.NamedAggregators-">addAccumulator(NamedAggregators, NamedAggregators)</a></span> - Method in class org.apache.beam.runners.spark.aggregators.<a href="org/apache/beam/runners/spark/aggregators/AggAccumParam.html" title="class in org.apache.beam.runners.spark.aggregators">AggAccumParam</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/ActiveWindowSet.html#addActiveForTesting-W-">addActiveForTesting(W)</a></span> - Method in interface org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/ActiveWindowSet.html" title="interface in org.apache.beam.sdk.util">ActiveWindowSet</a></dt> +<dd> +<div class="block">If <code>window</code> is not already known to be ACTIVE then add it as ACTIVE.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/MergingActiveWindowSet.html#addActiveForTesting-W-">addActiveForTesting(W)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/MergingActiveWindowSet.html" title="class in org.apache.beam.sdk.util">MergingActiveWindowSet</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/MergingActiveWindowSet.html#addActiveForTesting-W-java.lang.Iterable-">addActiveForTesting(W, Iterable<W>)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/MergingActiveWindowSet.html" title="class in org.apache.beam.sdk.util">MergingActiveWindowSet</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/NonMergingActiveWindowSet.html#addActiveForTesting-W-">addActiveForTesting(W)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/NonMergingActiveWindowSet.html" title="class in org.apache.beam.sdk.util">NonMergingActiveWindowSet</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addBoolean-java.util.Map-java.lang.String-boolean-">addBoolean(Map<String, Object>, String, boolean)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/ShardingWritableByteChannel.html#addChannel-java.nio.channels.WritableByteChannel-">addChannel(WritableByteChannel)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/ShardingWritableByteChannel.html" title="class in org.apache.beam.sdk.util">ShardingWritableByteChannel</a></dt> +<dd> +<div class="block">Adds another shard output channel.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addCollectionToSingletonOutput-org.apache.beam.sdk.values.PValue-org.apache.beam.sdk.values.PValue-">addCollectionToSingletonOutput(PValue, PValue)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an output to the previously added CollectionToSingleton Dataflow step, + consuming the specified input <code>PValue</code> and producing the specified output + <code>PValue</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/runners/TransformHierarchy.Node.html#addComposite-org.apache.beam.sdk.runners.TransformHierarchy.Node-">addComposite(TransformHierarchy.Node)</a></span> - Method in class org.apache.beam.sdk.runners.<a href="org/apache/beam/sdk/runners/TransformHierarchy.Node.html" title="class in org.apache.beam.sdk.runners">TransformHierarchy.Node</a></dt> +<dd> +<div class="block">Adds a composite operation to the transform node.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addDictionary-java.util.Map-java.lang.String-java.util.Map-">addDictionary(Map<String, Object>, String, Map<String, Object>)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addDouble-java.util.Map-java.lang.String-java.lang.Double-">addDouble(Map<String, Object>, String, Double)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/TestStream.Builder.html#addElements-T-T...-">addElements(T, T...)</a></span> - Method in class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/TestStream.Builder.html" title="class in org.apache.beam.sdk.testing">TestStream.Builder</a></dt> +<dd> +<div class="block">Adds the specified elements to the source with timestamp equal to the current watermark.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/TestStream.Builder.html#addElements-org.apache.beam.sdk.values.TimestampedValue-org.apache.beam.sdk.values.TimestampedValue...-">addElements(TimestampedValue<T>, TimestampedValue<T>...)</a></span> - Method in class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/TestStream.Builder.html" title="class in org.apache.beam.sdk.testing">TestStream.Builder</a></dt> +<dd> +<div class="block">Adds the specified elements to the source with the provided timestamps.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addEncodingInput-org.apache.beam.sdk.coders.Coder-">addEncodingInput(Coder<?>)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Sets the encoding for the current Dataflow step.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/display/DisplayData.Builder.html#addIfNotDefault-org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec-T-">addIfNotDefault(DisplayData.ItemSpec<T>, T)</a></span> - Method in interface org.apache.beam.sdk.transforms.display.<a href="org/apache/beam/sdk/transforms/display/DisplayData.Builder.html" title="interface in org.apache.beam.sdk.transforms.display">DisplayData.Builder</a></dt> +<dd> +<div class="block">Register the given display item if the value is different than the specified default.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/display/DisplayData.Builder.html#addIfNotNull-org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec-">addIfNotNull(DisplayData.ItemSpec<?>)</a></span> - Method in interface org.apache.beam.sdk.transforms.display.<a href="org/apache/beam/sdk/transforms/display/DisplayData.Builder.html" title="interface in org.apache.beam.sdk.transforms.display">DisplayData.Builder</a></dt> +<dd> +<div class="block">Register the given display item if the value is not null.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/spark/aggregators/AggAccumParam.html#addInPlace-org.apache.beam.runners.spark.aggregators.NamedAggregators-org.apache.beam.runners.spark.aggregators.NamedAggregators-">addInPlace(NamedAggregators, NamedAggregators)</a></span> - Method in class org.apache.beam.runners.spark.aggregators.<a href="org/apache/beam/runners/spark/aggregators/AggAccumParam.html" title="class in org.apache.beam.runners.spark.aggregators">AggAccumParam</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addInput-java.lang.String-java.lang.Boolean-">addInput(String, Boolean)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an input with the given name and value to the current + Dataflow step.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addInput-java.lang.String-java.lang.String-">addInput(String, String)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an input with the given name and value to the current + Dataflow step.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addInput-java.lang.String-java.lang.Long-">addInput(String, Long)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an input with the given name and value to the current + Dataflow step.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addInput-java.lang.String-org.apache.beam.sdk.values.PInput-">addInput(String, PInput)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an input with the given name to the previously added Dataflow + step, coming from the specified input PValue.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addInput-java.lang.String-java.util.Map-">addInput(String, Map<String, Object>)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an input that is a dictionary of strings to objects.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addInput-java.lang.String-java.util.List-">addInput(String, List<? extends Map<String, Object>>)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an input that is a list of objects.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/ApproximateUnique.ApproximateUniqueCombineFn.html#addInput-org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique-T-">addInput(ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique, T)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/ApproximateUnique.ApproximateUniqueCombineFn.html" title="class in org.apache.beam.sdk.transforms">ApproximateUnique.ApproximateUniqueCombineFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.Accumulator.html#addInput-InputT-">addInput(InputT)</a></span> - Method in interface org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.Accumulator.html" title="interface in org.apache.beam.sdk.transforms">Combine.AccumulatingCombineFn.Accumulator</a></dt> +<dd> +<div class="block">Adds the given input value to this accumulator, modifying + this accumulator.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.html#addInput-AccumT-InputT-">addInput(AccumT, InputT)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.AccumulatingCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.AccumulatingCombineFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineDoubleFn.html#addInput-double:A-java.lang.Double-">addInput(double[], Double)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineDoubleFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineDoubleFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineFn.html#addInput-org.apache.beam.sdk.transforms.Combine.Holder-V-">addInput(Combine.Holder<V>, V)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineIntegerFn.html#addInput-int:A-java.lang.Integer-">addInput(int[], Integer)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineIntegerFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineIntegerFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineLongFn.html#addInput-long:A-java.lang.Long-">addInput(long[], Long)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.BinaryCombineLongFn.html" title="class in org.apache.beam.sdk.transforms">Combine.BinaryCombineLongFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.CombineFn.html#addInput-AccumT-InputT-">addInput(AccumT, InputT)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.CombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.CombineFn</a></dt> +<dd> +<div class="block">Adds the given input value to the given accumulator, returning the + new accumulator value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.IterableCombineFn.html#addInput-java.util.List-V-">addInput(List<V>, V)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.IterableCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.IterableCombineFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Combine.KeyedCombineFn.html#addInput-K-AccumT-InputT-">addInput(K, AccumT, InputT)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Combine.KeyedCombineFn.html" title="class in org.apache.beam.sdk.transforms">Combine.KeyedCombineFn</a></dt> +<dd> +<div class="block">Adds the given input value to the given accumulator, returning the new accumulator value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/CombineFns.ComposedCombineFn.html#addInput-java.lang.Object:A-DataT-">addInput(Object[], DataT)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/CombineFns.ComposedCombineFn.html" title="class in org.apache.beam.sdk.transforms">CombineFns.ComposedCombineFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/CombineFns.ComposedCombineFnWithContext.html#addInput-java.lang.Object:A-DataT-org.apache.beam.sdk.transforms.CombineWithContext.Context-">addInput(Object[], DataT, CombineWithContext.Context)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/CombineFns.ComposedCombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms">CombineFns.ComposedCombineFnWithContext</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/CombineFns.ComposedKeyedCombineFn.html#addInput-K-java.lang.Object:A-DataT-">addInput(K, Object[], DataT)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/CombineFns.ComposedKeyedCombineFn.html" title="class in org.apache.beam.sdk.transforms">CombineFns.ComposedKeyedCombineFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/CombineFns.ComposedKeyedCombineFnWithContext.html#addInput-K-java.lang.Object:A-DataT-org.apache.beam.sdk.transforms.CombineWithContext.Context-">addInput(K, Object[], DataT, CombineWithContext.Context)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/CombineFns.ComposedKeyedCombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms">CombineFns.ComposedKeyedCombineFnWithContext</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/CombineWithContext.CombineFnWithContext.html#addInput-AccumT-InputT-org.apache.beam.sdk.transforms.CombineWithContext.Context-">addInput(AccumT, InputT, CombineWithContext.Context)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/CombineWithContext.CombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms">CombineWithContext.CombineFnWithContext</a></dt> +<dd> +<div class="block">Adds the given input value to the given accumulator, returning the + new accumulator value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/CombineWithContext.KeyedCombineFnWithContext.html#addInput-K-AccumT-InputT-org.apache.beam.sdk.transforms.CombineWithContext.Context-">addInput(K, AccumT, InputT, CombineWithContext.Context)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/CombineWithContext.KeyedCombineFnWithContext.html" title="class in org.apache.beam.sdk.transforms">CombineWithContext.KeyedCombineFnWithContext</a></dt> +<dd> +<div class="block">Adds the given input value to the given accumulator, returning the new accumulator value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Latest.LatestFn.html#addInput-org.apache.beam.sdk.values.TimestampedValue-org.apache.beam.sdk.values.TimestampedValue-">addInput(TimestampedValue<T>, TimestampedValue<T>)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Latest.LatestFn.html" title="class in org.apache.beam.sdk.transforms">Latest.LatestFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Sample.FixedSizedSampleFn.html#addInput-org.apache.beam.sdk.transforms.Top.BoundedHeap-T-">addInput(Top.BoundedHeap<KV<Integer, T>, SerializableComparator<KV<Integer, T>>>, T)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Sample.FixedSizedSampleFn.html" title="class in org.apache.beam.sdk.transforms">Sample.FixedSizedSampleFn</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PerKeyCombineFnRunner.html#addInput-K-AccumT-InputT-org.apache.beam.sdk.transforms.OldDoFn.ProcessContext-">addInput(K, AccumT, InputT, OldDoFn<?, ?>.ProcessContext)</a></span> - Method in interface org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PerKeyCombineFnRunner.html" title="interface in org.apache.beam.sdk.util">PerKeyCombineFnRunner</a></dt> +<dd> +<div class="block">Forwards the call to a <a href="org/apache/beam/sdk/transforms/CombineFnBase.PerKeyCombineFn.html" title="interface in org.apache.beam.sdk.transforms"><code>CombineFnBase.PerKeyCombineFn</code></a> to add the input in a <a href="org/apache/beam/sdk/transforms/OldDoFn.html" title="class in org.apache.beam.sdk.transforms"><code>OldDoFn</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PerKeyCombineFnRunner.html#addInput-K-AccumT-InputT-org.apache.beam.sdk.options.PipelineOptions-org.apache.beam.sdk.util.SideInputReader-java.util.Collection-">addInput(K, AccumT, InputT, PipelineOptions, SideInputReader, Collection<? extends BoundedWindow>)</a></span> - Method in interface org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PerKeyCombineFnRunner.html" title="interface in org.apache.beam.sdk.util">PerKeyCombineFnRunner</a></dt> +<dd> +<div class="block">Forwards the call to a <a href="org/apache/beam/sdk/transforms/CombineFnBase.PerKeyCombineFn.html" title="interface in org.apache.beam.sdk.transforms"><code>CombineFnBase.PerKeyCombineFn</code></a> to add the input.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PerKeyCombineFnRunner.html#addInputs-K-java.lang.Iterable-org.apache.beam.sdk.transforms.OldDoFn.ProcessContext-">addInputs(K, Iterable<InputT>, OldDoFn<?, ?>.ProcessContext)</a></span> - Method in interface org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PerKeyCombineFnRunner.html" title="interface in org.apache.beam.sdk.util">PerKeyCombineFnRunner</a></dt> +<dd> +<div class="block">Forwards the call to a <a href="org/apache/beam/sdk/transforms/CombineFnBase.PerKeyCombineFn.html" title="interface in org.apache.beam.sdk.transforms"><code>CombineFnBase.PerKeyCombineFn</code></a> to add all inputs in a <a href="org/apache/beam/sdk/transforms/OldDoFn.html" title="class in org.apache.beam.sdk.transforms"><code>OldDoFn</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addList-java.util.Map-java.lang.String-java.util.List-">addList(Map<String, Object>, String, List<? extends Map<String, Object>>)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addList-java.util.Map-java.lang.String-T:A-">addList(Map<String, Object>, String, T[])</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addLong-java.util.Map-java.lang.String-long-">addLong(Map<String, Object>, String, long)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addLongs-java.util.Map-java.lang.String-long...-">addLongs(Map<String, Object>, String, long...)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/jms/JmsCheckpointMark.html#addMessage-javax.jms.Message-">addMessage(Message)</a></span> - Method in class org.apache.beam.sdk.io.jms.<a href="org/apache/beam/sdk/io/jms/JmsCheckpointMark.html" title="class in org.apache.beam.sdk.io.jms">JmsCheckpointMark</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/metrics/MetricsFilter.Builder.html#addNameFilter-org.apache.beam.sdk.metrics.MetricNameFilter-">addNameFilter(MetricNameFilter)</a></span> - Method in class org.apache.beam.sdk.metrics.<a href="org/apache/beam/sdk/metrics/MetricsFilter.Builder.html" title="class in org.apache.beam.sdk.metrics">MetricsFilter.Builder</a></dt> +<dd> +<div class="block">Add a <a href="org/apache/beam/sdk/metrics/MetricNameFilter.html" title="class in org.apache.beam.sdk.metrics"><code>MetricNameFilter</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addNull-java.util.Map-java.lang.String-">addNull(Map<String, Object>, String)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addObject-java.util.Map-java.lang.String-java.util.Map-">addObject(Map<String, Object>, String, Map<String, Object>)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/common/ElementByteSizeObservableIterable.html#addObserver-java.util.Observer-">addObserver(Observer)</a></span> - Method in class org.apache.beam.sdk.util.common.<a href="org/apache/beam/sdk/util/common/ElementByteSizeObservableIterable.html" title="class in org.apache.beam.sdk.util.common">ElementByteSizeObservableIterable</a></dt> +<dd> +<div class="block">Sets the observer, which will observe the iterator returned in + the next call to iterator() method.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addOutput-org.apache.beam.sdk.values.PValue-">addOutput(PValue)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an output to the previously added Dataflow step, + producing the specified output <code>PValue</code>, + including its <code>Coder</code> if a <code>TypedPValue</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html#addOutput-org.apache.beam.runners.direct.DirectRunner.UncommittedBundle-org.apache.beam.runners.direct.DirectRunner.UncommittedBundle...-">addOutput(DirectRunner.UncommittedBundle<?>, DirectRunner.UncommittedBundle<?>...)</a></span> - Method in class org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html" title="class in org.apache.beam.runners.direct">StepTransformResult.Builder</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html#addOutput-java.util.Collection-">addOutput(Collection<DirectRunner.UncommittedBundle<?>>)</a></span> - Method in class org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html" title="class in org.apache.beam.runners.direct">StepTransformResult.Builder</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.WorkerLogLevelOverrides.html#addOverrideForClass-java.lang.Class-org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.Level-">addOverrideForClass(Class<?>, DataflowWorkerLoggingOptions.Level)</a></span> - Method in class org.apache.beam.runners.dataflow.options.<a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.WorkerLogLevelOverrides.html" title="class in org.apache.beam.runners.dataflow.options">DataflowWorkerLoggingOptions.WorkerLogLevelOverrides</a></dt> +<dd> +<div class="block">Overrides the default log level for the passed in class.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.WorkerLogLevelOverrides.html#addOverrideForName-java.lang.String-org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.Level-">addOverrideForName(String, DataflowWorkerLoggingOptions.Level)</a></span> - Method in class org.apache.beam.runners.dataflow.options.<a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.WorkerLogLevelOverrides.html" title="class in org.apache.beam.runners.dataflow.options">DataflowWorkerLoggingOptions.WorkerLogLevelOverrides</a></dt> +<dd> +<div class="block">Overrides the default log level for the passed in name.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.WorkerLogLevelOverrides.html#addOverrideForPackage-java.lang.Package-org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.Level-">addOverrideForPackage(Package, DataflowWorkerLoggingOptions.Level)</a></span> - Method in class org.apache.beam.runners.dataflow.options.<a href="org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.WorkerLogLevelOverrides.html" title="class in org.apache.beam.runners.dataflow.options">DataflowWorkerLoggingOptions.WorkerLogLevelOverrides</a></dt> +<dd> +<div class="block">Overrides the default log level for the passed in package.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/core/SideInputHandler.html#addSideInputValue-org.apache.beam.sdk.values.PCollectionView-org.apache.beam.sdk.util.WindowedValue-">addSideInputValue(PCollectionView<?>, WindowedValue<Iterable<?>>)</a></span> - Method in class org.apache.beam.runners.core.<a href="org/apache/beam/runners/core/SideInputHandler.html" title="class in org.apache.beam.runners.core">SideInputHandler</a></dt> +<dd> +<div class="block">Add the given value to the internal side-input store of the given side input.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addStep-org.apache.beam.sdk.transforms.PTransform-java.lang.String-">addStep(PTransform<?, ?>, String)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds a step to the Dataflow workflow for the given transform, with + the given Dataflow step type.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addStep-org.apache.beam.sdk.transforms.PTransform-com.google.api.services.dataflow.model.Step-">addStep(PTransform<?, ? extends PValue>, Step)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds a pre-defined step to the Dataflow workflow.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/metrics/MetricsFilter.Builder.html#addStep-java.lang.String-">addStep(String)</a></span> - Method in class org.apache.beam.sdk.metrics.<a href="org/apache/beam/sdk/metrics/MetricsFilter.Builder.html" title="class in org.apache.beam.sdk.metrics">MetricsFilter.Builder</a></dt> +<dd> +<div class="block">Add a step filter.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addString-java.util.Map-java.lang.String-java.lang.String-">addString(Map<String, Object>, String, String)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/Structs.html#addStringList-java.util.Map-java.lang.String-java.util.List-">addStringList(Map<String, Object>, String, List<String>)</a></span> - Static method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/Structs.html" title="class in org.apache.beam.sdk.util">Structs</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/options/GoogleApiDebugOptions.GoogleApiTracer.html#addTraceFor-com.google.api.client.googleapis.services.AbstractGoogleClient-java.lang.String-">addTraceFor(AbstractGoogleClient, String)</a></span> - Method in class org.apache.beam.sdk.options.<a href="org/apache/beam/sdk/options/GoogleApiDebugOptions.GoogleApiTracer.html" title="class in org.apache.beam.sdk.options">GoogleApiDebugOptions.GoogleApiTracer</a></dt> +<dd> +<div class="block">Creates a <a href="org/apache/beam/sdk/options/GoogleApiDebugOptions.GoogleApiTracer.html" title="class in org.apache.beam.sdk.options"><code>GoogleApiDebugOptions.GoogleApiTracer</code></a> that sets the trace destination on all + calls that match the given client type.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/options/GoogleApiDebugOptions.GoogleApiTracer.html#addTraceFor-com.google.api.client.googleapis.services.AbstractGoogleClientRequest-java.lang.String-">addTraceFor(AbstractGoogleClientRequest<?>, String)</a></span> - Method in class org.apache.beam.sdk.options.<a href="org/apache/beam/sdk/options/GoogleApiDebugOptions.GoogleApiTracer.html" title="class in org.apache.beam.sdk.options">GoogleApiDebugOptions.GoogleApiTracer</a></dt> +<dd> +<div class="block">Creates a <a href="org/apache/beam/sdk/options/GoogleApiDebugOptions.GoogleApiTracer.html" title="class in org.apache.beam.sdk.options"><code>GoogleApiDebugOptions.GoogleApiTracer</code></a> that sets the trace <code>traceDestination</code> on all + calls that match for the given request type.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html#addUnprocessedElements-org.apache.beam.sdk.util.WindowedValue...-">addUnprocessedElements(WindowedValue<InputT>...)</a></span> - Method in class org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html" title="class in org.apache.beam.runners.direct">StepTransformResult.Builder</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html#addUnprocessedElements-java.lang.Iterable-">addUnprocessedElements(Iterable<? extends WindowedValue<InputT>>)</a></span> - Method in class org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/StepTransformResult.Builder.html" title="class in org.apache.beam.runners.direct">StepTransformResult.Builder</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Aggregator.html#addValue-InputT-">addValue(InputT)</a></span> - Method in interface org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Aggregator.html" title="interface in org.apache.beam.sdk.transforms">Aggregator</a></dt> +<dd> +<div class="block">Adds a new value into the Aggregator.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html#addValueOnlyOutput-org.apache.beam.sdk.values.PValue-">addValueOnlyOutput(PValue)</a></span> - Method in interface org.apache.beam.runners.dataflow.<a href="org/apache/beam/runners/dataflow/DataflowPipelineTranslator.TranslationContext.html" title="interface in org.apache.beam.runners.dataflow">DataflowPipelineTranslator.TranslationContext</a></dt> +<dd> +<div class="block">Adds an output to the previously added Dataflow step, + producing the specified output <code>PValue</code>, + including its <code>Coder</code> if a <code>TypedPValue</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/spark/io/MicrobatchSource.Reader.html#advance--">advance()</a></span> - Method in class org.apache.beam.runners.spark.io.<a href="org/apache/beam/runners/spark/io/MicrobatchSource.Reader.html" title="class in org.apache.beam.runners.spark.io">MicrobatchSource.Reader</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/OffsetBasedSource.OffsetBasedReader.html#advance--">advance()</a></span> - Method in class org.apache.beam.sdk.io.<a href="org/apache/beam/sdk/io/OffsetBasedSource.OffsetBasedReader.html" title="class in org.apache.beam.sdk.io">OffsetBasedSource.OffsetBasedReader</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/Source.Reader.html#advance--">advance()</a></span> - Method in class org.apache.beam.sdk.io.<a href="org/apache/beam/sdk/io/Source.Reader.html" title="class in org.apache.beam.sdk.io">Source.Reader</a></dt> +<dd> +<div class="block">Advances the reader to the next valid record.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/UnboundedSource.UnboundedReader.html#advance--">advance()</a></span> - Method in class org.apache.beam.sdk.io.<a href="org/apache/beam/sdk/io/UnboundedSource.UnboundedReader.html" title="class in org.apache.beam.sdk.io">UnboundedSource.UnboundedReader</a></dt> +<dd> +<div class="block">Advances the reader to the next valid record.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/common/ElementByteSizeObserver.html#advance--">advance()</a></span> - Method in class org.apache.beam.sdk.util.common.<a href="org/apache/beam/sdk/util/common/ElementByteSizeObserver.html" title="class in org.apache.beam.sdk.util.common">ElementByteSizeObserver</a></dt> +<dd> +<div class="block">Advances the observer to the next element.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PubsubTestClient.html#advance--">advance()</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PubsubTestClient.html" title="class in org.apache.beam.sdk.util">PubsubTestClient</a></dt> +<dd> +<div class="block">For subscription mode only: + Track progression of time according to the <code>Clock</code> passed .</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/FileBasedSource.FileBasedReader.html#advanceImpl--">advanceImpl()</a></span> - Method in class org.apache.beam.sdk.io.<a href="org/apache/beam/sdk/io/FileBasedSource.FileBasedReader.html" title="class in org.apache.beam.sdk.io">FileBasedSource.FileBasedReader</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/OffsetBasedSource.OffsetBasedReader.html#advanceImpl--">advanceImpl()</a></span> - Method in class org.apache.beam.sdk.io.<a href="org/apache/beam/sdk/io/OffsetBasedSource.OffsetBasedReader.html" title="class in org.apache.beam.sdk.io">OffsetBasedSource.OffsetBasedReader</a></dt> +<dd> +<div class="block">Advances to the next record and returns <code>true</code>, or returns false if there is no next + record.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/DoFnTester.html#advanceInputWatermark-org.joda.time.Instant-">advanceInputWatermark(Instant)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/DoFnTester.html" title="class in org.apache.beam.sdk.transforms">DoFnTester</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html#advanceInputWatermark-org.joda.time.Instant-">advanceInputWatermark(Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html" title="class in org.apache.beam.sdk.util.state">InMemoryTimerInternals</a></dt> +<dd> +<div class="block">Advances input watermark to the given value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html#advanceInputWatermark-org.apache.beam.sdk.util.state.TimerCallback-org.joda.time.Instant-">advanceInputWatermark(TimerCallback, Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html" title="class in org.apache.beam.sdk.util.state">InMemoryTimerInternals</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Use advanceInputWatermark without callback and fireEventTimers.</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html#advanceOutputWatermark-org.joda.time.Instant-">advanceOutputWatermark(Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html" title="class in org.apache.beam.sdk.util.state">InMemoryTimerInternals</a></dt> +<dd> +<div class="block">Advances output watermark to the given value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/TestStream.Builder.html#advanceProcessingTime-org.joda.time.Duration-">advanceProcessingTime(Duration)</a></span> - Method in class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/TestStream.Builder.html" title="class in org.apache.beam.sdk.testing">TestStream.Builder</a></dt> +<dd> +<div class="block">Advance the processing time by the specified amount.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/DoFnTester.html#advanceProcessingTime-org.joda.time.Instant-">advanceProcessingTime(Instant)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/DoFnTester.html" title="class in org.apache.beam.sdk.transforms">DoFnTester</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html#advanceProcessingTime-org.joda.time.Instant-">advanceProcessingTime(Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html" title="class in org.apache.beam.sdk.util.state">InMemoryTimerInternals</a></dt> +<dd> +<div class="block">Advances processing time to the given value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html#advanceProcessingTime-org.apache.beam.sdk.util.state.TimerCallback-org.joda.time.Instant-">advanceProcessingTime(TimerCallback, Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html" title="class in org.apache.beam.sdk.util.state">InMemoryTimerInternals</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Use advanceProcessingTime without callback and fireProcessingTimers.</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html#advanceSynchronizedProcessingTime-org.joda.time.Instant-">advanceSynchronizedProcessingTime(Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html" title="class in org.apache.beam.sdk.util.state">InMemoryTimerInternals</a></dt> +<dd> +<div class="block">Advances synchronized processing time to the given value.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html#advanceSynchronizedProcessingTime-org.apache.beam.sdk.util.state.TimerCallback-org.joda.time.Instant-">advanceSynchronizedProcessingTime(TimerCallback, Instant)</a></span> - Method in class org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/InMemoryTimerInternals.html" title="class in org.apache.beam.sdk.util.state">InMemoryTimerInternals</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">Use advanceInputWatermark without callback and fireSynchronizedProcessingTimers.</span></div> +</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/TestStream.Builder.html#advanceWatermarkTo-org.joda.time.Instant-">advanceWatermarkTo(Instant)</a></span> - Method in class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/TestStream.Builder.html" title="class in org.apache.beam.sdk.testing">TestStream.Builder</a></dt> +<dd> +<div class="block">Advance the watermark of this source to the specified instant.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/TestStream.Builder.html#advanceWatermarkToInfinity--">advanceWatermarkToInfinity()</a></span> - Method in class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/TestStream.Builder.html" title="class in org.apache.beam.sdk.testing">TestStream.Builder</a></dt> +<dd> +<div class="block">Advance the watermark to infinity, completing this <a href="org/apache/beam/sdk/testing/TestStream.html" title="class in org.apache.beam.sdk.testing"><code>TestStream</code></a>.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterAll.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterAll</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block">Create a <a href="org/apache/beam/sdk/transforms/windowing/Trigger.html" title="class in org.apache.beam.sdk.transforms.windowing"><code>Trigger</code></a> that fires and finishes once after all of its sub-triggers have fired.</div> +</dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterAllStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterAllStateMachine</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block">A <a href="org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine</code></a> that fires and finishes once after all of its sub-triggers + have fired.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterDelayFromFirstElement</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block">A base class for triggers that happen after a processing time delay from the arrival + of the first element in a pane.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.html#AfterDelayFromFirstElement-org.apache.beam.sdk.util.TimeDomain-java.util.List-">AfterDelayFromFirstElement(TimeDomain, List<SerializableFunction<Instant, Instant>>)</a></span> - Constructor for class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/AfterDelayFromFirstElement.html" title="class in org.apache.beam.sdk.transforms.windowing">AfterDelayFromFirstElement</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterDelayFromFirstElementStateMachine</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block">A base class for triggers that happen after a processing time delay from the arrival + of the first element in a pane.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.html#AfterDelayFromFirstElementStateMachine-org.apache.beam.sdk.util.TimeDomain-java.util.List-">AfterDelayFromFirstElementStateMachine(TimeDomain, List<SerializableFunction<Instant, Instant>>)</a></span> - Constructor for class org.apache.beam.runners.core.triggers.<a href="org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.html" title="class in org.apache.beam.runners.core.triggers">AfterDelayFromFirstElementStateMachine</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterEach.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterEach</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block">A composite <a href="org/apache/beam/sdk/transforms/windowing/Trigger.html" title="class in org.apache.beam.sdk.transforms.windowing"><code>Trigger</code></a> that executes its sub-triggers in order.</div> +</dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterEachStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterEachStateMachine</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block">A composite <a href="org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine</code></a> that executes its sub-triggers in order.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/ModelEnforcement.html#afterElement-org.apache.beam.sdk.util.WindowedValue-">afterElement(WindowedValue<T>)</a></span> - Method in interface org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/ModelEnforcement.html" title="interface in org.apache.beam.runners.direct">ModelEnforcement</a></dt> +<dd> +<div class="block">Called after a call to <a href="org/apache/beam/runners/direct/TransformEvaluator.html#processElement-org.apache.beam.sdk.util.WindowedValue-"><code>TransformEvaluator.processElement(WindowedValue)</code></a> on the + provided <a href="org/apache/beam/sdk/util/WindowedValue.html" title="class in org.apache.beam.sdk.util"><code>WindowedValue</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/ModelEnforcement.html#afterFinish-org.apache.beam.runners.direct.DirectRunner.CommittedBundle-org.apache.beam.runners.direct.TransformResult-java.lang.Iterable-">afterFinish(DirectRunner.CommittedBundle<T>, TransformResult<T>, Iterable<? extends DirectRunner.CommittedBundle<?>>)</a></span> - Method in interface org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/ModelEnforcement.html" title="interface in org.apache.beam.runners.direct">ModelEnforcement</a></dt> +<dd> +<div class="block">Called after a bundle has been completed and <a href="org/apache/beam/runners/direct/TransformEvaluator.html#finishBundle--"><code>TransformEvaluator.finishBundle()</code></a> has been + called, producing the provided <a href="org/apache/beam/runners/direct/TransformResult.html" title="interface in org.apache.beam.runners.direct"><code>TransformResult</code></a> and + <code>output bundles</code>.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterFirst.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterFirst</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block">Create a composite <a href="org/apache/beam/sdk/transforms/windowing/Trigger.html" title="class in org.apache.beam.sdk.transforms.windowing"><code>Trigger</code></a> that fires once after at least one of its sub-triggers have + fired.</div> +</dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterFirstStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterFirstStateMachine</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block">Create a composite <a href="org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine</code></a> that fires once after at least one of its + sub-triggers have fired.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterPane.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterPane</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block"><a href="org/apache/beam/sdk/transforms/windowing/Trigger.html" title="class in org.apache.beam.sdk.transforms.windowing"><code>Trigger</code></a>s that fire based on properties of the elements in the current pane.</div> +</dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterPaneStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterPaneStateMachine</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block"><a href="org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine</code></a>s that fire based on properties of the elements in the current pane.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterProcessingTime</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block"><code>AfterProcessingTime</code> triggers fire based on the current processing time.</div> +</dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterProcessingTimeStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterProcessingTimeStateMachine</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block"><code>AfterProcessingTime</code> triggers fire based on the current processing time.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterSynchronizedProcessingTime</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block">A trigger that fires after synchronized processing time has reached a shared + threshold between upstream workers.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.html#AfterSynchronizedProcessingTime--">AfterSynchronizedProcessingTime()</a></span> - Constructor for class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.html" title="class in org.apache.beam.sdk.transforms.windowing">AfterSynchronizedProcessingTime</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterWatermark.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterWatermark</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block"><code>AfterWatermark</code> triggers fire based on progress of the system watermark.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterWatermark.AfterWatermarkEarlyAndLate.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterWatermark.AfterWatermarkEarlyAndLate</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/transforms/windowing/AfterWatermark.FromEndOfWindow.html" title="class in org.apache.beam.sdk.transforms.windowing"><span class="typeNameLink">AfterWatermark.FromEndOfWindow</span></a> - Class in <a href="org/apache/beam/sdk/transforms/windowing/package-summary.html">org.apache.beam.sdk.transforms.windowing</a></dt> +<dd> +<div class="block">A watermark trigger targeted relative to the end of the window.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/AfterWatermark.AfterWatermarkEarlyAndLate.html#AfterWatermarkEarlyAndLate-org.apache.beam.sdk.transforms.windowing.Trigger.OnceTrigger-org.apache.beam.sdk.transforms.windowing.Trigger.OnceTrigger-">AfterWatermarkEarlyAndLate(Trigger.OnceTrigger, Trigger.OnceTrigger)</a></span> - Constructor for class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/AfterWatermark.AfterWatermarkEarlyAndLate.html" title="class in org.apache.beam.sdk.transforms.windowing">AfterWatermark.AfterWatermarkEarlyAndLate</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterWatermarkStateMachine</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block"><code>AfterWatermark</code> triggers fire based on progress of the system watermark.</div> +</dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.FromEndOfWindow.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">AfterWatermarkStateMachine.FromEndOfWindow</span></a> - Class in <a href="org/apache/beam/runners/core/triggers/package-summary.html">org.apache.beam.runners.core.triggers</a></dt> +<dd> +<div class="block">A watermark trigger targeted relative to the end of the window.</div> +</dd> +<dt><a href="org/apache/beam/runners/spark/aggregators/AggAccumParam.html" title="class in org.apache.beam.runners.spark.aggregators"><span class="typeNameLink">AggAccumParam</span></a> - Class in <a href="org/apache/beam/runners/spark/aggregators/package-summary.html">org.apache.beam.runners.spark.aggregators</a></dt> +<dd> +<div class="block">Aggregator accumulator param.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/spark/aggregators/AggAccumParam.html#AggAccumParam--">AggAccumParam()</a></span> - Constructor for class org.apache.beam.runners.spark.aggregators.<a href="org/apache/beam/runners/spark/aggregators/AggAccumParam.html" title="class in org.apache.beam.runners.spark.aggregators">AggAccumParam</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/transforms/Aggregator.html" title="interface in org.apache.beam.sdk.transforms"><span class="typeNameLink">Aggregator</span></a><<a href="org/apache/beam/sdk/transforms/Aggregator.html" title="type parameter in Aggregator">InputT</a>,<a href="org/apache/beam/sdk/transforms/Aggregator.html" title="type parameter in Aggregator">OutputT</a>> - Interface in <a href="org/apache/beam/sdk/transforms/package-summary.html">org.apache.beam.sdk.transforms</a></dt> +<dd> +<div class="block">An <code>Aggregator<InputT></code> enables monitoring of values of type <code>InputT</code>, + to be combined across all bundles.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/Aggregator.AggregatorFactory.html" title="interface in org.apache.beam.sdk.transforms"><span class="typeNameLink">Aggregator.AggregatorFactory</span></a> - Interface in <a href="org/apache/beam/sdk/transforms/package-summary.html">org.apache.beam.sdk.transforms</a></dt> +<dd> +<div class="block"><span class="deprecatedLabel">Deprecated.</span> +<div class="block"><span class="deprecationComment">this is for use only by runners and exists only for a migration period. Please + use the identical interface in org.apache.beam.runners.core</span></div> +</div> +</dd> +<dt><a href="org/apache/beam/runners/direct/AggregatorContainer.html" title="class in org.apache.beam.runners.direct"><span class="typeNameLink">AggregatorContainer</span></a> - Class in <a href="org/apache/beam/runners/direct/package-summary.html">org.apache.beam.runners.direct</a></dt> +<dd> +<div class="block">AccumT container for the current values associated with <a href="org/apache/beam/sdk/transforms/Aggregator.html" title="interface in org.apache.beam.sdk.transforms"><code>Aggregators</code></a>.</div> +</dd> +<dt><a href="org/apache/beam/runners/direct/AggregatorContainer.AggregatorKey.html" title="class in org.apache.beam.runners.direct"><span class="typeNameLink">AggregatorContainer.AggregatorKey</span></a> - Class in <a href="org/apache/beam/runners/direct/package-summary.html">org.apache.beam.runners.direct</a></dt> +<dd> +<div class="block">Aggregators are identified by a step name and an aggregator name.</div> +</dd> +<dt><a href="org/apache/beam/runners/direct/AggregatorContainer.Mutator.html" title="class in org.apache.beam.runners.direct"><span class="typeNameLink">AggregatorContainer.Mutator</span></a> - Class in <a href="org/apache/beam/runners/direct/package-summary.html">org.apache.beam.runners.direct</a></dt> +<dd> +<div class="block">AccumT class for mutations to the aggregator values.</div> +</dd> +<dt><a href="org/apache/beam/runners/core/AggregatorFactory.html" title="interface in org.apache.beam.runners.core"><span class="typeNameLink">AggregatorFactory</span></a> - Interface in <a href="org/apache/beam/runners/core/package-summary.html">org.apache.beam.runners.core</a></dt> +<dd> +<div class="block">A factory for creating aggregators.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/AggregatorContainer.AggregatorKey.html#AggregatorKey--">AggregatorKey()</a></span> - Constructor for class org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/AggregatorContainer.AggregatorKey.html" title="class in org.apache.beam.runners.direct">AggregatorContainer.AggregatorKey</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/spark/aggregators/metrics/AggregatorMetric.html" title="class in org.apache.beam.runners.spark.aggregators.metrics"><span class="typeNameLink">AggregatorMetric</span></a> - Class in <a href="org/apache/beam/runners/spark/aggregators/metrics/package-summary.html">org.apache.beam.runners.spark.aggregators.metrics</a></dt> +<dd> +<div class="block">An adapter between the <a href="org/apache/beam/runners/spark/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.aggregators"><code>NamedAggregators</code></a> and codahale's <code>Metric</code> + interface.</div> +</dd> +<dt><a href="org/apache/beam/runners/spark/aggregators/metrics/AggregatorMetricSource.html" title="class in org.apache.beam.runners.spark.aggregators.metrics"><span class="typeNameLink">AggregatorMetricSource</span></a> - Class in <a href="org/apache/beam/runners/spark/aggregators/metrics/package-summary.html">org.apache.beam.runners.spark.aggregators.metrics</a></dt> +<dd> +<div class="block">A Spark <code>Source</code> that is tailored to expose an <a href="org/apache/beam/runners/spark/aggregators/metrics/AggregatorMetric.html" title="class in org.apache.beam.runners.spark.aggregators.metrics"><code>AggregatorMetric</code></a>, + wrapping an underlying <a href="org/apache/beam/runners/spark/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.aggregators"><code>NamedAggregators</code></a> instance.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/spark/aggregators/metrics/AggregatorMetricSource.html#AggregatorMetricSource-java.lang.String-org.apache.beam.runners.spark.aggregators.NamedAggregators-">AggregatorMetricSource(String, NamedAggregators)</a></span> - Constructor for class org.apache.beam.runners.spark.aggregators.metrics.<a href="org/apache/beam/runners/spark/aggregators/metrics/AggregatorMetricSource.html" title="class in org.apache.beam.runners.spark.aggregators.metrics">AggregatorMetricSource</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/direct/AggregatorContainer.AggregatorKey.html#aggregatorName--">aggregatorName()</a></span> - Method in class org.apache.beam.runners.direct.<a href="org/apache/beam/runners/direct/AggregatorContainer.AggregatorKey.html" title="class in org.apache.beam.runners.direct">AggregatorContainer.AggregatorKey</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/AggregatorRetrievalException.html" title="class in org.apache.beam.sdk"><span class="typeNameLink">AggregatorRetrievalException</span></a> - Exception in <a href="org/apache/beam/sdk/package-summary.html">org.apache.beam.sdk</a></dt> +<dd> +<div class="block">Signals that an exception has occurred while retrieving <a href="org/apache/beam/sdk/transforms/Aggregator.html" title="interface in org.apache.beam.sdk.transforms"><code>Aggregator</code></a>s.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/AggregatorRetrievalException.html#AggregatorRetrievalException-java.lang.String-java.lang.Throwable-">AggregatorRetrievalException(String, Throwable)</a></span> - Constructor for exception org.apache.beam.sdk.<a href="org/apache/beam/sdk/AggregatorRetrievalException.html" title="class in org.apache.beam.sdk">AggregatorRetrievalException</a></dt> +<dd> +<div class="block">Constructs a new <code>AggregatorRetrievalException</code> with the specified detail message and + cause.</div> +</dd> +<dt><a href="org/apache/beam/sdk/transforms/AggregatorRetriever.html" title="class in org.apache.beam.sdk.transforms"><span class="typeNameLink">AggregatorRetriever</span></a> - Class in <a href="org/apache/beam/sdk/transforms/package-summary.html">org.apache.beam.sdk.transforms</a></dt> +<dd> +<div class="block">An internal class for extracting <a href="org/apache/beam/sdk/transforms/Aggregator.html" title="interface in org.apache.beam.sdk.transforms"><code>Aggregators</code></a> from <a href="org/apache/beam/sdk/transforms/OldDoFn.html" title="class in org.apache.beam.sdk.transforms"><code>DoFns</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/DoFn.html#aggregators">aggregators</a></span> -
<TRUNCATED>
