com.google.cloud.dataflow.sdk.util

Class PaneInfoTracker

java.lang.Object

com.google.cloud.dataflow.sdk.util.PaneInfoTracker

public class PaneInfoTracker
extends Object

Encapsulates the logic for tracking the current PaneInfo and producing new PaneInfo for a trigger firing.

Constructor Summary

Constructors

Constructor and Description
PaneInfoTracker(TimerInternals timerInternals)

Method Summary

Modifier and Type	Method and Description
void	clear(ReduceFn.StateContext state)
StateContents<PaneInfo>	getNextPaneInfo(ReduceFn.Context context, boolean isForWatermarkTrigger, boolean isFinal)
void	storeCurrentPaneInfo(ReduceFn.Context context, PaneInfo currentPane)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PaneInfoTracker

public PaneInfoTracker(TimerInternals timerInternals)

Method Detail

clear

public void clear(ReduceFn.StateContext state)

getNextPaneInfo

public StateContents<PaneInfo> getNextPaneInfo(ReduceFn.Context context,
                                               boolean isForWatermarkTrigger,
                                               boolean isFinal)

storeCurrentPaneInfo

public void storeCurrentPaneInfo(ReduceFn.Context context,
                                 PaneInfo currentPane)