isStreaming: isStreaming

Description Usage Arguments Value Note See Also Examples

Description

Returns TRUE if this SparkDataFrame contains one or more sources that continuously return data as it arrives. A dataset that reads data from a streaming source must be executed as a StreamingQuery using write.stream.

Usage

1
is_streaming(.data)

Arguments

.data

a spark_tbl

Value

TRUE if this SparkDataFrame is from a streaming source

Note

isStreaming since 2.2.0

experimental

See Also

read.stream write.stream

Other SparkDataFrame functions: write.stream

Examples

1
2
3
4
5
6
## Not run: 
spark_session()
df <- read_stream("socket", host = "localhost", port = 9999)
is_Streaming(df)

## End(Not run)

danzafar/tidyspark documentation built on Sept. 30, 2020, 12:19 p.m.