使用Trident从RDBMS读取数据

Question

我是新来的暴风和三叉叉树。我写了一个spout (使用Storm core)来读取RDBMS。我重写了BaseRichSpout的open()方法

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函数。有没有人可以告诉我，我们如何在三叉树中实现同样的功能。我计划实现IOpaquePartitionedTridentSpout。此外，还有任何教程可以了解更多关于三叉树的知识。

Answer 1

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

您可以随时使用它作为您自己实现的参考。