【发布时间】:2021-10-07 14:53:30
【问题描述】:
有一个关于在 Kafka 中加入表的性能问题, 目前拓扑定义如下代码:
table1
.leftJoin(table2, Pair::with)
.leftJoin(table3, Pair::add)
.join(table4, (left) -> left.getValue(0).getId() Triplet::add)
.leftJoin(table5, Quartet::add)
.leftJoin(table6, Quintet::add)
我只是想知道如果我将 .join 移到其他人之前,可以提高使用数据的性能和速度吗? (如下代码):
table1
.join(table4, (left) -> left.getValue(0).getId() Pair::with)
.leftJoin(table2, Pair::add)
.leftJoin(table3, Triplet::add)
.leftJoin(table5, Quartet::add)
.leftJoin(table6, Quintet::add)
【问题讨论】:
标签: java apache-kafka apache-kafka-streams