You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Dhaval Modi <dh...@gmail.com> on 2017/01/31 12:30:18 UTC

Usage of storm-jdbc with flux

Hi All,

Can any one guide me with JDBC connection to Phoenix, using Flux &
storm-jdbc module of Storm?

Below is YAML code, I am trying to build. But I am facing issue with "
*com.google.common.collect.Maps"*

*+++++++++++++++++++++++++++++++++++*
*# Components*
*components:*
*  - id: "hikariConfigMap"*
*    className: "com.google.common.collect.Maps"*
*    configMethods:*
*      - name: "newHashMap"*
*      - name: "put"*
*        args:*
*          - "dataSourceClassName"*
*          - "${phoenix.className}"*
*      - name: "put"*
*        args:*
*          - "dataSource.url"*
*          - "${phoenix.url}"*
*      - name: "put"*
*        args:*
*          - "dataSource.user"*
*          - "${phoenix.user}"*
*      - name: "put"*
*        args:*
*          - "dataSource.password"*
*          - "${phoenix.password}"*
*  - id: "connectionProvider"*
*    className: "org.apache.storm.jdbc.common.HikariCPConnectionProvider"*
*    constructorArgs:*
*      - "ref: hikariConfigMap"*
*  - id: "simpleJdbcMapper"*
*    className: "org.apache.storm.jdbc.mapper.SimpleJdbcMapper"*
*    constructorArgs:*
*      - "${phoenix.tableName}"*
*      - "ref: connectionProvider"*
*++++++++++++++++++++++++++++++++++++++++++++++++++++++++++*

Regards,
Dhaval Modi
dhavalmodi24@gmail.com