pyspark.sql.streaming
StreamingQuery.awaitTermination StreamingQuery.exception StreamingQuery.explain StreamingQuery.id StreamingQuery.isActive StreamingQuery.lastProgress StreamingQuery.name StreamingQuery.processAllAvailable StreamingQuery.recentProgress StreamingQuery.runId StreamingQuery.status StreamingQuery.stop StreamingQueryManager.active StreamingQueryManager.addListener StreamingQueryManager.awaitAnyTermination StreamingQueryManager.get StreamingQueryManager.removeListener StreamingQueryManager.resetTerminated