Hi Kristoff, There are no plans of adding state support to the gap extractors but you could do this using a two-step approach, i.e. have an operation in front of the window that keeps track of session gaps, enriches the message with the gap that should be used and then the extractor extracts that gap. This is a more modular approach compared to putting everything in one operator/extractor.
Best, Aljoscha > On 3. Jan 2020, at 08:52, vino yang <yanghua1...@gmail.com> wrote: > > Hi KristoffSC, > > >> Are there any plans to add support of Flink State into > >> SessionWindowTimeGapExtractor? > > As I said, `SessionWindowTimeGapExtractor` is neither a general UDF nor an > operator. > > But I cannot give a clear answer. Let me ping @Aljoscha Krettek to give the > answer. > > Best, > Vino > > KristoffSC <krzysiek.chmielew...@gmail.com> 于2020年1月3日周五 上午6:17写道： > Ok, > I did some more tests and yep, it seems that there is no way to use Flink's > State in class that will implement SessionWindowTimeGapExtractor. > > Even if I will implement this interface on a class that is an operator, > whenever extract method is called it does not have any access to Flink's > state. Even calling getRuntimeContext() from it throws an exception. > > Are there any plans to add support of Flink State into > SessionWindowTimeGapExtractor? > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
