Package org.apache.calcite.sql

Class SqlSessionTableFunction

java.lang.Object

org.apache.calcite.sql.SqlOperator

org.apache.calcite.sql.SqlFunction

org.apache.calcite.sql.SqlWindowTableFunction

org.apache.calcite.sql.SqlSessionTableFunction

All Implemented Interfaces:

SqlTableFunction

public class SqlSessionTableFunction
extends SqlWindowTableFunction

SqlSessionTableFunction implements an operator for per-key sessionization. It allows four parameters:

1. table as data source
2. a descriptor to provide a watermarked column name from the input table
3. a descriptor to provide a column as key, on which sessionization will be applied, optional
4. an interval parameter to specify a inactive activity gap to break sessions

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.sql.SqlWindowTableFunction

SqlWindowTableFunction.AbstractOperandMetadata

Field Summary

Fields inherited from class org.apache.calcite.sql.SqlWindowTableFunction

ARG0_TABLE_FUNCTION_WINDOWING, PARAM_DATA, PARAM_KEY, PARAM_OFFSET, PARAM_SIZE, PARAM_SLIDE, PARAM_TIMECOL

Fields inherited from class org.apache.calcite.sql.SqlOperator

kind, MDX_PRECEDENCE, NL

Constructor Summary

Constructors

Constructor	Description
SqlSessionTableFunction()

Method Summary

Methods inherited from class org.apache.calcite.sql.SqlWindowTableFunction

argumentMustBeScalar, getOperandTypeChecker, getRowTypeInference

Methods inherited from class org.apache.calcite.sql.SqlFunction

deriveType, getFunctionType, getNameAsId, getParamNames, getParamTypes, getSqlIdentifier, getSyntax, isQuantifierAllowed, unparse, validateCall, validateQuantifier

Methods inherited from class org.apache.calcite.sql.SqlOperator

acceptCall, acceptCall, adjustType, allowsFraming, checkOperandCount, checkOperandTypes, constructArgNameList, constructArgTypeList, constructOperandList, createCall, createCall, createCall, createCall, createCall, createCall, createCall, deriveOperandType, equals, getAllowedSignatures, getAllowedSignatures, getKind, getLeftPrec, getMonotonicity, getMonotonicity, getName, getOperandCountRange, getOperandTypeInference, getReturnTypeInference, getRightPrec, getSignatureTemplate, getSqlCallFactory, getStrongPolicyInference, hashCode, inferReturnType, inferReturnType, isAggregator, isDeterministic, isDynamicFunction, isGroup, isGroupAuxiliary, isName, isSymmetrical, leftPrec, not, preValidateCall, requiresDecimalExpansion, requiresOrder, requiresOver, reverse, rewriteCall, rightPrec, toString, unparseListClause, unparseListClause, validateOperands, validRexOperands

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.calcite.sql.SqlTableFunction

tableCharacteristic

Constructor Details

SqlSessionTableFunction

public SqlSessionTableFunction()