flink文档中有一个在scala中使用拆分器方法的示例,如下所示:
// Create an Array of K TrainTestDataSets
val dataKFolded: Array[TrainTestDataSet] = Splitter.kFoldSplit(data, 10)
然而,在java中,我不得不传递到 TypeInformation
以及 ClassTag
. 我想是为了 TypeInformation
这个 TypeInformation.of(TypeofDataset.class)
是有效输入。但我不知道第二个参数用什么。
1条答案
按热度按时间uqzxnwby1#
给这个scala签名
java调用将是
scala.reflect.ClassTag$