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
