12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- package com.sagacloud.util.compute_engine.fjd;
- import com.alibaba.fastjson.JSONArray;
- import com.alibaba.fastjson.JSONObject;
- import com.sagacloud.repository.HBaseSaveManagerRepository;
- import com.sagacloud.util.compute_engine.util.ConstantCE;
- import com.sagacloud.util.compute_engine.util.QueryUtil;
- import com.zillion.database.agent.ZillionAgent;
- import com.zillion.util.common.ZillionConstant;
- import org.apache.hadoop.conf.Configuration;
- import java.io.InputStream;
- public class ComputeEngineReset {
- public static void main(String[] args) throws Exception {
- ZillionConstant.ObserverWait = 0L;
- Configuration configuration = new Configuration();
- InputStream inCoreSite = ConstantCE.getStream("core-site.xml");
- configuration.addResource(inCoreSite);
- InputStream inHbaseSite = ConstantCE.getStream("hbase-site.xml");
- configuration.addResource(inHbaseSite);
- InputStream inHdfsSite = ConstantCE.getStream("hdfs-site.xml");
- configuration.addResource(inHdfsSite);
- ZillionAgent agent = new ZillionAgent(configuration);
- agent.Start();
- if (!QueryUtil.database_exist(ConstantCE.database_name)) {
- HBaseSaveManagerRepository.randomZillionAgent().NDL_AddDatabase(ConstantCE.database_name);
- }
- // TableUtil.DropTables( ConstantCE.database_name);
- TableUtil.AddTables(ConstantCE.database_name);
- boolean ci_include = false;
- boolean is_clear = false;
- boolean only_log = true;
- TableUtil.ClearTables(ConstantCE.database_name, ci_include, is_clear, only_log);
- JSONArray times = QueryUtil.select(ConstantCE.database_name, "fjd_0_buildingcomputetime", new JSONObject());
- for (int i = 0; i < times.size(); i++) {
- JSONObject time = (JSONObject) times.get(i);
- JSONObject Criteria = new JSONObject();
- Criteria.put("building", time.get("building"));
- JSONObject Set = new JSONObject();
- Set.put("compute_time", time.get("first_compute_time"));
- QueryUtil.update(ConstantCE.database_name, "fjd_0_buildingcomputetime", Criteria, Set);
- }
- }
- }
|