Uses of Class org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine (Apache Beam SDK for Java, version 0.4.0)

In-Reply-To: <84111c2e83cc404e92f8e292fe1e5eeb@git.apache.org> References: <84111c2e83cc404e92f8e292fe1e5eeb@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [09/52] [partial] beam-site git commit: Publish Javadoc for version 0.4.0 archived-at: Mon, 09 Jan 2017 22:31:40 -0000 http://git-wip-us.apache.org/repos/asf/beam-site/blob/de6a0417/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/ExecutableTriggerStateMachine.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/ExecutableTriggerStateMachine.html b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/ExecutableTriggerStateMachine.html new file mode 100644 index 0000000..cd3ac04 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/ExecutableTriggerStateMachine.html @@ -0,0 +1,387 @@ + + + + + + +Uses of Class org.apache.beam.runners.core.triggers.ExecutableTriggerStateMachine (Apache Beam SDK for Java, version 0.4.0) + + + + + + + + +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ + + + + + + + + + + + + + + + +

Packages that use ExecutableTriggerStateMachine
Package	Description
org.apache.beam.runners.core	+ Provides utilities for Beam runner authors. +
org.apache.beam.runners.core.triggers	+ State machine implementations for triggers, called "triggers" because + they react to events. +

+ + +

Uses of ExecutableTriggerStateMachine in org.apache.beam.runners.core

+ + + + + + + + + + +

Constructors in org.apache.beam.runners.core with parameters of type ExecutableTriggerStateMachine
Constructor and Description
`ReduceFnRunner(K key, + WindowingStrategy<?,W> windowingStrategy, + ExecutableTriggerStateMachine triggerStateMachine, + StateInternals<K> stateInternals, + TimerInternals timerInternals, + OutputWindowedValue<KV<K,OutputT>> outputter, + SideInputReader sideInputReader, + Aggregator<Long,Long> droppedDueToClosedWindow, + ReduceFn<K,InputT,OutputT,W> reduceFn, + PipelineOptions options)`

+ + +

Uses of ExecutableTriggerStateMachine in org.apache.beam.runners.core.triggers

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + +

Methods in org.apache.beam.runners.core.triggers that return ExecutableTriggerStateMachine
Modifier and Type	Method and Description
`static <W extends BoundedWindow> ExecutableTriggerStateMachine`	ExecutableTriggerStateMachine.`create(TriggerStateMachine trigger)`
`static <W extends BoundedWindow> ExecutableTriggerStateMachine`	ExecutableTriggerStateMachine.`createForOnceTrigger(TriggerStateMachine.OnceTriggerStateMachine trigger, + int nextUnusedIndex)`
`ExecutableTriggerStateMachine`	TriggerStateMachine.TriggerInfo.`firstUnfinishedSubTrigger()` + Returns the first unfinished sub-trigger. +
`ExecutableTriggerStateMachine`	ExecutableTriggerStateMachine.`getSubTriggerContaining(int index)`
`ExecutableTriggerStateMachine`	TriggerStateMachine.TriggerInfo.`subTrigger(int subtriggerIndex)` + Access the executable version of the specified sub-trigger. +

+ + + + + + + + + + + + + + + + + + + + + + + + +

Methods in org.apache.beam.runners.core.triggers that return types with arguments of type ExecutableTriggerStateMachine
Modifier and Type	Method and Description
`Set<ExecutableTriggerStateMachine>`	FinishedTriggersSet.`getFinishedTriggers()` + Returns a mutable `Set` of the underlying triggers that are finished. +
`Iterable<ExecutableTriggerStateMachine>`	TriggerStateMachine.TriggerInfo.`subTriggers()` + Access the executable versions of the sub-triggers of the current trigger. +
`List<ExecutableTriggerStateMachine>`	ExecutableTriggerStateMachine.`subTriggers()`
`Iterable<ExecutableTriggerStateMachine>`	TriggerStateMachine.TriggerInfo.`unfinishedSubTriggers()` + Returns an iterable over the unfinished sub-triggers of the current trigger. +

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

Methods in org.apache.beam.runners.core.triggers with parameters of type ExecutableTriggerStateMachine
Modifier and Type	Method and Description
`TriggerStateMachine.TriggerContext`	TriggerStateMachineContextFactory.`base(W window, + Timers timers, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet)`
`void`	FinishedTriggersSet.`clearRecursively(ExecutableTriggerStateMachine trigger)`
`void`	FinishedTriggers.`clearRecursively(ExecutableTriggerStateMachine trigger)` + Sets the trigger and all of its subtriggers to unfinished. +
`void`	FinishedTriggersBitSet.`clearRecursively(ExecutableTriggerStateMachine trigger)`
`MergingStateAccessor<?,W>`	TriggerStateMachineContextFactory.`createMergingStateAccessor(W mergeResult, + Collection<W> mergingWindows, + ExecutableTriggerStateMachine trigger)`
`TriggerStateMachine.OnElementContext`	TriggerStateMachineContextFactory.`createOnElementContext(W window, + Timers timers, + org.joda.time.Instant elementTimestamp, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet)`
`TriggerStateMachine.OnMergeContext`	TriggerStateMachineContextFactory.`createOnMergeContext(W window, + Timers timers, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet, + Map<W,FinishedTriggers> finishedSets)`
`StateAccessor<?>`	TriggerStateMachineContextFactory.`createStateAccessor(W window, + ExecutableTriggerStateMachine trigger)`
`abstract TriggerStateMachine.TriggerContext`	TriggerStateMachine.TriggerContext.`forTrigger(ExecutableTriggerStateMachine trigger)` + Create a sub-context for the given sub-trigger. +
`abstract TriggerStateMachine.OnElementContext`	TriggerStateMachine.OnElementContext.`forTrigger(ExecutableTriggerStateMachine trigger)` + Create an `OnElementContext` for executing the given trigger. +
`abstract TriggerStateMachine.OnMergeContext`	TriggerStateMachine.OnMergeContext.`forTrigger(ExecutableTriggerStateMachine trigger)` + Create an `OnMergeContext` for executing the given trigger. +
`boolean`	ExecutableTriggerStateMachine.`isCompatible(ExecutableTriggerStateMachine other)`
`boolean`	FinishedTriggersSet.`isFinished(ExecutableTriggerStateMachine trigger)`
`boolean`	FinishedTriggers.`isFinished(ExecutableTriggerStateMachine trigger)` + Returns `true` if the trigger is finished. +
`boolean`	FinishedTriggersBitSet.`isFinished(ExecutableTriggerStateMachine trigger)`
`void`	FinishedTriggersSet.`setFinished(ExecutableTriggerStateMachine trigger, + boolean value)`
`void`	FinishedTriggers.`setFinished(ExecutableTriggerStateMachine trigger, + boolean value)` + Sets the fact that the trigger is finished. +
`void`	FinishedTriggersBitSet.`setFinished(ExecutableTriggerStateMachine trigger, + boolean value)`

+ + + + + + + + + + + + +

Method parameters in org.apache.beam.runners.core.triggers with type arguments of type ExecutableTriggerStateMachine
Modifier and Type	Method and Description
`static FinishedTriggersSet`	FinishedTriggersSet.`fromSet(Set<ExecutableTriggerStateMachine> finishedTriggers)`

+ + + + + + + + + + +

Constructors in org.apache.beam.runners.core.triggers with parameters of type ExecutableTriggerStateMachine
Constructor and Description
`TriggerStateMachineRunner(ExecutableTriggerStateMachine rootTrigger, + TriggerStateMachineContextFactory<W> contextFactory)`

+ +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ +

+ + http://git-wip-us.apache.org/repos/asf/beam-site/blob/de6a0417/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggers.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggers.html b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggers.html new file mode 100644 index 0000000..f25d806 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggers.html @@ -0,0 +1,241 @@ + + + + + + +Uses of Interface org.apache.beam.runners.core.triggers.FinishedTriggers (Apache Beam SDK for Java, version 0.4.0) + + + + + + + + +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ + + + + + + + + + + + +
Packages that use FinishedTriggers
Package Description
org.apache.beam.runners.core.triggers +
State machine implementations for triggers, called "triggers" because + they react to events.
+
+

Packages that use FinishedTriggers
Package	Description
org.apache.beam.runners.core.triggers	+ State machine implementations for triggers, called "triggers" because + they react to events. +

+ + +

Uses of FinishedTriggers in org.apache.beam.runners.core.triggers

+ + + + + + + + + + + + + + + + +

Classes in org.apache.beam.runners.core.triggers that implement FinishedTriggers
Modifier and Type	Class and Description
`class`	`FinishedTriggersBitSet` + A `FinishedTriggers` implementation based on an underlying `BitSet`. +
`class`	`FinishedTriggersSet` + An implementation of `FinishedTriggers` atop a user-provided mutable `Set`. +

+ + + + + + + + + + + + +

Methods in org.apache.beam.runners.core.triggers that return FinishedTriggers
Modifier and Type	Method and Description
`FinishedTriggers`	FinishedTriggers.`copy()` + Create an independent copy of this mutable `FinishedTriggers`. +

+ + + + + + + + + + + + + + + + + + + + +

Methods in org.apache.beam.runners.core.triggers with parameters of type FinishedTriggers
Modifier and Type	Method and Description
`TriggerStateMachine.TriggerContext`	TriggerStateMachineContextFactory.`base(W window, + Timers timers, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet)`
`TriggerStateMachine.OnElementContext`	TriggerStateMachineContextFactory.`createOnElementContext(W window, + Timers timers, + org.joda.time.Instant elementTimestamp, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet)`
`TriggerStateMachine.OnMergeContext`	TriggerStateMachineContextFactory.`createOnMergeContext(W window, + Timers timers, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet, + Map<W,FinishedTriggers> finishedSets)`

+ + + + + + + + + + + + +

Method parameters in org.apache.beam.runners.core.triggers with type arguments of type FinishedTriggers
Modifier and Type	Method and Description
`TriggerStateMachine.OnMergeContext`	TriggerStateMachineContextFactory.`createOnMergeContext(W window, + Timers timers, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet, + Map<W,FinishedTriggers> finishedSets)`

+ +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ +

+ + http://git-wip-us.apache.org/repos/asf/beam-site/blob/de6a0417/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersBitSet.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersBitSet.html b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersBitSet.html new file mode 100644 index 0000000..1e299d5 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersBitSet.html @@ -0,0 +1,177 @@ + + + + + + +Uses of Class org.apache.beam.runners.core.triggers.FinishedTriggersBitSet (Apache Beam SDK for Java, version 0.4.0) + + + + + + + + +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ + + + + + + + + + + + +
Packages that use FinishedTriggersBitSet
Package Description
org.apache.beam.runners.core.triggers +
State machine implementations for triggers, called "triggers" because + they react to events.
+
+

Packages that use FinishedTriggersBitSet
Package	Description
org.apache.beam.runners.core.triggers	+ State machine implementations for triggers, called "triggers" because + they react to events. +

+ + +

Uses of FinishedTriggersBitSet in org.apache.beam.runners.core.triggers

+ + + + + + + + + + + + + + + + + + + + +

Methods in org.apache.beam.runners.core.triggers that return FinishedTriggersBitSet
Modifier and Type	Method and Description
`FinishedTriggersBitSet`	FinishedTriggersBitSet.`copy()`
`static FinishedTriggersBitSet`	FinishedTriggersBitSet.`emptyWithCapacity(int capacity)`
`static FinishedTriggersBitSet`	FinishedTriggersBitSet.`fromBitSet(BitSet bitSet)`

+ +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ +

+ + http://git-wip-us.apache.org/repos/asf/beam-site/blob/de6a0417/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersSet.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersSet.html b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersSet.html new file mode 100644 index 0000000..6cc7b3f --- /dev/null +++ b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/FinishedTriggersSet.html @@ -0,0 +1,173 @@ + + + + + + +Uses of Class org.apache.beam.runners.core.triggers.FinishedTriggersSet (Apache Beam SDK for Java, version 0.4.0) + + + + + + + + +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ + + + + + + + + + + + +
Packages that use FinishedTriggersSet
Package Description
org.apache.beam.runners.core.triggers +
State machine implementations for triggers, called "triggers" because + they react to events.
+
+

Packages that use FinishedTriggersSet
Package	Description
org.apache.beam.runners.core.triggers	+ State machine implementations for triggers, called "triggers" because + they react to events. +

+ + +

Uses of FinishedTriggersSet in org.apache.beam.runners.core.triggers

+ + + + + + + + + + + + + + + + +

Methods in org.apache.beam.runners.core.triggers that return FinishedTriggersSet
Modifier and Type	Method and Description
`FinishedTriggersSet`	FinishedTriggersSet.`copy()`
`static FinishedTriggersSet`	FinishedTriggersSet.`fromSet(Set<ExecutableTriggerStateMachine> finishedTriggers)`

+ +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ +

+ + http://git-wip-us.apache.org/repos/asf/beam-site/blob/de6a0417/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/NeverStateMachine.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/NeverStateMachine.html b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/NeverStateMachine.html new file mode 100644 index 0000000..2f765e8 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.4.0/org/apache/beam/runners/core/triggers/class-use/NeverStateMachine.html @@ -0,0 +1,171 @@ + + + + + + +Uses of Class org.apache.beam.runners.core.triggers.NeverStateMachine (Apache Beam SDK for Java, version 0.4.0) + + + + + + + + +

+ + +

Skip navigation links

+ + + +

Frames
No Frames

All Classes

+ +

+ + +

+ + + + + + + + + + + + +
Packages that use NeverStateMachine
Package Description
org.apache.beam.runners.core.triggers +
State machine implementations for triggers, called "triggers" because + they react to events.
+
+