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/
