in src/main/scala/org/apache/flink/benchmark/functions/ScalaADTSource.scala [24:27]
override protected def getElement(keyId: Int): ADT = keyId match { case 0 => ADT1("a") case 1 => ADT2(1) }