http://git-wip-us.apache.org/repos/asf/beam-site/blob/dc04d667/content/documentation/sdks/javadoc/0.6.0/index-all.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.6.0/index-all.html b/content/documentation/sdks/javadoc/0.6.0/index-all.html new file mode 100644 index 0000000..eec4133 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.6.0/index-all.html @@ -0,0 +1,19962 @@ +<!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_112-google-v7) on Wed Mar 08 17:12:58 PST 2017 --> +<title>Index</title> +<meta name="date" content="2017-03-08"> +<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"; + } + } + catch(err) { + } +//--> +</script> +<noscript> +<div>JavaScript is disabled on your browser.</div> +</noscript> +<!-- ========= START OF TOP NAVBAR ======= --> +<div class="topNav"><a name="navbar.top"> +<!-- --> +</a> +<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> +<a name="navbar.top.firstrow"> +<!-- --> +</a> +<ul class="navList" title="Navigation"> +<li><a href="overview-summary.html">Overview</a></li> +<li>Package</li> +<li>Class</li> +<li><a href="overview-tree.html">Tree</a></li> +<li><a href="deprecated-list.html">Deprecated</a></li> +<li 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/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><span class="memberNameLink"><a href="org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.AccumulatorCheckpointingSparkListener.html#AccumulatorCheckpointingSparkListener--">AccumulatorCheckpointingSparkListener()</a></span> - Constructor for class org.apache.beam.runners.spark.aggregators.<a href="org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.AccumulatorCheckpointingSparkListener.html" title="class in org.apache.beam.runners.spark.aggregators">AggregatorsAccumulator.AccumulatorCheckpointingSparkListener</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/spark/metrics/MetricsAccumulator.AccumulatorCheckpointingSparkListener.html#AccumulatorCheckpointingSparkListener--">AccumulatorCheckpointingSparkListener()</a></span> - Constructor for class org.apache.beam.runners.spark.metrics.<a href="org/apache/beam/runners/spark/metrics/MetricsAccumulator.AccumulatorCheckpointingSparkListener.html" title="class in org.apache.beam.runners.spark.metrics">MetricsAccumulator.AccumulatorCheckpointingSparkListener</a></dt> +<dd> </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><span class="memberNameLink"><a href="org/apache/beam/runners/spark/util/GlobalWatermarkHolder.html#add-int-org.apache.beam.runners.spark.util.GlobalWatermarkHolder.SparkWatermarks-">add(int, GlobalWatermarkHolder.SparkWatermarks)</a></span> - Static method in class org.apache.beam.runners.spark.util.<a href="org/apache/beam/runners/spark/util/GlobalWatermarkHolder.html" title="class in org.apache.beam.runners.spark.util">GlobalWatermarkHolder</a></dt> +<dd> </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/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/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/runners/spark/util/GlobalWatermarkHolder.html#addAll-java.util.Map-">addAll(Map<Integer, Queue<GlobalWatermarkHolder.SparkWatermarks>>)</a></span> - Static method in class org.apache.beam.runners.spark.util.<a href="org/apache/beam/runners/spark/util/GlobalWatermarkHolder.html" title="class in org.apache.beam.runners.spark.util">GlobalWatermarkHolder</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/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/sdk/util/state/SetState.html#addIfAbsent-T-">addIfAbsent(T)</a></span> - Method in interface org.apache.beam.sdk.util.state.<a href="org/apache/beam/sdk/util/state/SetState.html" title="interface in org.apache.beam.sdk.util.state">SetState</a></dt> +<dd> +<div class="block">Add a value to the buffer if it is not already present.</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/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/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/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/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/apex/ApexYarnLauncher.html#addProperties-org.apache.hadoop.conf.Configuration-java.util.Properties-">addProperties(Configuration, Properties)</a></span> - Static method in class org.apache.beam.runners.apex.<a href="org/apache/beam/runners/apex/ApexYarnLauncher.html" title="class in org.apache.beam.runners.apex">ApexYarnLauncher</a></dt> +<dd> +<div class="block">Transfer the properties to the configuration object.</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/sdk/transforms/DelegatingAggregator.html#addValue-AggInputT-">addValue(AggInputT)</a></span> - Method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/DelegatingAggregator.html" title="class in org.apache.beam.sdk.transforms">DelegatingAggregator</a></dt> +<dd> </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/runners/spark/util/GlobalWatermarkHolder.html#advance-org.apache.spark.api.java.JavaSparkContext-">advance(JavaSparkContext)</a></span> - Static method in class org.apache.beam.runners.spark.util.<a href="org/apache/beam/runners/spark/util/GlobalWatermarkHolder.html" title="class in org.apache.beam.runners.spark.util">GlobalWatermarkHolder</a></dt> +<dd> +<div class="block">Advances the watermarks to the next-in-line watermarks.</div> +</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/runners/spark/io/CreateStream.html#advanceNextBatchWatermarkToInfinity--">advanceNextBatchWatermarkToInfinity()</a></span> - Method in class org.apache.beam.runners.spark.io.<a href="org/apache/beam/runners/spark/io/CreateStream.html" title="class in org.apache.beam.runners.spark.io">CreateStream</a></dt> +<dd> +<div class="block">Advances the watermark in the next batch to the end-of-time.</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/runners/spark/io/CreateStream.html#advanceWatermarkForNextBatch-org.joda.time.Instant-">advanceWatermarkForNextBatch(Instant)</a></span> - Method in class org.apache.beam.runners.spark.io.<a href="org/apache/beam/runners/spark/io/CreateStream.html" title="class in org.apache.beam.runners.spark.io">CreateStream</a></dt> +<dd> +<div class="block">Advances the watermark in the next batch.</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/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><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/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/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><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.html#AfterProcessingTime-java.util.List-">AfterProcessingTime(List<TimestampTransform>)</a></span> - Constructor for class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.html" title="class in org.apache.beam.sdk.transforms.windowing">AfterProcessingTime</a></dt> +<dd> </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"><i><b>FOR INTERNAL USE ONLY</b></i>.</div> +</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/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/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><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/metrics/AggregatorMetric.html" title="class in org.apache.beam.runners.spark.metrics"><span class="typeNameLink">AggregatorMetric</span></a> - Class in <a href="org/apache/beam/runners/spark/metrics/package-summary.html">org.apache.beam.runners.spark.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/metrics/AggregatorMetricSource.html" title="class in org.apache.beam.runners.spark.metrics"><span class="typeNameLink">AggregatorMetricSource</span></a> - Class in <a href="org/apache/beam/runners/spark/metrics/package-summary.html">org.apache.beam.runners.spark.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/metrics/AggregatorMetric.html" title="class in org.apache.beam.runners.spark.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/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.metrics.<a href="org/apache/beam/runners/spark/metrics/AggregatorMetricSource.html" title="class in org.apache.beam.runners.spark.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/DoFn.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> - Variable in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/DoFn.html" title="class in org.apache.beam.sdk.transforms">DoFn</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.html" title="class in org.apache.beam.runners.spark.aggregators"><span class="typeNameLink">AggregatorsAccumulator</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">For resilience, <code>Accumulators</code> are required to be wrapped in a Singleton.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.html#AggregatorsAccumulator--">AggregatorsAccumulator()</a></span> - Constructor for class org.apache.beam.runners.spark.aggregators.<a href="org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.html" title="class in org.apache.beam.runners.spark.aggregators">AggregatorsAccumulator</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.AccumulatorCheckpointingSparkListener.html" title="class in org.apache.beam.runners.spark.aggregators"><span class="typeNameLink">AggregatorsAccumulator.AccumulatorCheckpointingSparkListener</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">Spark Listener which checkpoints <a href="org/apache/beam/runners/spark/aggregators/NamedAggregators.html" title="class in org.apache.beam.runners.spark.aggregators"><code>NamedAggregators</code></a> values for fault-tolerance.</div> +</dd> +<dt><a href="org/apache/beam/sdk/AggregatorValues.html" title="class in org.apache.beam.sdk"><span class="typeNameLink">AggregatorValues</span></a><<a href="org/apache/beam/sdk/AggregatorValues.html" title="type parameter in AggregatorValues">T</a>> - Class in <a href="org/apache/beam/sdk/package-summary.html">org.apache.beam.sdk</a></dt> +<dd> +<div class="block">A collection of values associated with an <a href="org/apache/beam/sdk/transforms/Aggregator.html" title="interface in org.apache.beam.sdk.transforms"><code>Aggregator</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/AggregatorValues.html#AggregatorValues--">AggregatorValues()</a></span> - Constructor for class org.apache.beam.sdk.<a href="org/apache/beam/sdk/AggregatorValues.html" title="class in org.apache.beam.sdk">AggregatorValues</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.html#alignedTo-org.joda.time.Duration-org.joda.time.Instant-">alignedTo(Duration, Instant)</a></span> - Method in class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.html" title="class in org.apache.beam.sdk.transforms.windowing">AfterProcessingTime</a></dt> +<dd> +<div class="block">Aligns timestamps to the smallest multiple of <code>period</code> since the <code>offset</code> greater + than the timestamp.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.html#alignedTo-org.joda.time.Duration-">alignedTo(Duration)</a></span> - Method in class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.html" title="class in org.apache.beam.sdk.transforms.windowing">AfterProcessingTime</a></dt> +<dd> +<div class="block">Aligns the time to be the smallest multiple of <code>period</code> greater than the epoch + boundary (aka <code>new Instant(0)</code>).</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/TimestampTransform.html#alignTo-org.joda.time.Duration-org.joda.time.Instant-">alignTo(Duration, Instant)</a></span> - Static method in class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/TimestampTransform.html" title="class in org.apache.beam.sdk.transforms.windowing">TimestampTransform</a></dt> +<dd> +<div class="block">Returns a transform that aligns a timestamp to the next boundary of <code>period</code>, starting + from <code>offset</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/TimestampTransform.html#alignTo-org.joda.time.Duration-">alignTo(Duration)</a></span> - Static method in class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/TimestampTransform.html" title="class in org.apache.beam.sdk.transforms.windowing">TimestampTransform</a></dt> +<dd> +<div class="block">Returns a transform that aligns a timestamp to the next boundary of <code>period</code>, starting + from the start of the epoch.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/windowing/TimestampTransform.AlignTo.html#AlignTo--">AlignTo()</a></span> - Constructor for class org.apache.beam.sdk.transforms.windowing.<a href="org/apache/beam/sdk/transforms/windowing/TimestampTransform.AlignTo.html" title="class in org.apache.beam.sdk.transforms.windowing">TimestampTransform.AlignTo</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/CoderProperties.html#ALL_CONTEXTS">ALL_CONTEXTS</a></span> - Static variable in class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/CoderProperties.html" title="class in org.apache.beam.sdk.testing">CoderProperties</a></dt> +<dd> +<div class="block">All the contexts, for use in test cases.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/range/ByteKeyRange.html#ALL_KEYS">ALL_KEYS</a></span> - Static variable in class org.apache.beam.sdk.io.range.<a href="org/apache/beam/sdk/io/range/ByteKeyRange.html" title="class in org.apache.beam.sdk.io.range">ByteKeyRange</a></dt> +<dd> +<div class="block">The range of all keys, with empty start and end keys.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/ShardingWritableByteChannel.html#ALL_SHARDS">ALL_SHARDS</a></span> - Static variable 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">Special shard number that causes a write to all shards.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Regex.html#allMatches-java.lang.String-">allMatches(String)</a></span> - Static method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Regex.html" title="class in org.apache.beam.sdk.transforms">Regex</a></dt> +<dd> +<div class="block">Returns a <a href="org/apache/beam/sdk/transforms/Regex.AllMatches.html" title="class in org.apache.beam.sdk.transforms"><code>Regex.AllMatches</code></a> <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> that checks if the entire line matches + the Regex.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Regex.html#allMatches-java.util.regex.Pattern-">allMatches(Pattern)</a></span> - Static method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Regex.html" title="class in org.apache.beam.sdk.transforms">Regex</a></dt> +<dd> +<div class="block">Returns a <a href="org/apache/beam/sdk/transforms/Regex.AllMatches.html" title="class in org.apache.beam.sdk.transforms"><code>Regex.AllMatches</code></a> <a href="org/apache/beam/sdk/transforms/PTransform.html" title="class in org.apache.beam.sdk.transforms"><code>PTransform</code></a> that checks if the entire line matches + the Regex.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Regex.AllMatches.html#AllMatches-java.util.regex.Pattern-">AllMatches(Pattern)</a></span> - Constructor for class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Regex.AllMatches.html" title="class in org.apache.beam.sdk.transforms">Regex.AllMatches</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PropertyNames.html#ALLOWED_ENCODINGS">ALLOWED_ENCODINGS</a></span> - Static variable in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PropertyNames.html" title="class in org.apache.beam.sdk.util">PropertyNames</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/CompressedSource.CompressedReader.html#allowsDynamicSplitting--">allowsDynamicSplitting()</a></span> - Method in class org.apache.beam.sdk.io.<a href="org/apache/beam/sdk/io/CompressedSource.CompressedReader.html" title="class in org.apache.beam.sdk.io">CompressedSource.CompressedReader</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/io/OffsetBasedSource.OffsetBasedReader.html#allowsDynamicSplitting--">allowsDynamicSplitting()</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">Whether this reader should allow dynamic splitting of the offset ranges.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/TestPipelineOptions.AlwaysPassMatcher.html#AlwaysPassMatcher--">AlwaysPassMatcher()</a></span> - Constructor for class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/TestPipelineOptions.AlwaysPassMatcher.html" title="class in org.apache.beam.sdk.testing">TestPipelineOptions.AlwaysPassMatcher</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/testing/TestPipelineOptions.AlwaysPassMatcherFactory.html#AlwaysPassMatcherFactory--">AlwaysPassMatcherFactory()</a></span> - Constructor for class org.apache.beam.sdk.testing.<a href="org/apache/beam/sdk/testing/TestPipelineOptions.AlwaysPassMatcherFactory.html" title="class in org.apache.beam.sdk.testing">TestPipelineOptions.AlwaysPassMatcherFactory</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/join/CoGbkResult.html#and-org.apache.beam.sdk.values.TupleTag-java.util.List-">and(TupleTag<V>, List<V>)</a></span> - Method in class org.apache.beam.sdk.transforms.join.<a href="org/apache/beam/sdk/transforms/join/CoGbkResult.html" title="class in org.apache.beam.sdk.transforms.join">CoGbkResult</a></dt> +<dd> +<div class="block">Returns a new <a href="org/apache/beam/sdk/transforms/join/CoGbkResult.html" title="class in org.apache.beam.sdk.transforms.join"><code>CoGbkResult</code></a> based on this, with the given tag and given data + added to it.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/join/KeyedPCollectionTuple.html#and-org.apache.beam.sdk.values.TupleTag-org.apache.beam.sdk.values.PCollection-">and(TupleTag<V>, PCollection<KV<K, V>>)</a></span> - Method in class org.apache.beam.sdk.transforms.join.<a href="org/apache/beam/sdk/transforms/join/KeyedPCollectionTuple.html" title="class in org.apache.beam.sdk.transforms.join">KeyedPCollectionTuple</a></dt> +<dd> +<div class="block">Returns a new <code>KeyedPCollectionTuple<K></code> that is the same as this, + appended with the given PCollection.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PTuple.html#and-org.apache.beam.sdk.values.TupleTag-V-">and(TupleTag<V>, V)</a></span> - Method in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PTuple.html" title="class in org.apache.beam.sdk.util">PTuple</a></dt> +<dd> +<div class="block">Returns a new PTuple that has all the values and + tags of this PTuple plus the given value and tag.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/values/PCollection.IsBounded.html#and-org.apache.beam.sdk.values.PCollection.IsBounded-">and(PCollection.IsBounded)</a></span> - Method in enum org.apache.beam.sdk.values.<a href="org/apache/beam/sdk/values/PCollection.IsBounded.html" title="enum in org.apache.beam.sdk.values">PCollection.IsBounded</a></dt> +<dd> +<div class="block">Returns the composed IsBounded property.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/values/PCollectionList.html#and-org.apache.beam.sdk.values.PCollection-">and(PCollection<T>)</a></span> - Method in class org.apache.beam.sdk.values.<a href="org/apache/beam/sdk/values/PCollectionList.html" title="class in org.apache.beam.sdk.values">PCollectionList</a></dt> +<dd> +<div class="block">Returns a new <a href="org/apache/beam/sdk/values/PCollectionList.html" title="class in org.apache.beam.sdk.values"><code>PCollectionList</code></a> that has all the <a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollections</code></a> of + this <a href="org/apache/beam/sdk/values/PCollectionList.html" title="class in org.apache.beam.sdk.values"><code>PCollectionList</code></a> plus the given <a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> appended to the end.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/values/PCollectionList.html#and-java.lang.Iterable-">and(Iterable<PCollection<T>>)</a></span> - Method in class org.apache.beam.sdk.values.<a href="org/apache/beam/sdk/values/PCollectionList.html" title="class in org.apache.beam.sdk.values">PCollectionList</a></dt> +<dd> +<div class="block">Returns a new <a href="org/apache/beam/sdk/values/PCollectionList.html" title="class in org.apache.beam.sdk.values"><code>PCollectionList</code></a> that has all the <a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollections</code></a> of + this <a href="org/apache/beam/sdk/values/PCollectionList.html" title="class in org.apache.beam.sdk.values"><code>PCollectionList</code></a> plus the given <a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollections</code></a> appended to the + end, in order.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/values/PCollectionTuple.html#and-org.apache.beam.sdk.values.TupleTag-org.apache.beam.sdk.values.PCollection-">and(TupleTag<T>, PCollection<T>)</a></span> - Method in class org.apache.beam.sdk.values.<a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values">PCollectionTuple</a></dt> +<dd> +<div class="block">Returns a new <a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values"><code>PCollectionTuple</code></a> that has each <a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> and + <a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values"><code>TupleTag</code></a> of this <a href="org/apache/beam/sdk/values/PCollectionTuple.html" title="class in org.apache.beam.sdk.values"><code>PCollectionTuple</code></a> plus the given <a href="org/apache/beam/sdk/values/PCollection.html" title="class in org.apache.beam.sdk.values"><code>PCollection</code></a> + associated with the given <a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values"><code>TupleTag</code></a>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/values/TupleTagList.html#and-org.apache.beam.sdk.values.TupleTag-">and(TupleTag<?>)</a></span> - Method in class org.apache.beam.sdk.values.<a href="org/apache/beam/sdk/values/TupleTagList.html" title="class in org.apache.beam.sdk.values">TupleTagList</a></dt> +<dd> +<div class="block">Returns a new <a href="org/apache/beam/sdk/values/TupleTagList.html" title="class in org.apache.beam.sdk.values"><code>TupleTagList</code></a> that has all the <a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values"><code>TupleTags</code></a> of + this <a href="org/apache/beam/sdk/values/TupleTagList.html" title="class in org.apache.beam.sdk.values"><code>TupleTagList</code></a> plus the given <a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values"><code>TupleTag</code></a> appended to the end.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/values/TupleTagList.html#and-java.util.List-">and(List<TupleTag<?>>)</a></span> - Method in class org.apache.beam.sdk.values.<a href="org/apache/beam/sdk/values/TupleTagList.html" title="class in org.apache.beam.sdk.values">TupleTagList</a></dt> +<dd> +<div class="block">Returns a new <a href="org/apache/beam/sdk/values/TupleTagList.html" title="class in org.apache.beam.sdk.values"><code>TupleTagList</code></a> that has all the <a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values"><code>TupleTags</code></a> of + this <a href="org/apache/beam/sdk/values/TupleTagList.html" title="class in org.apache.beam.sdk.values"><code>TupleTagList</code></a> plus the given <a href="org/apache/beam/sdk/values/TupleTag.html" title="class in org.apache.beam.sdk.values"><code>TupleTags</code></a> appended to the end, + in order.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/common/ReflectHelpers.html#ANNOTATION_FORMATTER">ANNOTATION_FORMATTER</a></span> - Static variable in class org.apache.beam.sdk.util.common.<a href="org/apache/beam/sdk/util/common/ReflectHelpers.html" title="class in org.apache.beam.sdk.util.common">ReflectHelpers</a></dt> +<dd> +<div class="block">A <a href="http://google.github.io/guava/releases/20.0/api/docs/com/google/common/base/Function.html?is-external=true" title="class or interface in com.google.common.base"><code>Function</code></a> that returns a concise string for a <code>Annotation</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/Sample.html#any-long-">any(long)</a></span> - Static method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/Sample.html" title="class in org.apache.beam.sdk.transforms">Sample</a></dt> +<dd> +<div class="block"><code>Sample#any(long)</code> takes a <code>PCollection<T></code> and a limit, and + produces a new <code>PCollection<T></code> containing up to limit + elements of the input <code>PCollection</code>.</div> +</dd> +<dt><a href="org/apache/beam/runners/apex/ApexPipelineOptions.html" title="interface in org.apache.beam.runners.apex"><span class="typeNameLink">ApexPipelineOptions</span></a> - Interface in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Options that configure the Apex pipeline.</div> +</dd> +<dt><a href="org/apache/beam/runners/apex/ApexRunner.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexRunner</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">A <a href="org/apache/beam/sdk/runners/PipelineRunner.html" title="class in org.apache.beam.sdk.runners"><code>PipelineRunner</code></a> that translates the + pipeline to an Apex DAG and executes it on an Apex cluster.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/apex/ApexRunner.html#ApexRunner-org.apache.beam.runners.apex.ApexPipelineOptions-">ApexRunner(ApexPipelineOptions)</a></span> - Constructor for class org.apache.beam.runners.apex.<a href="org/apache/beam/runners/apex/ApexRunner.html" title="class in org.apache.beam.runners.apex">ApexRunner</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/apex/ApexRunner.CreateApexPCollectionView.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexRunner.CreateApexPCollectionView</span></a><<a href="org/apache/beam/runners/apex/ApexRunner.CreateApexPCollectionView.html" title="type parameter in ApexRunner.CreateApexPCollectionView">ElemT</a>,<a href="org/apache/beam/runners/apex/ApexRunner.CreateApexPCollectionView.html" title="type parameter in ApexRunner.CreateApexPCollectionView">ViewT</a>> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Creates a primitive <a href="org/apache/beam/sdk/values/PCollectionView.html" title="interface in org.apache.beam.sdk.values"><code>PCollectionView</code></a>.</div> +</dd> +<dt><a href="org/apache/beam/runners/apex/ApexRunnerRegistrar.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexRunnerRegistrar</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Contains the <a href="org/apache/beam/sdk/runners/PipelineRunnerRegistrar.html" title="interface in org.apache.beam.sdk.runners"><code>PipelineRunnerRegistrar</code></a> and <a href="org/apache/beam/sdk/options/PipelineOptionsRegistrar.html" title="interface in org.apache.beam.sdk.options"><code>PipelineOptionsRegistrar</code></a> for the + <a href="org/apache/beam/runners/apex/ApexRunner.html" title="class in org.apache.beam.runners.apex"><code>ApexRunner</code></a>.</div> +</dd> +<dt><a href="org/apache/beam/runners/apex/ApexRunnerRegistrar.Options.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexRunnerRegistrar.Options</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Registers the <a href="org/apache/beam/runners/apex/ApexPipelineOptions.html" title="interface in org.apache.beam.runners.apex"><code>ApexPipelineOptions</code></a>.</div> +</dd> +<dt><a href="org/apache/beam/runners/apex/ApexRunnerRegistrar.Runner.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexRunnerRegistrar.Runner</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Registers the <a href="org/apache/beam/runners/apex/ApexRunner.html" title="class in org.apache.beam.runners.apex"><code>ApexRunner</code></a>.</div> +</dd> +<dt><a href="org/apache/beam/runners/apex/ApexRunnerResult.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexRunnerResult</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Result of executing a <a href="org/apache/beam/sdk/Pipeline.html" title="class in org.apache.beam.sdk"><code>Pipeline</code></a> with Apex in embedded mode.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/apex/ApexRunnerResult.html#ApexRunnerResult-com.datatorrent.api.DAG-org.apache.apex.api.Launcher.AppHandle-">ApexRunnerResult(DAG, Launcher.AppHandle)</a></span> - Constructor for class org.apache.beam.runners.apex.<a href="org/apache/beam/runners/apex/ApexRunnerResult.html" title="class in org.apache.beam.runners.apex">ApexRunnerResult</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/apex/ApexYarnLauncher.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexYarnLauncher</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Proxy to launch the YARN application through the hadoop script to run in the + pre-configured environment (class path, configuration, native libraries etc.).</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/runners/apex/ApexYarnLauncher.html#ApexYarnLauncher--">ApexYarnLauncher()</a></span> - Constructor for class org.apache.beam.runners.apex.<a href="org/apache/beam/runners/apex/ApexYarnLauncher.html" title="class in org.apache.beam.runners.apex">ApexYarnLauncher</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/runners/apex/ApexYarnLauncher.LaunchParams.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexYarnLauncher.LaunchParams</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Launch parameters that will be serialized and passed to the child process.</div> +</dd> +<dt><a href="org/apache/beam/runners/apex/ApexYarnLauncher.ProcessWatcher.html" title="class in org.apache.beam.runners.apex"><span class="typeNameLink">ApexYarnLauncher.ProcessWatcher</span></a> - Class in <a href="org/apache/beam/runners/apex/package-summary.html">org.apache.beam.runners.apex</a></dt> +<dd> +<div class="block">Starts a command and waits for it to complete.</div> +</dd> +<dt><a href="org/apache/beam/sdk/util/ApiSurface.html" title="class in org.apache.beam.sdk.util"><span class="typeNameLink">ApiSurface</span></a> - Class in <a href="org/apache/beam/sdk/util/package-summary.html">org.apache.beam.sdk.util</a></dt> +<dd> +<div class="block">Represents the API surface of a package prefix.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/PropertyNames.html#APPEND_TRAILING_NEWLINES">APPEND_TRAILING_NEWLINES</a></span> - Static variable in class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/PropertyNames.html" title="class in org.apache.beam.sdk.util">PropertyNames</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/util/AppEngineEnvironment.html" title="class in org.apache.beam.sdk.util"><span class="typeNameLink">AppEngineEnvironment</span></a> - Class in <a href="org/apache/beam/sdk/util/package-summary.html">org.apache.beam.sdk.util</a></dt> +<dd> +<div class="block">Stores whether we are running within AppEngine or not.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/util/AppEngineEnvironment.html#AppEngineEnvironment--">AppEngineEnvironment()</a></span> - Constructor for class org.apache.beam.sdk.util.<a href="org/apache/beam/sdk/util/AppEngineEnvironment.html" title="class in org.apache.beam.sdk.util">AppEngineEnvironment</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/beam/sdk/transforms/GroupByKey.html#applicableTo-org.apache.beam.sdk.values.PCollection-">applicableTo(PCollection<?>)</a></span> - Static method in class org.apache.beam.sdk.transforms.<a href="org/apache/beam/sdk/transforms/GroupByKey.html" title="class in org.apache.beam.sdk.transforms">GroupByKey</a></dt> +<dd> </dd> +<dt><a href="org/apache/beam/sdk/options/ApplicationNameOptions.html" title="interface in org.apache.beam.sdk.options"><span class="typeNameLink">ApplicationNameOptions</span></a> - Interface in <a href="org/apache/beam/sdk/options/package-summary.h
<TRUNCATED>