Hi Dmytro,
For 1.11:
Like Godfrey said, you can use
"TableEnvironment#createFunction/createTemporarySystemFunction". And like
Timo said, can support function with new type system.
But for 1.10 and 1.9:
A workaround way is:
"tEnv.getCatalog(tEnv.getCurrentCatalog()).get().createFunction"
You may
Hi Dmytro,
table function will be supported in Flink 1.11 with the new type system.
Hopefully, we can also support aggregate functions until then.
Regards,
Timo
On 14.04.20 15:33, godfrey he wrote:
Hi Dmytro,
Currently, TableEnvironment does not support
register AggregationFunction and
Hi Dmytro,
Currently, TableEnvironment does not support register AggregationFunction
and TableFunction, because type extractor has not been unified for Java and
Scala.
One approach is we can use "TableEnvironment#createFunction" which will
register UDF to catalog.
I find
`StreamTableEnvironment.create()` yields a `StreamTableEnvironmentImpl`
object,
which has several `registerFunction` interface for
ScalarFunction/TableFunction/AggregateFunction/TableAggregateFunction.
`TableEnvironment.create()` yields a `TableEnvironmentImpl` object, which
is a unify entry
Hi All,
Could you please tell how to register custom Aggregation function in blink
batch app?
In case of streaming mode:
We create
EnvironmentSettings bsSettings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
StreamTableEnvironment tableEnv =
