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