Ṣe Spark pese ọjọ & akoko nigbati a gba iṣẹlẹ kan pato ni ṣiṣan ti a ṣeto?
Kì í ṣe ní tààràtà. Orisun ti awọn data jẹ lodidi fun iṣẹlẹ akoko, awọn <unk>de<unk> akoko jẹ maa awọn timestamp lati awọn ifiranṣẹ olupin orisun ti o ti wa ni kika lati (Kafka, Kinesis, ati be be lo) ati awọn <unk>processing<unk> akoko le wa ni fi sii nigba ti processing awọn ti nwọle data ṣiṣan lilo awọn iṣẹ package current_timestamp iṣẹ. https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.functions$ Eleyi ni ko gangan nigbati Spark gba awọn data lati awọn olupin sugbon ti wa ni sunmọ ati ki o yoo wa ni akojọpọ nipa idasilẹ aarin. Akiyesi pe iṣẹ yii ko le ṣee lo nigbati o wa ni ipo lemọlemọfún. https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#supported-queries