Commit 4183b23b authored by xiebaofa's avatar xiebaofa

删除

parent 71e81fb7
package com.miya.hive;
import com.miya.App;
import com.miya.common.SessionClient;
public class OriginalProcess {
private static final String SQL1 = "use catalog myhive";
private static final String SQL3 = "INSERT into accountpay_p " +
"SELECT *,DATE_FORMAT(`date`,'yyyyMMdd') from accountpay ";
public static void main(String[] args) throws Exception {
SessionClient session = new SessionClient(new App().getClass().getName(),"123.60.47.52", 8083, "streaming");
System.out.println(session.submitStatement(SQL1).getResults());
System.out.println(session.submitStatement(SQL3).getResults());
session.close();
}
}
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