isStreaming

Возвращает, True если он DataFrame содержит один или несколько источников, которые постоянно возвращают данные по мере поступления. ОбъектDataFrame, который считывает данные из источника потоковой передачи, должен выполняться в StreamingQuery качестве start метода.DataStreamWriter Методы, возвращающие один ответ, например count или collect, вызывают исключение AnalysisException при наличии источника потоковой передачи.

Возвраты

bool

Примеры

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