IP Learning tsg项目 spark版本首次提交

This commit is contained in:
wanglihui
2020-08-07 10:07:52 +08:00
parent f44beda912
commit 6ea2518ee4
2 changed files with 22 additions and 0 deletions

View File

@@ -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)