public class ReplicateRows extends TableFunction<Row>
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns the result type of the evaluation method with a given signature.
collect, getKind, setCollector
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public ReplicateRows(TypeInformation fieldTypes)
public void eval(Object... inputs)
public TypeInformation<Row> getResultType()
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.
public TypeInformation<?> getParameterTypes(Class<?> signature)
TypeInformationabout the operands of the evaluation method with a given signature.
In order to perform operand type inference in SQL (especially when NULL is used) it might be
necessary to determine the parameter
TypeInformation of an evaluation method.
By default Flink's type extraction facilities are used for this but might be wrong for
more complex, custom, or composite types.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.