maybe a custom SparkStreamingInterpreter can handle this. zeppelin WS protocol is defined in:
https://github.com/apache/zeppelin/blob/master/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/socket/Message.java <https://github.com/apache/zeppelin/blob/master/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/socket/Message.java> every [c-s] message is handled by zeppelin backend, [s-c] is handled by zeppelin frontend.All you have to do is when new streaming data is there, triigger a [s-c] message from backend, a frontend event handler may also required. > 在 2016年9月8日，11:39，kant kodali <kanth...@gmail.com> 写道： > > ok here is a concrete example. I am still trying to connect the dots..If I > were to split Zeppelin as both front end and backend then I wouldn't choose > to use Zeppelin in the first place. The main motivation for me to explore > Zeppelin is that I don't have to spend time developing different > visualiztions. I have used tableau before I see Zeppelin to be similar in > some ways. ok now here is the problem I am trying to solve and any help I can > get will be great! > > say I am trying to build a time series graph(bar graph or whatever works) > where my x axis represent time and y axis represent total number of > transactions and say every second I get updates through web socket from my > server and I need the graph to be updated every second. thats it. > > please let me know if that is feasible. > > Thanks, > Kant > > On Wed, Sep 7, 2016 at 6:59 PM, spacewalk...@163.com > <mailto:spacewalk...@163.com> <spacewalk...@163.com > <mailto:spacewalk...@163.com>> wrote: > i thought it was a separating zeppelin backend and frontend problem, but what > @corneadoug say is a high-level WS description, maybe i misinterpretation > @kant kodali’s issue > > >> 在 2016年9月8日，09:48，Corneau Damien <cornead...@gmail.com >> <mailto:cornead...@gmail.com>> 写道： >> >> This change wouldn't solve your issue, it is the address where the front-end >> send his API requests and listen to WS (zeppelin server) >> I guess your requirements are different. >> >> The way Zeppelin works is usually pretty simple: >> >> 1) You type your code in the front-end >> 2) That code is sent to Zeppelin server to be run >> 3) The server send it to the right processing engine >> 4) Processing engine send back the result >> 5) Zeppelin Server send a websocket event >> 6) Front-end show whatever he receives >> >> You might be able to find a few Notebook examples on how some people used >> Spark Streaming here: >> https://www.zeppelinhub.com/viewer/showcases/Streaming >> <https://www.zeppelinhub.com/viewer/showcases/Streaming> >> >> On Thu, Sep 8, 2016 at 3:30 AM, kant kodali <kanth...@gmail.com >> <mailto:kanth...@gmail.com>> wrote: >> Hi! Thanks for this but I still see the big picture. I have not used Angular >> before nor I am a frontend guy. so I have the following questions. >> >> Why do we need to change the source code? isn't this configurable or isn't >> there a way to pass url as a parameter? If you think it is the easiest way >> sure I can change that. >> How change this let me grab data from my websocket server and display it >> with the charts/graphs (simple to graphs we see when we run sql on Zeppelin >> notebook) >> if there is a simple example that would be awesome. >> Thanks again! >> >> >> >> >> >> On Wed, Sep 7, 2016 5:05 AM, spacewalk...@163.com >> <mailto:spacewalk...@163.com> spacewalk...@163.com >> <mailto:spacewalk...@163.com> wrote: >> @kant kodali >> >> change zeppelin-web\ src\components\baseUrl\baseUrl.service.js like this: >> >> this.getWebsocketUrl = function() { >> var wsProtocol = location.protocol === 'https:' ? 'wss:' : 'ws:'; >> return wsProtocol + ‘//your_ip_address:' + this.getPort() + >> skipTrailingSlash(location.pathname) + '/ws'; >> }; >> >> this.getRestApiBase = function() { >> return location.protocol + '//your_ip_address:' + this.getPort() + >> skipTrailingSlash(location.pathname) + >> '/api'; >> }; >>> 在 2016年9月7日，15:39，kant kodali <kanth...@gmail.com >>> <mailto:kanth...@gmail.com>> 写道： >>> >>> HI Guys, >>> >>> I have a server which can handle websocket connections. Now I would like to >>> see if there is a way to tell apache zeppellin to create to websocket >>> connect to my server and display the whatever it received? >>> >>> Thanks, >>> Kant >> >> > >
