Flink的from/insert 有文档吗？

对不起，我无法提供具体的文档链接，因为我是一个基于文本的人工智能助手，无法访问互联网或提供特定的网站链接。然而，我可以告诉你如何在Flink中插入或更新数据。

在Flink中，你可以使用DataStream API的writeAsText()或writeUsingOutputFormat()方法将数据写入到文件或数据库中。这些方法需要一个输出格式作为参数，这个输出格式定义了如何写入数据。

例如，如果你想将数据写入到一个文本文件中，你可以使用writeAsText()方法，并将一个FileOutputFormat作为参数。以下是一个示例：

DataStream<String> output = env.addSource(new SimpleStringSchema())
                .name("StringSource");
output.writeUsingOutputFormat(new FileOutputFormat<>(new TextOutputFormat<>()))
        .name("Write to file");
env.execute("WordCount");

在这个示例中，SimpleStringSchema是一个字符串来源，它会生成一些随机字符串。FileOutputFormat是一个输出格式，它会将这些字符串写入到一个文件中。

如果你想将数据写入到一个数据库表中，你可以使用writeUsingOutputFormat()方法，并将一个DatabaseOutputFormat作为参数。以下是一个示例：

DataStream<Tuple2<String, Integer>> output = env.addSource(new WordCountSource())
                .name("WordCountSource");
output.writeUsingOutputFormat(new DatabaseOutputFormat<>(new MySqlOutputFormat<>()))
        .name("Write to database");
env.execute("WordCount");

在这个示例中，MySqlOutputFormat是一个数据库输出格式，它会将这些字符串写入到一个MySQL数据库表中。

直接在脚本中 from 即可，标准的 query。元数据注册后新建作业脚本正文中直接写 query
--DML
BEGIN STATEMENT SET; --写入多个Sink时，必填。
INSERT INTO blackhole_sinkA
SELECT UPPER(name), sum(score)
FROM datagen_source
GROUP BY UPPER(name);
INSERT INTO blackhole_sinkB
SELECT LOWER(name), max(score)
FROM datagen_source
GROUP BY LOWER(name);
END; --写入多个Sink时，必填。一键插入 ddl 的需求已经在排期规划中了~此回答整理自钉群“实时计算Flink产品交流群”