在apach spark流中使用foreachRDD内部的数据库连接
Insparkstreaming,Iwanttoquerythedbbeforeeachbatchisprocessed,storetheresultsinahashmapthatcanbeserializedandsentoveranetworktotheexecutors.在sparkstrea...
在apach spark流中使用foreachRDD内部的数据库连接
Insparkstreaming,Iwanttoquerythedbbeforeeachbatchisprocessed,storetheresultsinahashmapthatcanbeserializedandsentoveranetworktotheexecutors.在sparkstrea...