storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dhaval Modi <dhavalmod...@gmail.com>
Subject Usage of storm-jdbc with flux
Date Tue, 31 Jan 2017 12:30:18 GMT
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

Mime
View raw message