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

2018-03-29 Thread Timo Walther
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

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

2018-03-29 Thread 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 stream2 = stream1.process(new MyProcessFunction()).name("Ingest data»); … I have created package-private class with