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