如何在Java中使用Flinks Splitter方法

Question

flink文档有一个在scala中使用Splitter方法的示例，如下所示：

// Create an Array of K TrainTestDataSets
val dataKFolded: Array[TrainTestDataSet] =  Splitter.kFoldSplit(data, 10)

然而，在Java中，我不得不传递TypeInformation和ClassTag的进一步参数。我认为对于TypeInformation，TypeInformation.of(TypeofDataset.class)是有效的输入。但我找不出第二个参数使用什么。

Answer 1

给定这个Scala签名

def kFoldSplit[T: TypeInformation : ClassTag](
      input: DataSet[T],
      kFolds: Int,
      seed: Long = Utils.RNG.nextLong()
) : Array[TrainTestDataSet[T]]

Java调用将是

Splitter.kFoldSplit(
    data,
    10,
    99,
    TypeInformation.of(TypeofDataset.class),
    ClassTag$.MODULE$.apply(TypeofDataset.class)
)

ClassTag$来自

scala.reflect.ClassTag$

很可怕，但很有必要。