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 for ease of discussion). Shouldn't Context be Context<IN> not Context<T> ? based on the docs? I'm having a hard time understanding what's getting sent to me here in Context. Anyone have any insights on why these might be different ?
/** * Interface for implementing user defined sink functionality. * * @param <IN> Input type parameter. */ @Public public interface SinkFunction<IN> extends Function, Serializable { /** * Context that {@link SinkFunction SinkFunctions } can use for getting additional data about * an input record. * * <p>The context is only valid for the duration of a * {@link SinkFunction#invoke(Object, Context)} call. Do not store the context and use * afterwards! * * @param <T> The type of elements accepted by the sink. */ @Public // Interface might be extended in the future with additional methods. interface Context<T> { org.apache.flink/flink-streaming-java_2.11/1.5.0/784a58515da2194a2e74666e8d53d50fac8c03/flink-streaming-java_2.11-1.5.0-sources.jar!/org/apache/flink/streaming/api/functions/sink/SinkFunction.java