R/sdf_streaming.R

Defines functions sdf_is_streaming

Documented in sdf_is_streaming

#' Spark DataFrame is Streaming
#'
#' Is the given Spark DataFrame a streaming data?
#'
#' @template roxlate-ml-x
#' @export
sdf_is_streaming <- function(x) {
  sc <- spark_connection(x)
  spark_version(sc) >= "2.0.0" && invoke(spark_dataframe(x), "isStreaming")
}

Try the sparklyr package in your browser

Any scripts or data that you put into this service are public.

sparklyr documentation built on Jan. 8, 2022, 5:06 p.m.