Re: How can I set configuration of process function from job's main?

Posted by Timo Walther on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-can-I-set-configuration-of-process-function-from-job-s-main-tp19245p19247.html

Hi,

the configuration parameter is just legacy API. You can simply pass any
serializable object to the constructor of your process function.

Regards,
Timo


Am 29.03.18 um 20:38 schrieb Main Frame:

> Hi guys! Iam newbie in flink and I have probably silly question about streaming api.
>
> So for the instance:
>
> I trying to apply SomeProcessFunction to stream1
>
> …
> DataStream<ObjectNode> stream2 = stream1.process(new MyProcessFunction()).name("Ingest data»);
> …
>
> I have created package-private class with MyProcessFunction which extends ProcessFunction.
>
> class MyProcessFunction extends ProcessFunction<ObjectNode, ObjectNode> {
>
>      @Override
>      public void open(Configuration parameters) throws Exception {
>           ...
>      }
>      …
> }
>
> How can I set parameters variable before execution of MyProcessFunction?
>
> ———————————————
>
> Timofeev Dmitry
> VoIP Engineer
> Open source telephony solutions
> Skype: itsroot
> Linkedin: https://www.linkedin.com/in/itsroot