??????flink-1.11 ddl kafka-to-hive????

[JasonLee]

hi
hive??????????????????????????????????????????


| |
JasonLee
|
|
??????17610775...@163.com
|

Signature is customized by Netease Mail Master

??2020??07??21?? 19:09??kcz ??????
hive-1.2.1
chk 
??????????????chk????????????????chk??????kafka????????????????hive??????????????????????????????????
String hiveSql = "CREATE  TABLE  stream_tmp.fs_table (\n" +
       "  host STRING,\n" +
       "  url STRING," +
       "  public_date STRING" +
       ") partitioned by (public_date string) " +
       "stored as PARQUET " +
       "TBLPROPERTIES (\n" +
       "  'sink.partition-commit.delay'='0 s',\n" +
       "  'sink.partition-commit.trigger'='partition-time',\n" +
       "  'sink.partition-commit.policy.kind'='metastore,success-file'" +
       ")";
tableEnv.executeSql(hiveSql);


tableEnv.executeSql("INSERT INTO  stream_tmp.fs_table SELECT host, url, 
DATE_FORMAT(public_date, 'yyyy-MM-dd') FROM stream_tmp.source_table");