@Internal public final class TemporalTableFunctionImpl extends TemporalTableFunction
timeAttribute
, for which it returns matching version of
the underlyingHistoryTable
, from which this TemporalTableFunction
was created.
This function shouldn't be evaluated. Instead calls to it should be rewritten by the optimiser into other operators (like Temporal Table Join).
collector
Modifier and Type | Method and Description |
---|---|
static TemporalTableFunction |
create(QueryOperation operationTree,
Expression timeAttribute,
Expression primaryKey) |
void |
eval(Timestamp row) |
Expression |
getPrimaryKey() |
RowTypeInfo |
getResultType()
Returns the result type of the evaluation method with a given signature.
|
Expression |
getTimeAttribute() |
QueryOperation |
getUnderlyingHistoryTable() |
collect, getKind, getParameterTypes, setCollector
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequirements, isDeterministic
public void eval(Timestamp row)
public Expression getTimeAttribute()
public Expression getPrimaryKey()
public RowTypeInfo getResultType()
TableFunction
This method needs to be overridden in case Flink's type extraction facilities are not
sufficient to extract the TypeInformation
based on the return type of the evaluation
method. Flink's type extraction facilities can handle basic types or
simple POJOs but might be wrong for more complex, custom, or composite types.
getResultType
in class TableFunction<Row>
TypeInformation
of result type or null
if Flink should determine the typepublic QueryOperation getUnderlyingHistoryTable()
public static TemporalTableFunction create(QueryOperation operationTree, Expression timeAttribute, Expression primaryKey)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.