Skip to content

F
flink-sql-gateway-task
Commit 00811e7b authored by xiebaofa's avatar xiebaofa
Browse files
Options

修改字段类型

parent 0b18d42d
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
src/main/java/com/miya/huawei/ReturnPayKafkaBinlogToHBase.java
View file @ 00811e7b
......@@ -18,7 +18,7 @@ public class ReturnPayKafkaBinlogToHBase {
"status STRING ,\n" +
"trad_desc STRING ,\n" +
"date STRING ,\n" +
"miyadate DATETIME,\n" +
"miyadate STRING,\n" +
"retotal_fee STRING ,\n" +
"cashier STRING ,\n" +
"posbatch STRING ,\n" +
......@@ -59,7 +59,7 @@ public class ReturnPayKafkaBinlogToHBase {
" status STRING ,\n" +
" trad_desc STRING ,\n" +
" date STRING ,\n" +
" miyadate DATETIME,\n" +
" miyadate STRING,\n" +
" retotal_fee STRING ,\n" +
" cashier STRING ,\n" +
" posbatch STRING ,\n" +
......@@ -87,7 +87,7 @@ public class ReturnPayKafkaBinlogToHBase {
private static final String CREATE_JOB_SQL = "INSERT INTO huawei_hbase_sink_table\n" +
"SELECT " +
" CONCAT( CAST( (MOD(CAST(DATE_FORMAT(`date`,'yyyyMMdd') AS INT),10)) AS STRING ) , '~' , DATE_FORMAT(`date`,'yyyyMMdd'),'~' ,trade_no) ," +
" ROW(" +
" ROW(" +
"saasid ,\n" +
"marketid ,\n" +
"operator_id ,\n" +
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment