override protected def getElement()

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)
  }