diff --git a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala index b5f875f..038e301 100644 --- a/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala +++ b/ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala @@ -22,6 +22,10 @@ object UpdateDocument { private val LOG = LoggerFactory.getLogger(UpdateDocument.getClass) private val baseArangoData = new BaseArangoData() + def updateDocument(): Unit ={ + + } + def updateVertexFqdn(): Unit ={ baseArangoData.readHistoryData("FQDN",historyVertexFqdnMap,classOf[BaseDocument]) val hisVerFqdnBc = spark.sparkContext.broadcast(historyVertexFqdnMap) diff --git a/ip-learning-spark/src/test/scala/cn/ac/iie/test/threadTest.java b/ip-learning-spark/src/test/scala/cn/ac/iie/test/threadTest.java new file mode 100644 index 0000000..912f4a2 --- /dev/null +++ b/ip-learning-spark/src/test/scala/cn/ac/iie/test/threadTest.java @@ -0,0 +1,18 @@ +package cn.ac.iie.test; + +public class threadTest implements Runnable { + private int count = 10; + @Override + public /*synchronized*/ void run() { + count--; + System.out.println(Thread.currentThread().getName() + " count = " + count); + } + + public static void main(String[] args) { + threadTest t = new threadTest(); + for(int i=0; i<5; i++) { + new Thread(t, "THREAD" + i).start(); + } + } + +}