더북(TheBook)

Note

Second 대신 Millisecond(밀리초)와 Minute(분) 객체를 사용해 주기를 지정할 수도 있다.

 

이 코드에서는 StreamingContext 생성자가 기존 SparkContext를 재사용했지만, 다음과 같이 스파크 설정 객체를 전달하면 SparkStream은 새로운 SparkContext를 시작한다.

val conf = new SparkConf().setMaster("local[4]").setAppName("App name")
val ssc = new StreamingContext(conf, Seconds(5))

 

이 코드는 스파크 독립형 애플리케이션에 사용할 수 있다. 하지만 스파크 셸에서는 SparkContext 두 개 이상을 동일 JVM에 초기화할 수 없으므로 코드가 동작하지 않는다.

신간 소식 구독하기
뉴스레터에 가입하시고 이메일로 신간 소식을 받아 보세요.