java - 使用 Trident 从 RDBMS 中读取

Question

我是风暴和三叉戟的新手。我写了一个 spout（使用 Storm 核心）来读取 RDBMS。我重写的open()方法BaseRichSpout

public void open(Map map, TopologyContext topologyContext, SpoutOutputCollector spoutOutputCollector) {
    this.collector = spoutOutputCollector;
    this.context = topologyContext;
    // connect to DB
    connection = RDBMSConnection.getConnection();
    query = "SELECT * from CUSTOMER";

}

现在我想用 Trident 来做同样的事情，因为它内置了 join 功能。谁能告诉我，我们如何在 Trident 中实现相同的功能。我正计划实施IOpaquePartitionedTridentSpout。还有任何教程可以了解有关 Trident 的更多信息。

Answer 1

我建议不要为这样一个常见的任务重新发明轮子，看看现有的解决方案是否适合你。例如：https ://github.com/apache/storm/tree/master/external/storm-jdbc

您始终可以将其用作您自己的实现的参考。