from: loader to: spark evidence: - file: "loader/src/main/scala/org/apache/s2graph/loader/subscriber/GraphSubscriber.scala" contains "import org.apache.s2graph.spark.spark.WithKafka" from: loader to: spark evidence: - file: "loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala" contains "import org.apache.s2graph.spark.spark.SparkApp" from: loader to: spark evidence: - file: "loader/src/main/scala/org/apache/s2graph/loader/subscriber/WalLogStat.scala" contains "import org.apache.spark.streaming.kafka.HasOffsetRanges" from: loader to: spark evidence: - file: "loader/src/main/scala/org/apache/s2graph/loader/subscriber/WalLogToHDFS.scala" contains "import org.apache.spark.streaming.kafka.HasOffsetRanges"