R/sdf_streaming.R

In sparklyr: R Interface to Apache Spark

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