Description :
this bring the data from jdbc source to hbase
Yaml Description :
- source_table_name ---> JDBC source table name
- source_driver ---> JDBC source driver
- source_user ---> JDBC source user
- source_password ---> JDBC password
- source_columns ---> if you want to select few columns then column name (comma separated ) else null
- source_jdbc_url ---> JDBC source url
- hbase_table_name ---> hbase table name
- jdbc_query ---> JDBC query if needs to select few rows based on condition
- cast_query ---> if you want to add columns and changes column types before ingesting hbase write query
spark submit command :
spark-submit --class com.hemanth.com.HbaseIngesterApp --jars