Я построил график с использованием API GraphX и платформы баз данных, который представляет последовательность событий файла журнала. В частности, события файла журнала имеют следующую структуру:
"timestamp event1"
"timestamp event2"
"timestamp event3"
....
Таким образом, узлами являются типы событий (event1,event2,event3, etc...) с идентификатором, а ребра представляют временную последовательность событий с весом для каждого ребра, например:
src dest weight
event1 event2 0.7
event1 event4 0.3
event2 event3 0.5
Я должен найти все возможные пути от события src до события dest и затем проверить, соответствует ли определенная последовательность событий, прочитанная из другого файла с той же схемой (such as "timestamp event"), одному из найденных возможных путей. Я новичок в Spark и Scala, поэтому я надеюсь, что кто-нибудь может помочь мне сделать это.