public interface WindowFramer
Modifier and Type | Field and Description |
---|---|
static TemplateClassDefinition<WindowFramer> |
FRAME_TEMPLATE_DEFINITION |
static TemplateClassDefinition<WindowFramer> |
NOFRAME_TEMPLATE_DEFINITION |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
void |
doWork()
process the inner batch and write the aggregated values in the container
|
int |
getOutputCount() |
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
|
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
|
void |
setup(List<WindowDataBatch> batches,
VectorContainer container,
OperatorContext operatorContext,
boolean requireFullPartition,
WindowPOP popConfig) |
static final TemplateClassDefinition<WindowFramer> NOFRAME_TEMPLATE_DEFINITION
static final TemplateClassDefinition<WindowFramer> FRAME_TEMPLATE_DEFINITION
void setup(List<WindowDataBatch> batches, VectorContainer container, OperatorContext operatorContext, boolean requireFullPartition, WindowPOP popConfig) throws SchemaChangeException
SchemaChangeException
void doWork() throws SchemaChangeException
SchemaChangeException
DrillException
int getOutputCount()
void cleanup()
boolean isSamePartition(@Named(value="b1Index") int b1Index, @Named(value="b1") VectorAccessible b1, @Named(value="b2Index") int b2Index, @Named(value="b2") VectorAccessible b2) throws SchemaChangeException
b1Index
- index of first rowb1
- batch for first rowb2Index
- index of second rowb2
- batch for second rowSchemaChangeException
boolean isPeer(@Named(value="b1Index") int b1Index, @Named(value="b1") VectorAccessible b1, @Named(value="b2Index") int b2Index, @Named(value="b2") VectorAccessible b2) throws SchemaChangeException
b1Index
- index of first rowb1
- batch for first rowb2Index
- index of second rowb2
- batch for second rowSchemaChangeException
Copyright © 1970 The Apache Software Foundation. All rights reserved.