Re: Re: 实现 UpsertStreamTableSink, BatchTableSink 接口代码

2019-03-26 文章 邓成刚【qq】
,1243296274875303847,"1c3.2729.20190327021200",XX,1553652720927835) 结论:true 是用来插入数据的,false 是用来删除数据的,出现false时一定会有一条之前插入的数据 。。。 邓成刚【qq】   发件人: 邓成刚【qq】 发送时间: 2019-03-26 18:40 收件人: user-zh 主题: Re: 回复: 实现 UpsertStreamTableSink, BatchTableSink 接口代码 不好意思,我理解错了,更正一下: APPEND 流是没有这个字段的,只有更新流才有,true

Re: 回复: 实现 UpsertStreamTableSink, BatchTableSink 接口代码

2019-03-26 文章 邓成刚【qq】
不好意思,我理解错了,更正一下: APPEND 流是没有这个字段的,只有更新流才有,true 表示 APPEND ,false 表示 update,这个值应该是流发出数据时自己带的,不是人为赋值的。。。   发件人: 邓成刚【qq】 发送时间: 2019-03-26 18:27 收件人: user-zh 主题: 回复: 实现 UpsertStreamTableSink, BatchTableSink 接口代码 这里面决定 update 或 delete 的 Boolean型值 怎么赋?   这里的  Boolean 值 是流类型决定,如果流是APPEND,则为true, update

回复: 实现 UpsertStreamTableSink, BatchTableSink 接口代码

2019-03-26 文章 邓成刚【qq】
这里面决定 update 或 delete 的 Boolean型值 怎么赋? 这里的  Boolean 值 是流类型决定,如果流是APPEND,则为true, update,为false,你直接打印流会有这个字段 不知道我的理解是否正确,期待大佬解答。。。 邓成刚【qq】   发件人: baiyg25...@hundsun.com 发送时间: 2019-03-26 18:02 收件人: user-zh 主题: 实现 UpsertStreamTableSink, BatchTableSink 接口代码 大家好!         伙伴们,附件有实现 blink 中 flink

实现 UpsertStreamTableSink, BatchTableSink 接口代码

2019-03-26 文章 baiyg25...@hundsun.com
大家好! 伙伴们,附件有实现 blink 中 flink-table 模块 UpsertStreamTableSink, BatchTableSink 接口代码 ,自实现类放在 flink-jdbc 模块 org.apache.flink.api.java.io.jdbc 包下。大神们帮忙看看呗! 江湖救急啊! 目前实现后,在代码中调用,报异常: Exception in thread "main" org.apache.flink.table.api.TableException: Arity [4] of result