fix compile error.
Project: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/commit/3a37a587 Tree: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/tree/3a37a587 Diff: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/diff/3a37a587 Branch: refs/heads/master Commit: 3a37a587c6f44b0f685a994d3529215c5ee6f3bb Parents: 2c3bb98 Author: DO YUNG YOON <[email protected]> Authored: Mon Oct 23 15:20:55 2017 +0900 Committer: DO YUNG YOON <[email protected]> Committed: Mon Oct 23 15:20:55 2017 +0900 ---------------------------------------------------------------------- .../org/apache/s2graph/loader/subscriber/TransferToHFile.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/3a37a587/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala ---------------------------------------------------------------------- diff --git a/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala b/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala index a5d73f4..618c1bd 100644 --- a/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala +++ b/loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala @@ -123,9 +123,9 @@ object TransferToHFile extends SparkApp { } def toKeyValues(strs: Seq[String], labelMapping: Map[String, String], autoEdgeCreate: Boolean): Iterator[KeyValue] = { - val kvList = new util.ArrayList[KeyValue] + val kvList = new java.util.ArrayList[KeyValue] for (s <- strs) { - val elementList = Graph.toGraphElement(s, labelMapping).toSeq + val elementList = GraphSubscriberHelper.g.toGraphElement(s, labelMapping).toSeq for (element <- elementList) { if (element.isInstanceOf[S2Edge]) { val edge = element.asInstanceOf[S2Edge] @@ -136,7 +136,7 @@ object TransferToHFile extends SparkApp { } } else if (element.isInstanceOf[S2Vertex]) { val vertex = element.asInstanceOf[S2Vertex] - val putRequestList = GraphSubscriberHelper.g.storage.vertexSerializer(vertex).toKeyValues.map { kv => + val putRequestList = GraphSubscriberHelper.g.getStorage(vertex.service).vertexSerializer(vertex).toKeyValues.map { kv => new PutRequest(kv.table, kv.row, kv.cf, kv.qualifier, kv.value, kv.timestamp) } for (p <- putRequestList) {
