all

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

@@ -81,7 +81,7 @@ object makedata_02_writeredis {
 
   def handleUser(record: Record, schema: TableSchema): util.ArrayList[String] = {
     val feature = RecommRedisFeatureConstructor.constructUserFeature(record)
-    val key = String.format("user_info_%s", feature.getUid)
+    val key = String.format("user:video:%s", feature.getUid)
     val value = feature.getValue
     val kv = new util.ArrayList[String](2)
     kv.add(key)

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_03_deleteredis.scala

@@ -62,7 +62,7 @@ object makedata_03_deleteredis {
 
   def handleUser(record: Record, schema: TableSchema): util.ArrayList[String] = {
     val feature = RecommRedisFeatureConstructor.constructUserFeature(record)
-    val key = String.format("user:video:%s", feature.getUid)
+    val key = String.format("user_info_:%s", feature.getUid)
     val value = feature.getValue
     val kv = new util.ArrayList[String](2)
     kv.add(key)