小编Agn*_*dra的帖子

我想知道如何从文本文件中仅提取数字数据并读取它的过程。我有一个名为 temperature.txt 的文本文件，它不断在模拟我的代码时附加数据。我想知道 javascript 中的代码以将数据实时流式传输到 plotly。

'use strict';
var plotly = require('plotly')('agni_2006','jtwubwfjtp');
var initdata = [{x:[], y:[], stream:{token:'g1z4cinzke', maxpoints:200}}];
var initlayout = {fileopt : 'overwrite', filename : 'try'};
plotly.plot(initdata, initlayout, function (err, msg) {
if (err) return console.log(err);
console.log(msg);

var stream1 = plotly.stream('g1z4cinzke', function (err, res) {
    if (err) return console.log(err);
    console.log(res);
    clearInterval(loop); // once stream is closed, stop writing
});
var i = 0;
var loop = setInterval(function () {
    var data = { x : i, y : …

我正在尝试使用zeppelin来绘制实时图表.我每分钟对推文进行情绪分析.我可以静态查询并绘制图表.但我希望这是动态完成的.我是zeppelin的新手,对angularJS知之甚少.这个问题的正确方法应该是什么？

 val final_score=uni_join.map{case((year,month,day,hour,minutes),(tweet_count,sentiment))=>(year, month, day, hour, minutes(sentiment/tweet_count).ceil)}


final_score.saveToCassandra("twitter", "score",writeConf = WriteConf(ttl = TTLOption.constant(1000)))

final_score.foreachRDD(score => {
val rowRDD =score.map{case(year,month,day,hour,minutes,sentiment) =>(year,month,day,hour,minutes,sentiment) }
  val tempDF = sqlContext.createDataFrame(rowRDD)

   z.angularBindGlobal("stream", parsed) //to bind parsed to stream.
   tempDF.registerTempTable("realTimeTable")
})

对上表进行查询,我就能得到图表.但我想每分钟动态更新图表,以便与情绪评分保持同步.先谢谢.[更新] zeppelin笔记本的角度部分如下:

%angular
<div id="graph"  style="height: 100%; width: 100%">
<canvas id="myChart" width="400" height="400"></canvas>
<div id="legendDiv"></div>
</div>
<script>
function initMap() {

var colorList = ["#fde577", "#ff6c40", "#c72a40", "#520833", "#a88399"]


var el = angular.element($('#stream'));

console.log("El is "+el) //returns el as object

angular.element(el).ready(function() {
    console.log('Hello')
    window.locationWatcher =el.$scope.$watch('stream', function(new, old){ …