کیا سٹرکچرڈ اسٹریمنگ میں کوئی خاص ایونٹ موصول ہونے پر چنگاری تاریخ اور وقت فراہم کرتی ہے؟
-
براہ راست نہیں۔ ڈیٹا کا ماخذ ایونٹ کے وقت کے لیے ذمہ دار ہے، "آمد" کا وقت عام طور پر اس میسج سرور سورس کا ٹائم اسٹیمپ ہوتا ہے جس سے آپ پڑھ رہے ہیں (کافکا، کنیسیس، وغیرہ) اور آنے والے وقت پر کارروائی کرتے وقت "پراسیسنگ" کا وقت داخل کیا جا سکتا ہے۔ فنکشن پیکیج کرنٹ_ٹائم اسٹیمپ فنکشن کا استعمال کرتے ہوئے ڈیٹا اسٹریم۔ https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.functions$ یہ اس وقت نہیں ہے جب اسپارک کو سرور سے ڈیٹا موصول ہوا تھا لیکن قریب ہے اور ہوگا ٹرگر وقفہ کے لحاظ سے گروپ کیا جائے۔ نوٹ کریں کہ یہ فنکشن مسلسل موڈ میں ہونے پر استعمال نہیں کیا جا سکتا ہے۔ https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#supported-queries