I'm not aware of any plans to replace it.
For the Batch API it also works properly, so deprecating it would be
misleading.
On 13.06.2017 16:04, Mikhail Pryakhin wrote:
Hi Chesnay,
Thanks for the reply,
The existing signature for open() is a remnant of the past.
Should the method be deprecated then so that it doesn’t confuse users?
Kind Regards,
Mike Pryakhin
On 13 Jun 2017, at 16:54, Chesnay Schepler <ches...@apache.org
<mailto:ches...@apache.org>> wrote:
The existing signature for open() is a remnant of the past.
We currently recommend to pass all arguments through the constructor
and store them in fields.
You can of course also pass a Configuration containing all parameters.
On 13.06.2017 15:46, Mikhail Pryakhin wrote:
Hi all!
A RichMapFunction [1] provides a very handy setup method
RichFunction#open(org.apache.flink.configuration.Configuration)
which consumes a Configuration instance as an argument, but this
argument doesn't bear any configuration parameters because it is
always passed to the method as a new instance. [2] depicts the problem.
Is there any way to pass configuration parameters to the
RichFunction#open method via the Configuration parameter? Or is it
a bug?
P.S. I'm using flink 1.3
Thanks in advance!
[1]
https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/functions/RichMapFunction.java
[2]
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java#L111
Kind Regards,
Mike Pryakhin