Hi Kurt,
Are you looking for Hybridsource[1], please see more information in
document[1].
Hope it helps.
[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/connectors/datastream/hybridsource/
Best,
JING ZHANG
Kurtis Walker 于2021年10月22日周五 上午9:33写道：
> I have a case where my Flink jo
Hi Aissa,
Flink supports to read from multiple sources in one job. You have to call
multiple times `StreamExecutionEnvironment.addSource()` with the respective
`SourceFunction`. Flink does not come with a ready-made MongoDB connector.
However, there is a project which tried to implement a MongoDB
One job can have multiple data sources. You would then have one stream per
source like this:
You can then create separate operator graphs from this so that you have
three
separate computations on the data, maybe like this:
They will be executed separately. However, if you don't want to combine t
In general, all-pairs-shortest-paths is a non-scalable problem as it
produces output proportional to the square of the number of vertices in
a network.
--sebastian
On 15.02.2015 12:37, Vasiliki Kalavri wrote:
Hi,
you can certainly use a for-loop like this to run SSSP several times.
Just mak
Hi,
you can certainly use a for-loop like this to run SSSP several times. Just
make sure you return or store the result of the computation for each
source, by adding a data sink e.g.:
for (id : Ids) {
graph.run(new SingleSourceShortestPaths(id, maxIterations))
.getVertices().print();
