我有一个从RichSinkFunction扩展的接收器，它正在缓存一些信息。当我的进程完成时，我希望更新所有缓存的信息，以便强制调用它。
我可以从一个KeyedProcessAccumulatorFunction调用该接收器，用类型为ReadOnlyContext的上下文调用它，它就可以工作了。

public class PageAccumulateFunction implements KeyedProcessAccumulatorFunction{
    public SessionAccumulator accumulate(
            @NonNull Tuple2<CollectionMessage, PropertyInfo> value,
            @NonNull SessionAccumulator accumulator,
            @NonNull KeyedBroadcastProcessFunction.ReadOnlyContext ctx) {
        ....
        ctx.output(outputTag, message);
    }
}

但是在我的RichMapFunction类中，我不能调用那个接收器。我可以得到一个RuntimeContext对象（但不是ReadOnlyContext），但是我不知道我是否可以用它来调用RichSinkFunction接收器。

public class SessionMapper extends RichMapFunction<SessionAccumulator, GenericRecord>{
    public GenericRecord map(SessionAccumulator sessionAccumulator) {
        ....
        RuntimeContext ctx = getRuntimeContext();
        ....
    }
}

你知道吗？