[SPARK]개별 평균 & Spark Streaming 테스트 과정1. 실시간 데이터 수집2. 게이트웨이-디바이스-센서종류 별로 데이터 그룹3. 개별 평균 센서 원시데이터 샘플 {"device":"gateway","mac":"00:40:9d:98:aa:79","timezone":"KST","data":[{"mac":"d0:09:cb:d1:08:da","rssi":"-36","time":"2017-02-03 17:44:20.710,"sensor":"9012","value":"874"}]} SPARK STREAMING 에서 실시간으로 들어오는 Json 형태의 센서 데이터 Parsing JavaDStream line_data = data.flatMap(new FlatMapFunction() { private static final long serialVersion.. 더보기 이전 1 ··· 85 86 87 88 89 90 91 ··· 98 다음