com.google.cloud.dataflow.sdk.util

Class NonEmptyPanes<W extends BoundedWindow>

java.lang.Object

com.google.cloud.dataflow.sdk.util.NonEmptyPanes<W>

Type Parameters:

W - The kind of windows being tracked.

public abstract class NonEmptyPanes<W extends BoundedWindow>
extends Object

Tracks which windows have non-empty panes. Specifically, which windows have new elements since their last triggering.

Constructor Summary

Constructors

Constructor and Description
NonEmptyPanes()

Method Summary

Modifier and Type	Method and Description
abstract void	clearPane(ReduceFn.Context context) Record that the given pane is empty.
static <W extends BoundedWindow> NonEmptyPanes<W>	create(WindowingStrategy<?,W> strategy, ReduceFn<?,?,?,W> reduceFn)
abstract StateContents<Boolean>	isEmpty(ReduceFn.Context context) Return true if the current pane for the window in context is non-empty.
abstract void	recordContent(ReduceFn.Context context) Record that some content has been added to the window in context, and therefore the current pane is not empty.

Methods inherited from class java.lang.Object

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

Constructor Detail

NonEmptyPanes

public NonEmptyPanes()

Method Detail

create

public static <W extends BoundedWindow> NonEmptyPanes<W> create(WindowingStrategy<?,W> strategy,
                                                                ReduceFn<?,?,?,W> reduceFn)

recordContent

public abstract void recordContent(ReduceFn.Context context)

Record that some content has been added to the window in context, and therefore the current pane is not empty.

clearPane

public abstract void clearPane(ReduceFn.Context context)

Record that the given pane is empty.

isEmpty

public abstract StateContents<Boolean> isEmpty(ReduceFn.Context context)

Return true if the current pane for the window in context is non-empty.