isStreaming

Retourne True si cela DataFrame contient une ou plusieurs sources qui retournent en continu des données à mesure qu’elles arrivent. Un DataFrame qui lit les données d’une source de diffusion en continu doit être exécuté en tant qu’utilisation StreamingQuery de la start méthode dans DataStreamWriter. Les méthodes qui retournent une seule réponse, telle que count ou collect, lèvent une AnalysisException source de diffusion en continu présente.

Retours

bool

Exemples

df = spark.readStream.format("rate").load()
df.isStreaming
# True