Re: SinkFunction invoke method signature

2018-07-14 Thread Philip Doctor
c: user@flink.apache.org Subject: Re: SinkFunction invoke method signature The variables T and IN aren't related to each other. That is, whether the context interface is defined as Context or Context makes no difference, since it is an interface which are always static. At runtime, the context giv

Re: SinkFunction invoke method signature

2018-07-14 Thread Chesnay Schepler
The variables T and IN aren't related to each other. That is, whether the context interface is defined as Context or Context makes no difference, since it is an interface which are always static. At runtime, the context given to the function should be of type Context, but I don't know why the

Re: SinkFunction invoke method signature

2018-07-13 Thread Ashwin Sinha
+1 We encountered the exact same issue today. On Fri, Jul 13, 2018 at 10:51 PM Philip Doctor wrote: > Dear Flink Users, > I noticed my sink's `invoke` method was deprecated, so I went to update > it, I'm a little surprised by the new method signature, especially on > Context (copy+pasted below