Hi Ankur, you can have custom state in your Flink operators, including a graph. There is no graph state abstraction provided at the moment, but it shouldn't be too hard for you to implement your own. If your use-case only requires processing edge additions only, then you might want to take a look into gelly-stream [1]. Is it a single-pass graph streaming API, processing edge additions, and operating on graph summaries.
Cheers, -Vasia. [1]: https://github.com/vasia/gelly-streaming On 26 February 2016 at 14:59, Ankur Sharma <an...@stud.uni-saarland.de> wrote: > Hello, > > Thanks for reply. > > I want to create a graph from stream and query it. You got it right. > > Stream may be edges that are getting added or removed from the graph. > > Is there a way to create a empty global graph that can be transformed > using a stream of updates? > > Best, > *Ankur Sharma* > *3.15 E1.1 Universität des Saarlandes* > *66123, Saarbrücken Germany* > *Email: ankur.sha...@mpi-inf.mpg.de <ankur.sha...@mpi-inf.mpg.de> * > * an...@stud.uni-saarland.de <an...@stud.uni-saarland.de>* > > On 26 Feb 2016, at 14:55, Robert Metzger <rmetz...@apache.org> wrote: > > Hi Ankur, > > Can you provide a bit more information on what you are trying to achieve? > > Do you want to keep a graph build from an stream of events within Flink > and query that? > Or you you want to change the dataflow graph of Flink while a job is > running? > > Regards, > Robert > > > On Thu, Feb 25, 2016 at 11:19 PM, Ankur Sharma <an...@stud.uni-saarland.de > > wrote: > >> Hello, >> >> Is it possible to create and update graph with streaming edge and vertex >> data in flink? >> >> Best, >> *Ankur Sharma* >> *3.15 E1.1 Universität des Saarlandes* >> *66123, Saarbrücken Germany* >> *Email: ankur.sha...@mpi-inf.mpg.de <ankur.sha...@mpi-inf.mpg.de> * >> * an...@stud.uni-saarland.de <an...@stud.uni-saarland.de>* >> >> > >
