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