源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.flink.graph.generator.TestUtils

示例1
@Test
public void testParallelism() throws Exception {
	int parallelism = 2;

	Graph<IntValue, NullValue, NullValue> simpleGraph = graph
		.run(new Simplify<>());

	simpleGraph.getVertices().output(new DiscardingOutputFormat<>());
	simpleGraph.getEdges().output(new DiscardingOutputFormat<>());

	TestUtils.verifyParallelism(env, parallelism);
}
示例2
@Test
public void testParallelism() throws Exception {
	int parallelism = 2;

	Graph<IntValue, NullValue, NullValue> simpleGraph = graph
		.run(new Simplify<>(true));

	simpleGraph.getVertices().output(new DiscardingOutputFormat<>());
	simpleGraph.getEdges().output(new DiscardingOutputFormat<>());

	TestUtils.verifyParallelism(env, parallelism);
}
示例3
@Test
public void testParallelism() throws Exception {
	int parallelism = 2;

	Graph<IntValue, NullValue, NullValue> simpleGraph = graph
		.run(new Simplify<>());

	simpleGraph.getVertices().output(new DiscardingOutputFormat<>());
	simpleGraph.getEdges().output(new DiscardingOutputFormat<>());

	TestUtils.verifyParallelism(env, parallelism);
}
示例4
@Test
public void testParallelism() throws Exception {
	int parallelism = 2;

	Graph<IntValue, NullValue, NullValue> simpleGraph = graph
		.run(new Simplify<>(true));

	simpleGraph.getVertices().output(new DiscardingOutputFormat<>());
	simpleGraph.getEdges().output(new DiscardingOutputFormat<>());

	TestUtils.verifyParallelism(env, parallelism);
}
示例5
@Test
public void testParallelism() throws Exception {
	int parallelism = 2;

	Graph<IntValue, NullValue, NullValue> simpleGraph = graph
		.run(new Simplify<>());

	simpleGraph.getVertices().output(new DiscardingOutputFormat<>());
	simpleGraph.getEdges().output(new DiscardingOutputFormat<>());

	TestUtils.verifyParallelism(env, parallelism);
}
示例6
@Test
public void testParallelism() throws Exception {
	int parallelism = 2;

	Graph<IntValue, NullValue, NullValue> simpleGraph = graph
		.run(new Simplify<>(true));

	simpleGraph.getVertices().output(new DiscardingOutputFormat<>());
	simpleGraph.getEdges().output(new DiscardingOutputFormat<>());

	TestUtils.verifyParallelism(env, parallelism);
}