Dear Gordon, Till
Thank you so much for your helpful answers. I managed to solve my problem
with your guidelines.
Much appreciated, keep up the good work!
Cheers
Cumprimentos,
*Pedro Lima Monteiro*
On 17 February 2017 at 10:10, Tzu-Li (Gordon) Tai
wrote:
> Sorry, I just realized I didn’t no
Sorry, I just realized I didn’t notice the second part question of your last
email when replying.
Thanks Till for answering it!
On February 17, 2017 at 6:05:58 PM, Till Rohrmann (trohrm...@apache.org) wrote:
Dear Gordon,
Thanks for your help, I think I am on the right track as of now.
On the
Hi Pedro,
in order to add new sources you have to first stop the job (maybe taking a
savepoint if you want to resume later on) and then restart the job with the
changed topology.
Cheers,
Till
On Thu, Feb 16, 2017 at 4:06 PM, Tzu-Li (Gordon) Tai
wrote:
> Good to know!
>
>
> On February 16, 2017
Good to know!
On February 16, 2017 at 10:13:28 PM, Pedro Monteiro
(pedro.mlmonte...@gmail.com) wrote:
Dear Gordon,
Thanks for your help, I think I am on the right track as of now.
On the other hand, I have another question: is it possible to add sources to
environments that are already execu
Dear Gordon,
Thanks for your help, I think I am on the right track as of now.
On the other hand, I have another question: is it possible to add sources
to environments that are already executing? In what I am currently
developing, I need to add new sources as they arrive to my system.
I will wai
Thank you again for your prompt response.
I will give it a try and will come back to you.
*Pedro Lima Monteiro*
On 16 February 2017 at 10:20, Tzu-Li (Gordon) Tai
wrote:
> I would recommend checking out the Flink RabbitMQ Source for examples:
> https://github.com/apache/flink/blob/master/flink-
I would recommend checking out the Flink RabbitMQ Source for examples:
https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
For your case, you should extend the `RichSourceFunction` which p
Dear Tzu-Li,
Thank you so much for your prompt response.
Lets assume I have a variable, in Java, env which is my
StreamExecutionEnvironment. When I go ahead and attempt to do:
> env.addSource();
>
It requests an implementation of a Source Function interface:
> env.addSource(new SourceFunct
Hi Pedro!
This is definitely possible, by simply writing a Flink `SourceFunction` that
uses MongoDB clients to fetch the data.
It should be straightforward and works well with MongoDB’s cursor APIs.
Could you explain a bit which part in particular you were stuck with?
Cheers,
Gordon
On Februa
Good morning,
I am trying to get data from MongoDB to be analysed in Flink.
I would like to know if it is possible to stream data from MongoDB into
Flink. I have looked into Flink's source function to add in the addSource
method of the StreamExecutionEnvironment but I had no luck.
Can anyone help
10 matches
Mail list logo
