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
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