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

Packages that use RepeatedlyStateMachine

Package

Description

org.apache.beam.runners.core.triggers

State machine implementations for triggers, called "triggers" because + they react to events.

Methods in org.apache.beam.runners.core.triggers that return RepeatedlyStateMachine
Modifier and Type	Method and Description
`static RepeatedlyStateMachine`	RepeatedlyStateMachine.`forever(TriggerStateMachine repeated)` + Create a composite trigger that repeatedly executes the trigger `repeated`, firing each + time it fires and ignoring any indications to finish. +

Methods in org.apache.beam.runners.core.triggers that return RepeatedlyStateMachine

Modifier and Type

Method and Description

static RepeatedlyStateMachine

RepeatedlyStateMachine.forever(TriggerStateMachine repeated) +

Create a composite trigger that repeatedly executes the trigger repeated, firing each + time it fires and ignoring any indications to finish.

Packages that use TriggerStateMachine.MergingTriggerInfo

Package

Description

org.apache.beam.runners.core.triggers

State machine implementations for triggers, called "triggers" because + they react to events.

Methods in org.apache.beam.runners.core.triggers that return TriggerStateMachine.MergingTriggerInfo
Modifier and Type	Method and Description
`abstract TriggerStateMachine.MergingTriggerInfo`	TriggerStateMachine.OnMergeContext.`trigger()`

Methods in org.apache.beam.runners.core.triggers that return TriggerStateMachine.MergingTriggerInfo

Modifier and Type

Method and Description

abstract TriggerStateMachine.MergingTriggerInfo

TriggerStateMachine.OnMergeContext.trigger()

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

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

+ + +

Uses of TriggerStateMachine.OnElementContext in org.apache.beam.runners.core.triggers

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

Methods in org.apache.beam.runners.core.triggers that return TriggerStateMachine.OnElementContext
Modifier and Type	Method and Description
`TriggerStateMachine.OnElementContext`	TriggerStateMachineContextFactory.`createOnElementContext(W window, + Timers timers, + org.joda.time.Instant elementTimestamp, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet)`
`abstract TriggerStateMachine.OnElementContext`	TriggerStateMachine.OnElementContext.`forTrigger(ExecutableTriggerStateMachine trigger)` + Create an `OnElementContext` for executing the given trigger. +

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

Methods in org.apache.beam.runners.core.triggers with parameters of type TriggerStateMachine.OnElementContext
Modifier and Type	Method and Description
`void`	ExecutableTriggerStateMachine.`invokeOnElement(TriggerStateMachine.OnElementContext c)` + Invoke the `TriggerStateMachine.onElement(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnElementContext)` method for this trigger, ensuring that the + bits are properly updated if the trigger finishes. +
`void`	DefaultTriggerStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	RepeatedlyStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	AfterDelayFromFirstElementStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	AfterAllStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	AfterWatermarkStateMachine.FromEndOfWindow.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	AfterFirstStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`abstract void`	TriggerStateMachine.`onElement(TriggerStateMachine.OnElementContext c)` + Called every time an element is incorporated into a window. +
`void`	AfterEachStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	NeverStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	ReshuffleTriggerStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`
`void`	AfterPaneStateMachine.`onElement(TriggerStateMachine.OnElementContext c)`

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

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

+ + +

Uses of TriggerStateMachine.OnMergeContext in org.apache.beam.runners.core.triggers

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

Methods in org.apache.beam.runners.core.triggers that return TriggerStateMachine.OnMergeContext
Modifier and Type	Method and Description
`TriggerStateMachine.OnMergeContext`	TriggerStateMachineContextFactory.`createOnMergeContext(W window, + Timers timers, + ExecutableTriggerStateMachine rootTrigger, + FinishedTriggers finishedSet, + Map<W,FinishedTriggers> finishedSets)`
`abstract TriggerStateMachine.OnMergeContext`	TriggerStateMachine.OnMergeContext.`forTrigger(ExecutableTriggerStateMachine trigger)` + Create an `OnMergeContext` for executing the given trigger. +

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

Methods in org.apache.beam.runners.core.triggers with parameters of type TriggerStateMachine.OnMergeContext
Modifier and Type	Method and Description
`void`	ExecutableTriggerStateMachine.`invokeOnMerge(TriggerStateMachine.OnMergeContext c)` + Invoke the `TriggerStateMachine.onMerge(org.apache.beam.runners.core.triggers.TriggerStateMachine.OnMergeContext)` method for this trigger, ensuring that the bits + are properly updated. +
`void`	DefaultTriggerStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	RepeatedlyStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	AfterDelayFromFirstElementStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	AfterAllStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	AfterWatermarkStateMachine.AfterWatermarkEarlyAndLate.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	AfterWatermarkStateMachine.FromEndOfWindow.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	AfterFirstStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)`
`abstract void`	TriggerStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)` + Called immediately after windows have been merged. +
`void`	AfterEachStateMachine.`onMerge(TriggerStateMachine.OnMergeContext context)`
`void`	NeverStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	ReshuffleTriggerStateMachine.`onMerge(TriggerStateMachine.OnMergeContext c)`
`void`	AfterPaneStateMachine.`onMerge(TriggerStateMachine.OnMergeContext context)`