How can I use the Flink State Processor API to process the state of a windowed CoGroup (or Join) functio