ComputeEngineReset.java 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. package com.sagacloud.util.compute_engine.fjd;
  2. import com.alibaba.fastjson.JSONArray;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.sagacloud.repository.HBaseSaveManagerRepository;
  5. import com.sagacloud.util.compute_engine.util.ConstantCE;
  6. import com.sagacloud.util.compute_engine.util.QueryUtil;
  7. import com.zillion.database.agent.ZillionAgent;
  8. import com.zillion.util.common.ZillionConstant;
  9. import org.apache.hadoop.conf.Configuration;
  10. import java.io.InputStream;
  11. public class ComputeEngineReset {
  12. public static void main(String[] args) throws Exception {
  13. ZillionConstant.ObserverWait = 0L;
  14. Configuration configuration = new Configuration();
  15. InputStream inCoreSite = ConstantCE.getStream("core-site.xml");
  16. configuration.addResource(inCoreSite);
  17. InputStream inHbaseSite = ConstantCE.getStream("hbase-site.xml");
  18. configuration.addResource(inHbaseSite);
  19. InputStream inHdfsSite = ConstantCE.getStream("hdfs-site.xml");
  20. configuration.addResource(inHdfsSite);
  21. ZillionAgent agent = new ZillionAgent(configuration);
  22. agent.Start();
  23. if (!QueryUtil.database_exist(ConstantCE.database_name)) {
  24. HBaseSaveManagerRepository.randomZillionAgent().NDL_AddDatabase(ConstantCE.database_name);
  25. }
  26. // TableUtil.DropTables( ConstantCE.database_name);
  27. TableUtil.AddTables(ConstantCE.database_name);
  28. boolean ci_include = false;
  29. boolean is_clear = false;
  30. boolean only_log = true;
  31. TableUtil.ClearTables(ConstantCE.database_name, ci_include, is_clear, only_log);
  32. JSONArray times = QueryUtil.select(ConstantCE.database_name, "fjd_0_buildingcomputetime", new JSONObject());
  33. for (int i = 0; i < times.size(); i++) {
  34. JSONObject time = (JSONObject) times.get(i);
  35. JSONObject Criteria = new JSONObject();
  36. Criteria.put("building", time.get("building"));
  37. JSONObject Set = new JSONObject();
  38. Set.put("compute_time", time.get("first_compute_time"));
  39. QueryUtil.update(ConstantCE.database_name, "fjd_0_buildingcomputetime", Criteria, Set);
  40. }
  41. }
  42. }