ost","query-one",
new SimpleStringSchema))
stream.addSink(new SinkFunction[String] {
override def invoke(value: String) = {
println(value)
}
})
env.execute("QueryOneExecutor")
}
}
Best,
Ankur Sharma
> On 06 Mar 2016, at 20:34, Márton B
() = { }
}
override def nextRecord() = {
}
}
Best,
Ankur Sharma
Information Systems Group
3.15 E1.1 Universität des Saarlandes
66123, Saarbrücken Germany
Email: ankur.sha...@mpi-inf.mpg.de <mailto:ankur.sha...@mpi-inf.mpg.de>
an...@stud.uni-saarland.de <mailto:an...@stud.uni-sa
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
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 <mailto:ankur.sha...@mpi-inf.mpg.de>
an...@stud.uni-saarl
MIN, I want to throw it away.
Using this priority I want to select the next job (given by tuple) that is
scheduled. These tasks have to be periodically scheduled until they are removed
from the queue completely.
Let me know if something is unclear.
Best,
Ankur Sharma
Information Systems Group
Hey,
Can you guide me to some example of ContinuousProcessingTimeTrigger?
I want to partition input stream into TimeWindow that should fire at continuous
time interval on its on without waiting for a new element to enter the stream.
Could you guide me to it?
Thanks
Best,
Ankur Sharma
which are not visible
earlier.
I also tried writing the result to socket but it also has same effect.
Please help.
Best,
Ankur Sharma
Information Systems Group
3.15 E1.1 Universität des Saarlandes
66123, Saarbrücken Germany
Email: ankur.sha...@mpi-inf.mpg.de <mailto:ankur.sha...@mpi-inf.mpg
