问题描述
我正在尝试过滤 BatchStage 但它不起作用它给了我以下错误：
BatchStage<Object> bd = jdbcBatchStageData.flatMap(list -> Traversers.traverseArray(list.toArray()));
bd.filter(k -> {
return true;
}).writeTo(Sinks.logger());
我的代码如下，我做错了什么？
这是一个工作：
BatchStage<Object> bd = jdbcBatchStageData.flatMap(list -> Traversers.traverseArray(list.toArray()));
bd.filter(k -> {
return filterItems((List<Map<String,Object>>)rules.get("criteria"));
}).writeTo(Sinks.logger());
public static boolean filterItems(List<Map<String,Object>> innerrules) {
return true;
}
这并不奇怪：
COUNT()我不知道为什么它不起作用，帮帮我。 如果我删除过滤器，它可以正常工作，但我需要过滤。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）