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

Posted by Main Frame 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-tp19245.html

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