У меня есть потоковый структурированный фрейм данных в sparkR, и я хочу указать количество строк в этом фрейме. Я пробовал этот вид кода sql:
# make a temp dataframe
createOrReplaceTempView(df2_spark, "json_df")
n1 <- sql("select count(*) from json_df")
, но n1 - это другой структурированный фрейм данных, поэтому я хотел бы знать метод с sparkR для доступа к значению в n1, которое дает мне реальное число строк json_df,следующее: printSchema (n1) write.stream (n1, "console", "complete") дают мне: root | - count (1): long (nullable = false) и + -------- +
| count (1) |+ -------- + |2500 |+ -------- + Как извлечь 2500 в целое число, которое я могу использовать в следующем коде ??