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

Class NoFrameSupportTemplate

java.lang.Object

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

All Implemented Interfaces:

WindowFramer

public abstract class NoFrameSupportTemplate
extends Object
implements WindowFramer

WindowFramer implementation that doesn't support the FRAME clause (will assume the default frame).

According to the SQL standard, LEAD, LAG, ROW_NUMBER, NTILE and all ranking functions don't support the FRAME clause. This class will handle such functions.

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.impl.window.WindowFramer

FRAME_TEMPLATE_DEFINITION, NOFRAME_TEMPLATE_DEFINITION

Constructor Summary

Constructors

Constructor and Description
NoFrameSupportTemplate()

Method Summary

Modifier and Type	Method and Description
void	cleanup()
abstract void	copyFromInternal(int inIndex, int outIndex)
abstract void	copyNext(int inIndex, int outIndex) Copies value(s) from inIndex row to outIndex row.
abstract void	copyPrev(int inIndex, int outIndex) Copies value(s) from inIndex row to outIndex row.
void	doWork() Processes all rows of the first batch.
int	getOutputCount()
abstract boolean	isPeer(int b1Index, VectorAccessible b1, int b2Index, VectorAccessible b2) Compares two rows from different batches (can be the same), if they have the same value for the order by expression
abstract boolean	isSamePartition(int b1Index, VectorAccessible b1, int b2Index, VectorAccessible b2) Compares two rows from different batches (can be the same), if they have the same value for the partition by expression
abstract void	outputRow(int outIndex, Partition partition) Called once for each row after we evaluate all peer rows.
abstract boolean	resetValues() Reset all window functions
void	setup(List<WindowDataBatch> batches, VectorContainer container, OperatorContext oContext, boolean requireFullPartition, WindowPOP popConfig)
abstract void	setupCopyFromInternal(VectorAccessible incoming, VectorAccessible outgoing)
abstract void	setupCopyNext(VectorAccessible incoming, VectorAccessible outgoing)
abstract void	setupCopyPrev(VectorAccessible incoming, VectorAccessible outgoing)
abstract void	setupPartition(WindowDataBatch incoming, VectorAccessible outgoing) Called once per partition, before processing the partition.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NoFrameSupportTemplate

public NoFrameSupportTemplate()

Method Detail

setup

public void setup(List<WindowDataBatch> batches,
                  VectorContainer container,
                  OperatorContext oContext,
                  boolean requireFullPartition,
                  WindowPOP popConfig)
           throws SchemaChangeException

Specified by:

setup in interface WindowFramer

Throws:

SchemaChangeException

doWork

public void doWork()

Processes all rows of the first batch.

Specified by:

doWork in interface WindowFramer

getOutputCount

public int getOutputCount()

Specified by:

getOutputCount in interface WindowFramer

Returns:

number rows processed in last batch

cleanup

public void cleanup()

Specified by:

cleanup in interface WindowFramer

toString

public String toString()

Overrides:

toString in class Object

outputRow

public abstract void outputRow(@Named(value="outIndex")
                               int outIndex,
                               @Named(value="partition")
                               Partition partition)
                        throws SchemaChangeException

Called once for each row after we evaluate all peer rows. Used to write a value in the row

Parameters:

outIndex - index of row

partition - object used by "computed" window functions

Throws:

SchemaChangeException

setupPartition

public abstract void setupPartition(@Named(value="incoming")
                                    WindowDataBatch incoming,
                                    @Named(value="outgoing")
                                    VectorAccessible outgoing)
                             throws SchemaChangeException

Called once per partition, before processing the partition. Used to setup read/write vectors

Parameters:

incoming - batch we will read from

outgoing - batch we will be writing to

Throws:

SchemaChangeException

copyNext

public abstract void copyNext(@Named(value="inIndex")
                              int inIndex,
                              @Named(value="outIndex")
                              int outIndex)
                       throws SchemaChangeException

Copies value(s) from inIndex row to outIndex row. Mostly used by LEAD. inIndex always points to the row next to outIndex

Parameters:

inIndex - source row of the copy

outIndex - destination row of the copy.

Throws:

SchemaChangeException

setupCopyNext

public abstract void setupCopyNext(@Named(value="incoming")
                                   VectorAccessible incoming,
                                   @Named(value="outgoing")
                                   VectorAccessible outgoing)
                            throws SchemaChangeException

Throws:

SchemaChangeException

copyPrev

public abstract void copyPrev(@Named(value="inIndex")
                              int inIndex,
                              @Named(value="outIndex")
                              int outIndex)
                       throws SchemaChangeException

Copies value(s) from inIndex row to outIndex row. Mostly used by LAG. inIndex always points to the previous row

Parameters:

inIndex - source row of the copy

outIndex - destination row of the copy.

Throws:

SchemaChangeException

setupCopyPrev

public abstract void setupCopyPrev(@Named(value="incoming")
                                   VectorAccessible incoming,
                                   @Named(value="outgoing")
                                   VectorAccessible outgoing)
                            throws SchemaChangeException

Throws:

SchemaChangeException

copyFromInternal

public abstract void copyFromInternal(@Named(value="inIndex")
                                      int inIndex,
                                      @Named(value="outIndex")
                                      int outIndex)
                               throws SchemaChangeException

Throws:

SchemaChangeException

setupCopyFromInternal

public abstract void setupCopyFromInternal(@Named(value="incoming")
                                           VectorAccessible incoming,
                                           @Named(value="outgoing")
                                           VectorAccessible outgoing)
                                    throws SchemaChangeException

Throws:

SchemaChangeException

resetValues

public abstract boolean resetValues()
                             throws SchemaChangeException

Reset all window functions

Throws:

SchemaChangeException

isSamePartition

public abstract boolean isSamePartition(@Named(value="b1Index")
                                        int b1Index,
                                        @Named(value="b1")
                                        VectorAccessible b1,
                                        @Named(value="b2Index")
                                        int b2Index,
                                        @Named(value="b2")
                                        VectorAccessible b2)
                                 throws SchemaChangeException

Compares two rows from different batches (can be the same), if they have the same value for the partition by expression

Specified by:

isSamePartition in interface WindowFramer

Parameters:

b1Index - index of first row

b1 - batch for first row

b2Index - index of second row

b2 - batch for second row

Returns:

true if the rows are in the same partition

Throws:

SchemaChangeException

isPeer

public abstract boolean isPeer(@Named(value="b1Index")
                               int b1Index,
                               @Named(value="b1")
                               VectorAccessible b1,
                               @Named(value="b2Index")
                               int b2Index,
                               @Named(value="b2")
                               VectorAccessible b2)
                        throws SchemaChangeException

Compares two rows from different batches (can be the same), if they have the same value for the order by expression

Specified by:

isPeer in interface WindowFramer

Parameters:

b1Index - index of first row

b1 - batch for first row

b2Index - index of second row

b2 - batch for second row

Returns:

true if the rows are in the same partition

Throws:

SchemaChangeException