spark time 转 string

spark time 转 string

import org.apache.spark.SparkConf
import org.apache.spark.streaming.{Seconds, StreamingContext}

import java.time.Instant



val conf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount")
val ssc = new StreamingContext(conf, Seconds(1))       

 val lines = ssc.socketTextStream("localhost", 9999)
        val windowedWordCounts = lines.window(Seconds(4), Seconds(2))
        windowedWordCounts.foreachRDD(
            (rdd, time) => {
                println(Instant.ofEpochMilli(time.milliseconds))
                rdd
            }
        )

ssc.start()
ssc.awaitTermination()

// spark打印时间 spark时间 bigint 2 string

打印结果:

2021-11-08T01:10:14Z