kotlin-spark-api_3.3.2_2.13/org.jetbrains.kotlinx.spark.api/saveAsHadoopFiles

saveAsHadoopFiles

fun <K, V> JavaDStream<Tuple2<K, V>>.saveAsHadoopFiles(prefix: String, suffix: String)

Save each RDD in this DStream as a Hadoop file. The file name at each batch interval is generated based on prefix and suffix: "prefix-TIME_IN_MS.suffix".