This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-0.4 in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
commit 9bf62b1c98b324247d851bf7003fd5745b718c72 Author: SYG-ATONE <[email protected]> AuthorDate: Fri Apr 21 19:26:08 2023 +0800 [doc] Improve flink api doc (#978) --- docs/content/api/flink-api.md | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/docs/content/api/flink-api.md b/docs/content/api/flink-api.md index d654c5d09..4d3c60471 100644 --- a/docs/content/api/flink-api.md +++ b/docs/content/api/flink-api.md @@ -81,7 +81,11 @@ public class WriteToTable { Row.ofKind(RowKind.INSERT, "Alice", 12), Row.ofKind(RowKind.INSERT, "Bob", 5), Row.ofKind(RowKind.UPDATE_BEFORE, "Alice", 12), - Row.ofKind(RowKind.UPDATE_AFTER, "Alice", 100)); + Row.ofKind(RowKind.UPDATE_AFTER, "Alice", 100)) + .returns( + Types.ROW_NAMED( + new String[] {"name", "age"}, + Types.STRING, Types.INT)); // interpret the DataStream as a Table Schema schema = Schema.newBuilder()
