Package org.apache.drill.exec.physical.impl.window

Class WindowFunction

java.lang.Object

org.apache.drill.exec.physical.impl.window.WindowFunction

public abstract class WindowFunction
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	WindowFunction.Type

Method Summary

Modifier and Type	Method	Description
boolean	canDoWork(int numBatchesAvailable, WindowPOP pop, boolean frameEndReached, boolean partitionEndReached)
boolean	requiresFullPartition(WindowPOP pop)

Methods inherited from class java.lang.Object

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

Method Details

requiresFullPartition

public boolean requiresFullPartition(WindowPOP pop)

Parameters:

pop - window group definition

Returns:

true if this window function requires all batches of current partition to be available before processing the first batch

canDoWork

public boolean canDoWork(int numBatchesAvailable,
 WindowPOP pop,
 boolean frameEndReached,
 boolean partitionEndReached)

Parameters:

numBatchesAvailable - number of batches available for current partition

pop - window group definition

frameEndReached - we found the last row of the first batch's frame

partitionEndReached - all batches of current partition are available

Returns:

true if this window function can process the first batch immediately