Ko dzomoto anopa musi & nguva apo chiitiko chaicho chakagamuchirwa mune muronga kuyerera?
Kwete zvakananga. The kunobva mashoko ndiye anokonzera chiitiko nguva, ari <unk>kusvika<unk> nguva iri kazhinji timestamp kubva shoko Server kunobva uri kuverenga kubva (Kafka, Kinesis, etc.) uye <unk>processing<unk> nguva inogona akaiswa apo processing ari kuuya date rukova vachishandisa mabasa pasuru current_timestamp basa. https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.functions$ This is not exactly when Spark received the data from the server but is close and will be grouped by trigger interval. Cherechedza kuti basa iri harigoni kushandiswa kana riri muchikamu chinopfuurira. https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#supported-queries