 ව්‍යුහගත ප්‍රවාහය තුළ විශේෂිත සිදුවීමක් ලැබුණු දිනය සහ වේලාව ස්පාර්ක් සපයන්නේද?
කෙලින්ම නොවේ. දත්තවල මූලාශ්‍රය සිදුවීම් වේලාව සඳහා වගකිව යුතු වේ, "පැමිණීමේ" වේලාව සාමාන්‍යයෙන් ඔබ කියවන පණිවිඩ සේවාදායක මූලාශ්‍රයෙන් (Kafka, Kinesis, ආදිය) වේලා මුද්‍රාව වන අතර එන ඒවා සැකසීමේදී "සැකසීම්" කාලය ඇතුළත් කළ හැක. කර්තව්‍ය පැකේජය භාවිතා කරමින් දත්ත ප්‍රවාහය current_timestamp ශ්‍රිතය. https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.functions$ Spark හට සේවාදායකයෙන් දත්ත ලැබුණු විට මෙය හරියටම සිදු නොවේ, නමුත් එය ආසන්නයේ සහ සිදුවනු ඇත. ප්‍රේරක පරතරය අනුව කාණ්ඩගත කළ යුතුය. අඛණ්ඩ මාදිලියේ ඇති විට මෙම කාර්යය භාවිතා කළ නොහැකි බව සලකන්න. https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#supported-queries