Release the code about readFromRedis

2019-09-04 15:00:39 +08:00 · 2019-09-04 15:00:39 +08:00 · 007a8dd85a
parent 5ac2165f41
commit 007a8dd85a
1 changed files with 2 additions and 3 deletions
--- a/piflow-bundle/src/main/scala/cn/piflow/bundle/redis/ReadFromRedis.scala
+++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/redis/ReadFromRedis.scala
@ -56,9 +56,8 @@ class ReadFromRedis extends ConfigurableStop{
      }
      Row.fromSeq(row.toArray.toSeq)
    })
-    //val df=spark.createDataFrame(newRDD,dfSchema)
-    //newRDD.show(20)
-    //out.write(df)
+    val df=spark.createDataFrame(newRDD,dfSchema)
+    out.write(df)
  }

  def initialize(ctx: ProcessContext): Unit = {