zhangbo 1 년 전
부모
커밋
16a8e939cf
1개의 변경된 파일1개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

+ 1 - 0
src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

@@ -80,6 +80,7 @@ object makedata_02_writeredis {
       redisTemplate.opsForValue.multiSet(redisFormat)
       result.iterator()
     })
+    println("action.count="+itemDataTakeRdd.count())
 
   }