当前位置：源码 > Java源码 >

Java源码示例：org.apache.flink.examples.scala.wordcount.WordCount

示例1

@Override
protected void testProgram() throws Exception {
	WordCount.main(new String[] {
			"--input", textPath,
			"--output", resultPath });
}

示例2

@Override
protected void testProgram() throws Exception {
	WordCount.main(new String[] {
			"--input", textPath,
			"--output", resultPath });
}

示例3

@Override
protected void testProgram() throws Exception {
	WordCount.main(new String[] {
			"--input", textPath,
			"--output", resultPath });
}