zeppelin에서 공유 변수를 사용하는 방식이 있다.


디폴트(isolated)는 같은 노트에서도 변수를 공유하지 않는다. 



하나의 노트에서만 변수를 공유하려면,  다음과 같이 진행한다. 



zeppelin -> interpreter 설정 -> spark interpreter 설정에서 edit 실행 -> interpreter mode를 scope 변경 -> spark interpreter 설정에서 restart 실행



만약 전체 노트에서 공유하고 싶다면, shared mode로 변경한다. 




테스트를 다음과 같이 진행할 수 있다. 







참고로, 


- 변수 공유는 interpreter가 재시작되면 다시 노트를 실행해 결과를 캐싱하게 해야 한다.

- registerTempTable에 저장하면 모든 노트에서 사용할 수 있다. 

'scala' 카테고리의 다른 글

[scala] Future 2  (0) 2016.11.23
[scala] Future 1  (0) 2016.11.22
spark의 mapValues/reduceByKey 예시  (0) 2016.11.14
[scala] List.map(function) 예시  (0) 2016.11.08
[zeppelin] zeppelin으로 spark 연동 시 팁 (또는 주의 사항)  (0) 2016.11.07
Posted by '김용환'
,