如何解决左加入榛子喷气机
我在我的应用程序中使用 Hazelcast Jet。
// value1
BatchStageWithKey<Map<String,Object>,Object> indianCustomerJson = value
.filter(model -> model.nationName().equals("india"))
.map(model -> JsonUtil.mapFrom(model.getJson_value()))
.groupingKey(p_json -> p_json.get("id"));
// value2
BatchStageWithKey<Map<String,Object> usaCustomerJson = value
.filter(model -> model.nationName().equals("usa"))
.map(model -> JsonUtil.mapFrom(model.getJson_value()))
.groupingKey(j_json -> j_json.get("id"));
这里我有两个 BatchStageWithKey 结果。
现在我想做左连接
from indianCustomerJson left join usaCustomerJson
基于 BatchStageKey
解决方法
连接是在 Hazelcast Jet 中手动完成的。您可以进行散列连接或共同组,请参阅以下示例:https://github.com/hazelcast/hazelcast-jet/tree/master/examples#joins
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。