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 |