http://git-wip-us.apache.org/repos/asf/beam-site/blob/7b1f1576/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachine.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachine.html b/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachine.html new file mode 100644 index 0000000..0846b40 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachine.html @@ -0,0 +1,739 @@ +<!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 Fri Jan 27 21:25:28 CET 2017 --> +<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> +<title>TriggerStateMachine (Apache Beam SDK for Java, version 0.5.0)</title> +<meta name="date" content="2017-01-27"> +<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> +<script type="text/javascript" src="../../../../../../script.js"></script> +</head> +<body> +<script type="text/javascript"><!-- + try { + if (location.href.indexOf('is-external=true') == -1) { + parent.document.title="TriggerStateMachine (Apache Beam SDK for Java, version 0.5.0)"; + } + } + catch(err) { + } +//--> +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":6,"i5":6,"i6":6,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":6,"i13":10,"i14":10}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; +</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><a href="package-summary.html">Package</a></li> +<li class="navBarCell1Rev">Class</li> +<li><a href="class-use/TriggerStateMachine.html">Use</a></li> +<li><a href="package-tree.html">Tree</a></li> +<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li> +<li><a href="../../../../../../index-all.html">Index</a></li> +<li><a href="../../../../../../help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/ReshuffleTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.MergingTriggerInfo.html" title="interface in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Next Class</span></a></li> +</ul> +<ul class="navList"> +<li><a href="../../../../../../index.html?org/apache/beam/runners/core/triggers/TriggerStateMachine.html" target="_top">Frames</a></li> +<li><a href="TriggerStateMachine.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> +<div> +<ul class="subNavList"> +<li>Summary: </li> +<li><a href="#nested.class.summary">Nested</a> | </li> +<li><a href="#field.summary">Field</a> | </li> +<li><a href="#constructor.summary">Constr</a> | </li> +<li><a href="#method.summary">Method</a></li> +</ul> +<ul class="subNavList"> +<li>Detail: </li> +<li><a href="#field.detail">Field</a> | </li> +<li><a href="#constructor.detail">Constr</a> | </li> +<li><a href="#method.detail">Method</a></li> +</ul> +</div> +<a name="skip.navbar.top"> +<!-- --> +</a></div> +<!-- ========= END OF TOP NAVBAR ========= --> +<!-- ======== START OF CLASS DATA ======== --> +<div class="header"> +<div class="subTitle">org.apache.beam.runners.core.triggers</div> +<h2 title="Class TriggerStateMachine" class="title">Class TriggerStateMachine</h2> +</div> +<div class="contentContainer"> +<ul class="inheritance"> +<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li> +<li> +<ul class="inheritance"> +<li>org.apache.beam.runners.core.triggers.TriggerStateMachine</li> +</ul> +</li> +</ul> +<div class="description"> +<ul class="blockList"> +<li class="blockList"> +<dl> +<dt>All Implemented Interfaces:</dt> +<dd><a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true" title="class or interface in java.io">Serializable</a></dd> +</dl> +<dl> +<dt>Direct Known Subclasses:</dt> +<dd><a href="../../../../../../org/apache/beam/runners/core/triggers/AfterEachStateMachine.html" title="class in org.apache.beam.runners.core.triggers">AfterEachStateMachine</a>, <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate.html" title="class in org.apache.beam.runners.core.triggers">AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate</a>, <a href="../../../../../../org/apache/beam/runners/core/triggers/DefaultTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">DefaultTriggerStateMachine</a>, <a href="../../../../../../org/apache/beam/runners/core/triggers/RepeatedlyStateMachine.html" title="class in org.apache.beam.runners.core.triggers">RepeatedlyStateMachine</a>, <a href="../../../../../../org/apache/beam/runners/core/triggers/ReshuffleTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ReshuffleTriggerStateMachine</a>, <a href="../../../../../../o rg/apache/beam/runners/core/triggers/TriggerStateMachine.OnceTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnceTriggerStateMachine</a></dd> +</dl> +<hr> +<br> +<pre>public abstract class <span class="typeNameLabel">TriggerStateMachine</span> +extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> +implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html?is-external=true" title="class or interface in java.io">Serializable</a></pre> +<div class="block"><code>Trigger</code>s control when the elements for a specific key and window are output. As elements + arrive, they are put into one or more windows by a <a href="../../../../../../org/apache/beam/sdk/transforms/windowing/Window.html" title="class in org.apache.beam.sdk.transforms.windowing"><code>Window</code></a> transform and its associated + <a href="../../../../../../org/apache/beam/sdk/transforms/windowing/WindowFn.html" title="class in org.apache.beam.sdk.transforms.windowing"><code>WindowFn</code></a>, and then passed to the associated <code>Trigger</code> to determine if the <code>Window</code>s contents should be output. + + <p>See <a href="../../../../../../org/apache/beam/sdk/transforms/GroupByKey.html" title="class in org.apache.beam.sdk.transforms"><code>GroupByKey</code></a> and <a href="../../../../../../org/apache/beam/sdk/transforms/windowing/Window.html" title="class in org.apache.beam.sdk.transforms.windowing"><code>Window</code></a> for more information + about how grouping with windows works. + + <p>The elements that are assigned to a window since the last time it was fired (or since the + window was created) are placed into the current window pane. Triggers are evaluated against the + elements as they are added. When the root trigger fires, the elements in the current pane will be + output. When the root trigger finishes (indicating it will never fire again), the window is + closed and any new elements assigned to that window are discarded. + + <p>Several predefined <code>Trigger</code>s are provided: + + <ul> + <li> <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>AfterWatermarkStateMachine</code></a> for firing when the watermark passes a timestamp + determined from either the end of the window or the arrival of the first element in a pane. + <li> <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterProcessingTimeStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>AfterProcessingTimeStateMachine</code></a> for firing after some amount of processing time has + elapsed (typically since the first element in a pane). + <li> <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterPaneStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>AfterPaneStateMachine</code></a> for firing off a property of the elements in the current pane, + such as the number of elements that have been assigned to the current pane. + </ul> + + <p>In addition, <code>Trigger</code>s can be combined in a variety of ways: + + <ul> + <li> <a href="../../../../../../org/apache/beam/runners/core/triggers/RepeatedlyStateMachine.html#forever-org.apache.beam.runners.core.triggers.TriggerStateMachine-"><code>RepeatedlyStateMachine.forever(org.apache.beam.runners.core.triggers.TriggerStateMachine)</code></a> to create a trigger that executes forever. Any time + its argument finishes it gets reset and starts over. Can be combined with <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#orFinally-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine-"><code>orFinally(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine)</code></a> to specify a condition that causes the repetition to stop. + <li> <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterEachStateMachine.html#inOrder-org.apache.beam.runners.core.triggers.TriggerStateMachine...-"><code>AfterEachStateMachine.inOrder(org.apache.beam.runners.core.triggers.TriggerStateMachine...)</code></a> to execute each trigger in sequence, firing each (and + every) time that a trigger fires, and advancing to the next trigger in the sequence when it + finishes. + <li> <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterFirstStateMachine.html#of-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine...-"><code>AfterFirstStateMachine.of(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine...)</code></a> to create a trigger that fires after at least one of its + arguments fires. An <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterFirstStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>AfterFirstStateMachine</code></a> trigger finishes after it fires once. + <li> <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterAllStateMachine.html#of-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine...-"><code>AfterAllStateMachine.of(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine...)</code></a> to create a trigger that fires after all least one of its + arguments have fired at least once. An <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterAllStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>AfterAllStateMachine</code></a> trigger finishes after it + fires once. + </ul> + + <p>Each trigger tree is instantiated per-key and per-window. Every trigger in the tree is in one + of the following states: + + <ul> + <li> Never Existed - before the trigger has started executing, there is no state associated with + it anywhere in the system. A trigger moves to the executing state as soon as it processes in + the current pane. + <li> Executing - while the trigger is receiving items and may fire. While it is in this state, it + may persist book-keeping information to persisted state, set timers, etc. + <li> Finished - after a trigger finishes, all of its book-keeping data is cleaned up, and the + system remembers only that it is finished. Entering this state causes us to discard any + elements in the buffer for that window, as well. + </ul> + + <p>Once finished, a trigger cannot return itself back to an earlier state, however a composite + trigger could reset its sub-triggers. + + <p>Triggers should not build up any state internally since they may be recreated between + invocations of the callbacks. All important values should be persisted using state before the + callback returns.</div> +<dl> +<dt><span class="seeLabel">See Also:</span></dt> +<dd><a href="../../../../../../serialized-form.html#org.apache.beam.runners.core.triggers.TriggerStateMachine">Serialized Form</a></dd> +</dl> +</li> +</ul> +</div> +<div class="summary"> +<ul class="blockList"> +<li class="blockList"> +<!-- ======== NESTED CLASS SUMMARY ======== --> +<ul class="blockList"> +<li class="blockList"><a name="nested.class.summary"> +<!-- --> +</a> +<h3>Nested Class Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Nested Class Summary table, listing nested classes, and an explanation"> +<caption><span>Nested Classes</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Class and Description</th> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>static interface </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.MergingTriggerInfo.html" title="interface in org.apache.beam.runners.core.triggers">TriggerStateMachine.MergingTriggerInfo</a></span></code> +<div class="block">Interact with properties of the trigger being executed, with extensions to deal with the + merging windows.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>static class </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnceTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnceTriggerStateMachine</a></span></code> +<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 are guaranteed to fire at most once should extend from this, + rather than the general <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine</code></a> class to indicate that behavior.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>class </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnElementContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnElementContext</a></span></code> +<div class="block">Extended <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine.TriggerContext</code></a> containing information accessible to the <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onElement-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext-"><code>onElement(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext)</code></a> + operational hook.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>class </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnMergeContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnMergeContext</a></span></code> +<div class="block">Extended <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine.TriggerContext</code></a> containing information accessible to the <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onMerge-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext-"><code>onMerge(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext)</code></a> + operational hook.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>class </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a></span></code> +<div class="block">Information accessible to all operational hooks in this <code>Trigger</code>.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>static interface </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerInfo.html" title="interface in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerInfo</a></span></code> +<div class="block">Interface for accessing information about the trigger being executed and other triggers in the + same tree.</div> +</td> +</tr> +</table> +</li> +</ul> +<!-- =========== FIELD SUMMARY =========== --> +<ul class="blockList"> +<li class="blockList"><a name="field.summary"> +<!-- --> +</a> +<h3>Field Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Field Summary table, listing fields, and an explanation"> +<caption><span>Fields</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Field and Description</th> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a>></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#subTriggers">subTriggers</a></span></code> </td> +</tr> +</table> +</li> +</ul> +<!-- ======== CONSTRUCTOR SUMMARY ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor.summary"> +<!-- --> +</a> +<h3>Constructor Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> +<caption><span>Constructors</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colFirst" scope="col">Modifier</th> +<th class="colLast" scope="col">Constructor and Description</th> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>protected </code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#TriggerStateMachine-java.util.List-">TriggerStateMachine</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a>> subTriggers)</code> </td> +</tr> +</table> +</li> +</ul> +<!-- ========== METHOD SUMMARY =========== --> +<ul class="blockList"> +<li class="blockList"><a name="method.summary"> +<!-- --> +</a> +<h3>Method Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> +<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t3" class="tableTab"><span><a href="javascript:show(4);">Abstract Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Method and Description</th> +</tr> +<tr id="i0" class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#clear-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-">clear</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a> c)</code> +<div class="block">Clear any state associated with this trigger in the given window.</div> +</td> +</tr> +<tr id="i1" class="rowColor"> +<td class="colFirst"><code>boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#equals-java.lang.Object-">equals</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> obj)</code> </td> +</tr> +<tr id="i2" class="altColor"> +<td class="colFirst"><code>int</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#hashCode--">hashCode</a></span>()</code> </td> +</tr> +<tr id="i3" class="rowColor"> +<td class="colFirst"><code>boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#isCompatible-org.apache.beam.runners.core.triggers.TriggerStateMachine-">isCompatible</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a> other)</code> +<div class="block">Returns whether this performs the same triggering as the given <code>Trigger</code>.</div> +</td> +</tr> +<tr id="i4" class="altColor"> +<td class="colFirst"><code>abstract void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onElement-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext-">onElement</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnElementContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnElementContext</a> c)</code> +<div class="block">Called every time an element is incorporated into a window.</div> +</td> +</tr> +<tr id="i5" class="rowColor"> +<td class="colFirst"><code>abstract void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-">onFire</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a> context)</code> +<div class="block">Adjusts the state of the trigger to be ready for the next pane.</div> +</td> +</tr> +<tr id="i6" class="altColor"> +<td class="colFirst"><code>abstract void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onMerge-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext-">onMerge</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnMergeContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnMergeContext</a> c)</code> +<div class="block">Called immediately after windows have been merged.</div> +</td> +</tr> +<tr id="i7" class="rowColor"> +<td class="colFirst"><code><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#orFinally-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine-">orFinally</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnceTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnceTriggerStateMachine</a> until)</code> +<div class="block">Specify an ending condition for this trigger.</div> +</td> +</tr> +<tr id="i8" class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#prefetchOnElement-org.apache.beam.sdk.util.state.StateAccessor-">prefetchOnElement</a></span>(<a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?> state)</code> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onElement-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext-"><code>onElement(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext)</code></a> call.</div> +</td> +</tr> +<tr id="i9" class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#prefetchOnFire-org.apache.beam.sdk.util.state.StateAccessor-">prefetchOnFire</a></span>(<a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?> state)</code> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-"><code>onFire(org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext)</code></a> call.</div> +</td> +</tr> +<tr id="i10" class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#prefetchOnMerge-org.apache.beam.sdk.util.state.MergingStateAccessor-">prefetchOnMerge</a></span>(<a href="../../../../../../org/apache/beam/sdk/util/state/MergingStateAccessor.html" title="interface in org.apache.beam.sdk.util.state">MergingStateAccessor</a><?,?> state)</code> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onMerge-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext-"><code>onMerge(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext)</code></a> call.</div> +</td> +</tr> +<tr id="i11" class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#prefetchShouldFire-org.apache.beam.sdk.util.state.StateAccessor-">prefetchShouldFire</a></span>(<a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?> state)</code> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#shouldFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-"><code>shouldFire(org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext)</code></a> call.</div> +</td> +</tr> +<tr id="i12" class="altColor"> +<td class="colFirst"><code>abstract boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#shouldFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-">shouldFire</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a> context)</code> +<div class="block">Returns <code>true</code> if the current state of the trigger indicates that its condition + is satisfied and it is ready to fire.</div> +</td> +</tr> +<tr id="i13" class="rowColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a>></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#subTriggers--">subTriggers</a></span>()</code> </td> +</tr> +<tr id="i14" class="altColor"> +<td class="colFirst"><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#toString--">toString</a></span>()</code> </td> +</tr> +</table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> +<!-- --> +</a> +<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3> +<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone--" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize--" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass--" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify--" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait--" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-ex ternal=true#wait-long-" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-int-" title="class or interface in java.lang">wait</a></code></li> +</ul> +</li> +</ul> +</li> +</ul> +</div> +<div class="details"> +<ul class="blockList"> +<li class="blockList"> +<!-- ============ FIELD DETAIL =========== --> +<ul class="blockList"> +<li class="blockList"><a name="field.detail"> +<!-- --> +</a> +<h3>Field Detail</h3> +<a name="subTriggers"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>subTriggers</h4> +<pre><a href="http://docs.oracle.com/javase/7/docs/api/javax/annotation/Nullable.html?is-external=true" title="class or interface in javax.annotation">@Nullable</a> +protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a>> subTriggers</pre> +</li> +</ul> +</li> +</ul> +<!-- ========= CONSTRUCTOR DETAIL ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor.detail"> +<!-- --> +</a> +<h3>Constructor Detail</h3> +<a name="TriggerStateMachine-java.util.List-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>TriggerStateMachine</h4> +<pre>protected TriggerStateMachine(<a href="http://docs.oracle.com/javase/7/docs/api/javax/annotation/Nullable.html?is-external=true" title="class or interface in javax.annotation">@Nullable</a> + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a>> subTriggers)</pre> +</li> +</ul> +</li> +</ul> +<!-- ============ METHOD DETAIL ========== --> +<ul class="blockList"> +<li class="blockList"><a name="method.detail"> +<!-- --> +</a> +<h3>Method Detail</h3> +<a name="onElement-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>onElement</h4> +<pre>public abstract void onElement(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnElementContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnElementContext</a> c) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> +<div class="block">Called every time an element is incorporated into a window.</div> +<dl> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> +</dl> +</li> +</ul> +<a name="onMerge-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>onMerge</h4> +<pre>public abstract void onMerge(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnMergeContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnMergeContext</a> c) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> +<div class="block">Called immediately after windows have been merged. + + <p>Leaf triggers should update their state by inspecting their status and any state in the + merging windows. Composite triggers should update their state by calling <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html#invokeOnMerge-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext-"><code>ExecutableTriggerStateMachine.invokeOnMerge(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext)</code></a> on their sub-triggers, and applying appropriate + logic. + + <p>A trigger such as <a href="../../../../../../org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.html#pastEndOfWindow--"><code>AfterWatermarkStateMachine.pastEndOfWindow()</code></a> may no longer be + finished; it is the responsibility of the trigger itself to record this fact. It is forbidden + for a trigger to become finished due to <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onMerge-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext-"><code>onMerge(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext)</code></a>, as it has not yet fired the pending + elements that led to it being ready to fire. + + <p>The implementation does not need to clear out any state associated with the old windows.</div> +<dl> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> +</dl> +</li> +</ul> +<a name="shouldFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>shouldFire</h4> +<pre>public abstract boolean shouldFire(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a> context) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> +<div class="block">Returns <code>true</code> if the current state of the trigger indicates that its condition + is satisfied and it is ready to fire.</div> +<dl> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> +</dl> +</li> +</ul> +<a name="onFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>onFire</h4> +<pre>public abstract void onFire(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a> context) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> +<div class="block">Adjusts the state of the trigger to be ready for the next pane. For example, a + <a href="../../../../../../org/apache/beam/runners/core/triggers/RepeatedlyStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>RepeatedlyStateMachine</code></a> trigger will reset its inner trigger, since it has fired. + + <p>If the trigger is finished, it is the responsibility of the trigger itself to + record that fact via the <code>context</code>.</div> +<dl> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> +</dl> +</li> +</ul> +<a name="prefetchOnElement-org.apache.beam.sdk.util.state.StateAccessor-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>prefetchOnElement</h4> +<pre>public void prefetchOnElement(<a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?> state)</pre> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onElement-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext-"><code>onElement(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext)</code></a> call.</div> +</li> +</ul> +<a name="prefetchOnMerge-org.apache.beam.sdk.util.state.MergingStateAccessor-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>prefetchOnMerge</h4> +<pre>public void prefetchOnMerge(<a href="../../../../../../org/apache/beam/sdk/util/state/MergingStateAccessor.html" title="interface in org.apache.beam.sdk.util.state">MergingStateAccessor</a><?,?> state)</pre> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onMerge-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext-"><code>onMerge(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext)</code></a> call.</div> +</li> +</ul> +<a name="prefetchShouldFire-org.apache.beam.sdk.util.state.StateAccessor-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>prefetchShouldFire</h4> +<pre>public void prefetchShouldFire(<a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?> state)</pre> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#shouldFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-"><code>shouldFire(org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext)</code></a> call.</div> +</li> +</ul> +<a name="prefetchOnFire-org.apache.beam.sdk.util.state.StateAccessor-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>prefetchOnFire</h4> +<pre>public void prefetchOnFire(<a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?> state)</pre> +<div class="block">Called to allow the trigger to prefetch any state it will likely need to read from during + an <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html#onFire-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-"><code>onFire(org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext)</code></a> call.</div> +</li> +</ul> +<a name="clear-org.apache.beam.runners.core.triggers.TriggerStateMachine.TriggerContext-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>clear</h4> +<pre>public void clear(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a> c) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></pre> +<div class="block">Clear any state associated with this trigger in the given window. + + <p>This is called after a trigger has indicated it will never fire again. The trigger system + keeps enough information to know that the trigger is finished, so this trigger should clear all + of its state.</div> +<dl> +<dt><span class="throwsLabel">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true" title="class or interface in java.lang">Exception</a></code></dd> +</dl> +</li> +</ul> +<a name="subTriggers--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>subTriggers</h4> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang">Iterable</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a>> subTriggers()</pre> +</li> +</ul> +<a name="isCompatible-org.apache.beam.runners.core.triggers.TriggerStateMachine-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>isCompatible</h4> +<pre>public boolean isCompatible(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a> other)</pre> +<div class="block">Returns whether this performs the same triggering as the given <code>Trigger</code>.</div> +</li> +</ul> +<a name="toString--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>toString</h4> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> toString()</pre> +<dl> +<dt><span class="overrideSpecifyLabel">Overrides:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString--" title="class or interface in java.lang">toString</a></code> in class <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></code></dd> +</dl> +</li> +</ul> +<a name="equals-java.lang.Object-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>equals</h4> +<pre>public boolean equals(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> obj)</pre> +<dl> +<dt><span class="overrideSpecifyLabel">Overrides:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-" title="class or interface in java.lang">equals</a></code> in class <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></code></dd> +</dl> +</li> +</ul> +<a name="hashCode--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>hashCode</h4> +<pre>public int hashCode()</pre> +<dl> +<dt><span class="overrideSpecifyLabel">Overrides:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode--" title="class or interface in java.lang">hashCode</a></code> in class <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></code></dd> +</dl> +</li> +</ul> +<a name="orFinally-org.apache.beam.runners.core.triggers.TriggerStateMachine.OnceTriggerStateMachine-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>orFinally</h4> +<pre>public <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine</a> orFinally(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnceTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnceTriggerStateMachine</a> until)</pre> +<div class="block">Specify an ending condition for this trigger. If the <code>until</code> fires then the combination + fires. + + <p>The expression <code>t1.orFinally(t2)</code> fires every time <code>t1</code> fires, and finishes as + soon as either <code>t1</code> finishes or <code>t2</code> fires, in which case it fires one last time + for <code>t2</code>. Both <code>t1</code> and <code>t2</code> are executed in parallel. This means that <code>t1</code> may have fired since <code>t2</code> started, so not all of the elements that <code>t2</code> has + seen are necessarily in the current pane. + + <p>For example the final firing of the following trigger may only have 1 element: + + <pre><code> + Repeatedly.forever(AfterPane.elementCountAtLeast(2)) + .orFinally(AfterPane.elementCountAtLeast(5)) + </code> + </pre> + + <p>Note that if <code>t1</code> is <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnceTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine.OnceTriggerStateMachine</code></a>, then <code>t1.orFinally(t2)</code> is + the same as <code>AfterFirst.of(t1, t2)</code>.</div> +</li> +</ul> +</li> +</ul> +</li> +</ul> +</div> +</div> +<!-- ========= END OF CLASS DATA ========= --> +<!-- ======= START OF BOTTOM NAVBAR ====== --> +<div class="bottomNav"><a name="navbar.bottom"> +<!-- --> +</a> +<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> +<a name="navbar.bottom.firstrow"> +<!-- --> +</a> +<ul class="navList" title="Navigation"> +<li><a href="../../../../../../overview-summary.html">Overview</a></li> +<li><a href="package-summary.html">Package</a></li> +<li class="navBarCell1Rev">Class</li> +<li><a href="class-use/TriggerStateMachine.html">Use</a></li> +<li><a href="package-tree.html">Tree</a></li> +<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li> +<li><a href="../../../../../../index-all.html">Index</a></li> +<li><a href="../../../../../../help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/ReshuffleTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.MergingTriggerInfo.html" title="interface in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Next Class</span></a></li> +</ul> +<ul class="navList"> +<li><a href="../../../../../../index.html?org/apache/beam/runners/core/triggers/TriggerStateMachine.html" target="_top">Frames</a></li> +<li><a href="TriggerStateMachine.html" target="_top">No Frames</a></li> +</ul> +<ul class="navList" id="allclasses_navbar_bottom"> +<li><a href="../../../../../../allclasses-noframe.html">All Classes</a></li> +</ul> +<div> +<script type="text/javascript"><!-- + allClassesLink = document.getElementById("allclasses_navbar_bottom"); + if(window==top) { + allClassesLink.style.display = "block"; + } + else { + allClassesLink.style.display = "none"; + } + //--> +</script> +</div> +<div> +<ul class="subNavList"> +<li>Summary: </li> +<li><a href="#nested.class.summary">Nested</a> | </li> +<li><a href="#field.summary">Field</a> | </li> +<li><a href="#constructor.summary">Constr</a> | </li> +<li><a href="#method.summary">Method</a></li> +</ul> +<ul class="subNavList"> +<li>Detail: </li> +<li><a href="#field.detail">Field</a> | </li> +<li><a href="#constructor.detail">Constr</a> | </li> +<li><a href="#method.detail">Method</a></li> +</ul> +</div> +<a name="skip.navbar.bottom"> +<!-- --> +</a></div> +<!-- ======== END OF BOTTOM NAVBAR ======= --> +<p class="legalCopy"><small>Copyright © 2016–2017 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p> +</body> +</html>
http://git-wip-us.apache.org/repos/asf/beam-site/blob/7b1f1576/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html b/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html new file mode 100644 index 0000000..2c6b5ff --- /dev/null +++ b/content/documentation/sdks/javadoc/0.5.0/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html @@ -0,0 +1,371 @@ +<!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 Fri Jan 27 21:25:28 CET 2017 --> +<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> +<title>TriggerStateMachineContextFactory (Apache Beam SDK for Java, version 0.5.0)</title> +<meta name="date" content="2017-01-27"> +<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> +<script type="text/javascript" src="../../../../../../script.js"></script> +</head> +<body> +<script type="text/javascript"><!-- + try { + if (location.href.indexOf('is-external=true') == -1) { + parent.document.title="TriggerStateMachineContextFactory (Apache Beam SDK for Java, version 0.5.0)"; + } + } + catch(err) { + } +//--> +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; +</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><a href="package-summary.html">Package</a></li> +<li class="navBarCell1Rev">Class</li> +<li><a href="class-use/TriggerStateMachineContextFactory.html">Use</a></li> +<li><a href="package-tree.html">Tree</a></li> +<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li> +<li><a href="../../../../../../index-all.html">Index</a></li> +<li><a href="../../../../../../help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerInfo.html" title="interface in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineRunner.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Next Class</span></a></li> +</ul> +<ul class="navList"> +<li><a href="../../../../../../index.html?org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" target="_top">Frames</a></li> +<li><a href="TriggerStateMachineContextFactory.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> +<div> +<ul class="subNavList"> +<li>Summary: </li> +<li>Nested | </li> +<li>Field | </li> +<li><a href="#constructor.summary">Constr</a> | </li> +<li><a href="#method.summary">Method</a></li> +</ul> +<ul class="subNavList"> +<li>Detail: </li> +<li>Field | </li> +<li><a href="#constructor.detail">Constr</a> | </li> +<li><a href="#method.detail">Method</a></li> +</ul> +</div> +<a name="skip.navbar.top"> +<!-- --> +</a></div> +<!-- ========= END OF TOP NAVBAR ========= --> +<!-- ======== START OF CLASS DATA ======== --> +<div class="header"> +<div class="subTitle">org.apache.beam.runners.core.triggers</div> +<h2 title="Class TriggerStateMachineContextFactory" class="title">Class TriggerStateMachineContextFactory<W extends <a href="../../../../../../org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>></h2> +</div> +<div class="contentContainer"> +<ul class="inheritance"> +<li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li> +<li> +<ul class="inheritance"> +<li>org.apache.beam.runners.core.triggers.TriggerStateMachineContextFactory<W></li> +</ul> +</li> +</ul> +<div class="description"> +<ul class="blockList"> +<li class="blockList"> +<hr> +<br> +<pre>public class <span class="typeNameLabel">TriggerStateMachineContextFactory<W extends <a href="../../../../../../org/apache/beam/sdk/transforms/windowing/BoundedWindow.html" title="class in org.apache.beam.sdk.transforms.windowing">BoundedWindow</a>></span> +extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></pre> +<div class="block">Factory for creating instances of the various <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers"><code>TriggerStateMachine</code></a> contexts. + + <p>These contexts are highly interdependent and share many fields; it is inadvisable + to create them via any means other than this factory class.</div> +</li> +</ul> +</div> +<div class="summary"> +<ul class="blockList"> +<li class="blockList"> +<!-- ======== CONSTRUCTOR SUMMARY ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor.summary"> +<!-- --> +</a> +<h3>Constructor Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> +<caption><span>Constructors</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colOne" scope="col">Constructor and Description</th> +</tr> +<tr class="altColor"> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html#TriggerStateMachineContextFactory-org.apache.beam.sdk.transforms.windowing.WindowFn-org.apache.beam.sdk.util.state.StateInternals-org.apache.beam.runners.core.ActiveWindowSet-">TriggerStateMachineContextFactory</a></span>(<a href="../../../../../../org/apache/beam/sdk/transforms/windowing/WindowFn.html" title="class in org.apache.beam.sdk.transforms.windowing">WindowFn</a><?,<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>> windowFn, + <a href="../../../../../../org/apache/beam/sdk/util/state/StateInternals.html" title="interface in org.apache.beam.sdk.util.state">StateInternals</a><?> stateInternals, + <a href="../../../../../../org/apache/beam/runners/core/ActiveWindowSet.html" title="interface in org.apache.beam.runners.core">ActiveWindowSet</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>> activeWindows)</code> </td> +</tr> +</table> +</li> +</ul> +<!-- ========== METHOD SUMMARY =========== --> +<ul class="blockList"> +<li class="blockList"><a name="method.summary"> +<!-- --> +</a> +<h3>Method Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> +<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Method and Description</th> +</tr> +<tr id="i0" class="altColor"> +<td class="colFirst"><code><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html#base-W-org.apache.beam.sdk.util.Timers-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-">base</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/sdk/util/Timers.html" title="interface in org.apache.beam.sdk.util">Timers</a> timers, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> rootTrigger, + <a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a> finishedSet)</code> </td> +</tr> +<tr id="i1" class="rowColor"> +<td class="colFirst"><code><a href="../../../../../../org/apache/beam/sdk/util/state/MergingStateAccessor.html" title="interface in org.apache.beam.sdk.util.state">MergingStateAccessor</a><?,<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html#createMergingStateAccessor-W-java.util.Collection-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-">createMergingStateAccessor</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> mergeResult, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>> mergingWindows, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> trigger)</code> </td> +</tr> +<tr id="i2" class="altColor"> +<td class="colFirst"><code><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnElementContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnElementContext</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html#createOnElementContext-W-org.apache.beam.sdk.util.Timers-org.joda.time.Instant-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-">createOnElementContext</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/sdk/util/Timers.html" title="interface in org.apache.beam.sdk.util">Timers</a> timers, + org.joda.time.Instant elementTimestamp, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> rootTrigger, + <a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a> finishedSet)</code> </td> +</tr> +<tr id="i3" class="rowColor"> +<td class="colFirst"><code><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnMergeContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnMergeContext</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html#createOnMergeContext-W-org.apache.beam.sdk.util.Timers-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-java.util.Map-">createOnMergeContext</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/sdk/util/Timers.html" title="interface in org.apache.beam.sdk.util">Timers</a> timers, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> rootTrigger, + <a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a> finishedSet, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>,<a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a>> finishedSets)</code> </td> +</tr> +<tr id="i4" class="altColor"> +<td class="colFirst"><code><a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html#createStateAccessor-W-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-">createStateAccessor</a></span>(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> trigger)</code> </td> +</tr> +</table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> +<!-- --> +</a> +<h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3> +<code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone--" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize--" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass--" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode--" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify--" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang /Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString--" title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait--" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-int-" title="class or interface in java.lang">wait</a></code></li> +</ul> +</li> +</ul> +</li> +</ul> +</div> +<div class="details"> +<ul class="blockList"> +<li class="blockList"> +<!-- ========= CONSTRUCTOR DETAIL ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor.detail"> +<!-- --> +</a> +<h3>Constructor Detail</h3> +<a name="TriggerStateMachineContextFactory-org.apache.beam.sdk.transforms.windowing.WindowFn-org.apache.beam.sdk.util.state.StateInternals-org.apache.beam.runners.core.ActiveWindowSet-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>TriggerStateMachineContextFactory</h4> +<pre>public TriggerStateMachineContextFactory(<a href="../../../../../../org/apache/beam/sdk/transforms/windowing/WindowFn.html" title="class in org.apache.beam.sdk.transforms.windowing">WindowFn</a><?,<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>> windowFn, + <a href="../../../../../../org/apache/beam/sdk/util/state/StateInternals.html" title="interface in org.apache.beam.sdk.util.state">StateInternals</a><?> stateInternals, + <a href="../../../../../../org/apache/beam/runners/core/ActiveWindowSet.html" title="interface in org.apache.beam.runners.core">ActiveWindowSet</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>> activeWindows)</pre> +</li> +</ul> +</li> +</ul> +<!-- ============ METHOD DETAIL ========== --> +<ul class="blockList"> +<li class="blockList"><a name="method.detail"> +<!-- --> +</a> +<h3>Method Detail</h3> +<a name="base-org.apache.beam.sdk.transforms.windowing.BoundedWindow-org.apache.beam.sdk.util.Timers-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-"> +<!-- --> +</a><a name="base-W-org.apache.beam.sdk.util.Timers-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>base</h4> +<pre>public <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.TriggerContext</a> base(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/sdk/util/Timers.html" title="interface in org.apache.beam.sdk.util">Timers</a> timers, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> rootTrigger, + <a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a> finishedSet)</pre> +</li> +</ul> +<a name="createOnElementContext-org.apache.beam.sdk.transforms.windowing.BoundedWindow-org.apache.beam.sdk.util.Timers-org.joda.time.Instant-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-"> +<!-- --> +</a><a name="createOnElementContext-W-org.apache.beam.sdk.util.Timers-org.joda.time.Instant-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>createOnElementContext</h4> +<pre>public <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnElementContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnElementContext</a> createOnElementContext(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/sdk/util/Timers.html" title="interface in org.apache.beam.sdk.util">Timers</a> timers, + org.joda.time.Instant elementTimestamp, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> rootTrigger, + <a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a> finishedSet)</pre> +</li> +</ul> +<a name="createOnMergeContext-org.apache.beam.sdk.transforms.windowing.BoundedWindow-org.apache.beam.sdk.util.Timers-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-java.util.Map-"> +<!-- --> +</a><a name="createOnMergeContext-W-org.apache.beam.sdk.util.Timers-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-org.apache.beam.runners.core.triggers.FinishedTriggers-java.util.Map-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>createOnMergeContext</h4> +<pre>public <a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.OnMergeContext.html" title="class in org.apache.beam.runners.core.triggers">TriggerStateMachine.OnMergeContext</a> createOnMergeContext(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/sdk/util/Timers.html" title="interface in org.apache.beam.sdk.util">Timers</a> timers, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> rootTrigger, + <a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a> finishedSet, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>,<a href="../../../../../../org/apache/beam/runners/core/triggers/FinishedTriggers.html" title="interface in org.apache.beam.runners.core.triggers">FinishedTriggers</a>> finishedSets)</pre> +</li> +</ul> +<a name="createStateAccessor-org.apache.beam.sdk.transforms.windowing.BoundedWindow-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-"> +<!-- --> +</a><a name="createStateAccessor-W-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>createStateAccessor</h4> +<pre>public <a href="../../../../../../org/apache/beam/sdk/util/state/StateAccessor.html" title="interface in org.apache.beam.sdk.util.state">StateAccessor</a><?> createStateAccessor(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> window, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> trigger)</pre> +</li> +</ul> +<a name="createMergingStateAccessor-org.apache.beam.sdk.transforms.windowing.BoundedWindow-java.util.Collection-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-"> +<!-- --> +</a><a name="createMergingStateAccessor-W-java.util.Collection-org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>createMergingStateAccessor</h4> +<pre>public <a href="../../../../../../org/apache/beam/sdk/util/state/MergingStateAccessor.html" title="interface in org.apache.beam.sdk.util.state">MergingStateAccessor</a><?,<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>> createMergingStateAccessor(<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a> mergeResult, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" title="type parameter in TriggerStateMachineContextFactory">W</a>> mergingWindows, + <a href="../../../../../../org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.html" title="class in org.apache.beam.runners.core.triggers">ExecutableTriggerStateMachine</a> trigger)</pre> +</li> +</ul> +</li> +</ul> +</li> +</ul> +</div> +</div> +<!-- ========= END OF CLASS DATA ========= --> +<!-- ======= START OF BOTTOM NAVBAR ====== --> +<div class="bottomNav"><a name="navbar.bottom"> +<!-- --> +</a> +<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> +<a name="navbar.bottom.firstrow"> +<!-- --> +</a> +<ul class="navList" title="Navigation"> +<li><a href="../../../../../../overview-summary.html">Overview</a></li> +<li><a href="package-summary.html">Package</a></li> +<li class="navBarCell1Rev">Class</li> +<li><a href="class-use/TriggerStateMachineContextFactory.html">Use</a></li> +<li><a href="package-tree.html">Tree</a></li> +<li><a href="../../../../../../deprecated-list.html">Deprecated</a></li> +<li><a href="../../../../../../index-all.html">Index</a></li> +<li><a href="../../../../../../help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachine.TriggerInfo.html" title="interface in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../../org/apache/beam/runners/core/triggers/TriggerStateMachineRunner.html" title="class in org.apache.beam.runners.core.triggers"><span class="typeNameLink">Next Class</span></a></li> +</ul> +<ul class="navList"> +<li><a href="../../../../../../index.html?org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.html" target="_top">Frames</a></li> +<li><a href="TriggerStateMachineContextFactory.html" target="_top">No Frames</a></li> +</ul> +<ul class="navList" id="allclasses_navbar_bottom"> +<li><a href="../../../../../../allclasses-noframe.html">All Classes</a></li> +</ul> +<div> +<script type="text/javascript"><!-- + allClassesLink = document.getElementById("allclasses_navbar_bottom"); + if(window==top) { + allClassesLink.style.display = "block"; + } + else { + allClassesLink.style.display = "none"; + } + //--> +</script> +</div> +<div> +<ul class="subNavList"> +<li>Summary: </li> +<li>Nested | </li> +<li>Field | </li> +<li><a href="#constructor.summary">Constr</a> | </li> +<li><a href="#method.summary">Method</a></li> +</ul> +<ul class="subNavList"> +<li>Detail: </li> +<li>Field | </li> +<li><a href="#constructor.detail">Constr</a> | </li> +<li><a href="#method.detail">Method</a></li> +</ul> +</div> +<a name="skip.navbar.bottom"> +<!-- --> +</a></div> +<!-- ======== END OF BOTTOM NAVBAR ======= --> +<p class="legalCopy"><small>Copyright © 2016–2017 <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved.</small></p> +</body> +</html>