assigning stream element to multiple windows of different types

[Vlad Podgurschi]

Hello,

Is it possible to assign one record of a stream to multiple windows of
different types, like so:


class MultiAssigner extends WindowAssigner[Record, ReportWindow] {

  override def assignWindows(i: Record, timestamp: Long) =
    asJavaCollection(
      List(
        W1(i.d1, i.d2, i.d3),
        W2(i.d1, i.d2, i.d4),
        W3(i.d1, i.d2, i.d5, i.d6)
      )
    )

  override def getWindowSerializer(executionConfig: ExecutionConfig) = {
    W1Serializer    //    <-----  how to specify multiple serializers???
  }
}


Here ReportWindow is the base class of W1, W2 and W3.

Thanks,
Vlad