بتوفر سبارك التاريخ والوقت اللي بتتلقاه حدث معين في التدفق المنظم؟
مش مباشرة. مصدر البيانات مسؤول عن وقت الحدث، وقت <unk>الوصول<unk> عادة الختم الزمني من مصدر سيرفر الرسالة اللي بتقرأ منه (كافكا، كينيسيس، إلخ) ويمكن إدراج وقت <unk>المعالجة<unk> وقت معالجة تدفق البيانات الواردة باستخدام وظيفة current_timestamp من حزمة الوظائف. 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