Je, cheche kutoa tarehe na wakati wakati tukio fulani ni kupokea katika mkondo umeboreshwa?
Si moja kwa moja. chanzo cha data ni wajibu kwa ajili ya tukio wakati, <unk>kuwasili<unk> wakati ni kawaida timestamp kutoka ujumbe server chanzo wewe ni kusoma kutoka (Kafka, Kinesis, nk) na <unk>processing<unk> wakati inaweza kuingizwa wakati wa usindikaji wa data zinazoingia mkondo kwa kutumia kazi mfuko current_timestamp kazi. https://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.sql.functions$ Hii si hasa wakati Spark kupokea data kutoka server lakini ni karibu na itakuwa makundi kwa trigger muda. Kumbuka kwamba kazi hii haiwezi kutumika wakati katika hali ya kuendelea. https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html#supported-queries