Использование Trident для чтения из СУБД

Я новичок в Storm and Trident. Я написал носик (использовал ядро ​​​​Storm) для чтения из СУБД. Я переопределяю метод 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, чтобы сделать то же самое, поскольку он имеет встроенную функцию соединения. Кто-нибудь, пожалуйста, дайте мне знать, как мы можем добиться такой же функциональности в Trident. Я планирую реализовать IOpaquePartitionedTridentSpout. Также есть какой-либо учебник, чтобы узнать больше о Trident.


java apache-storm trident
person Alok    schedule 19.02.2015    source источник
comment
вы можете проверить trident mongodb в качестве эталона для своей работы здесь: github.com/eldenbishop/trident-mongodb< /а>   -  person Shams    schedule 22.02.2015

Ответы (1)


arrow_upward
0
arrow_downward

Я бы посоветовал не изобретать велосипед для такой распространенной задачи и посмотреть, подойдет ли вам одно из существующих решений. Например: https://github.com/apache/storm/tree/master/external/storm-jdbc

Вы всегда можете использовать его в качестве эталона для своей собственной реализации.

person aljipa    schedule 03.09.2015
comment
Эта библиотека не имеет реализации носика. - person Luiz Picanço; 11.02.2016