Package org.apache.druid.sql.calcite.rel

Class Windowing

java.lang.Object

org.apache.druid.sql.calcite.rel.Windowing

public class Windowing
extends Object

Maps onto a WindowOperatorQuery.

Known sharp-edges/limitations: 1. The support is not yet fully aware of the difference between RANGE and ROWS when evaluating peers. (Note: The built-in functions are all implemented with the correctly defined semantics, so ranking functions that are defined to use RANGE do the right thing) 2. No support for framing last/first functions 3. No nth function 4. No finalization, meaning that aggregators like sketches that rely on finalization might return surprising results 5. No big big test suite of loveliness

Field Summary

Fields

Modifier and Type	Field	Description
static final com.google.common.collect.ImmutableMap<String,org.apache.druid.sql.calcite.rel.Windowing.ProcessorMaker>	KNOWN_WINDOW_FNS

Constructor Summary

Constructors

Constructor	Description
Windowing(RowSignature signature, List<OperatorFactory> ops)

Method Summary

Modifier and Type	Method	Description
static Windowing	fromCalciteStuff(PartialDruidQuery partialQuery, PlannerContext plannerContext, RowSignature sourceRowSignature, org.apache.calcite.rex.RexBuilder rexBuilder, VirtualColumnRegistry virtualColumnRegistry)
List<OperatorFactory>	getOperators()
RowSignature	getSignature()

Methods inherited from class java.lang.Object

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

Field Details

KNOWN_WINDOW_FNS

public static final com.google.common.collect.ImmutableMap<String,org.apache.druid.sql.calcite.rel.Windowing.ProcessorMaker> KNOWN_WINDOW_FNS

Constructor Details

Windowing

public Windowing(RowSignature signature,
 List<OperatorFactory> ops)

Method Details

fromCalciteStuff

@Nonnull
public static Windowing fromCalciteStuff(PartialDruidQuery partialQuery,
 PlannerContext plannerContext,
 RowSignature sourceRowSignature,
 org.apache.calcite.rex.RexBuilder rexBuilder,
 VirtualColumnRegistry virtualColumnRegistry)

getSignature

public RowSignature getSignature()

getOperators

public List<OperatorFactory> getOperators()