The Apache Flink community is very happy to announce the release of Apache
Flink Table Store 0.1.0.
Apache Flink Table Store provides storage for building dynamic tables for
both stream and batch processing in Flink, supporting high speed data
ingestion and timely data query.
Please check out the
Hi dear engineer,
I want to override the function open() in my UDF, like:
In open() function, I want to fetch the configred value "black_list_path", then
simply print that value out. And I config this value in ./sql-client.sh console:
SET black_list_path = /root/list.properties
Then
Hi dear engineer,
I want to override the function open() in my UDF, like:
|
public class BlackListConvertFunction extends ScalarFunction {
@Override
public void open(FunctionContext context) throws Exception {
String path = context.getJobParameter("black_list_path",
"/confi
