| commit | 993fe11f147cfc2d73b2394bd1d2b077c1770d46 | [log] [tgz] |
|---|---|---|
| author | DO YUNG YOON <steamshon@apache.org> | Thu Dec 06 21:36:51 2018 +0900 |
| committer | DO YUNG YOON <steamshon@apache.org> | Thu Dec 06 21:36:51 2018 +0900 |
| tree | 2867e369449bc80054a038513b7b526a972f6ca1 | |
| parent | 328e19cf9d2acea8fc5bfebf7ab317f8ff61ccee [diff] |
change column logs to edges.
diff --git a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/BuildTopFeaturesProcess.scala b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/BuildTopFeaturesProcess.scala index 048b470..52b2ff0 100644 --- a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/BuildTopFeaturesProcess.scala +++ b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/BuildTopFeaturesProcess.scala
@@ -114,7 +114,7 @@ val dimValColumnName = "dimVal" val rawFeatures = edges - .withColumn(dimValColumnName, explode(dimValExtractUDF(col("logs")))) + .withColumn(dimValColumnName, explode(dimValExtractUDF(col("edges")))) val dict = buildDictionary(ss, rawFeatures, param, dimValColumnName)