spark dstream
-
DStreamsspark streaming 2022. 4. 10. 18:49
코드 import org.apache.spark.sql.SparkSession import org.apache.spark.streaming.dstream.DStream import org.apache.spark.streaming.{Seconds, StreamingContext} object StreamingTest { def main(args: Array[String]): Unit = { val spark: SparkSession = SparkSession.builder().appName("StreamingTest").master("local[2]").getOrCreate() // 입력 데이터 존재 여부에 관계 없이 무조건 1초마다 배치가 실행됨 val ssc: StreamingContext = new ..