DAG dag = DAG.create("testBasicSuccessBroadcast");
Vertex v1 =
Vertex.create("v1", TestProcessor.getProcDesc(null), 2, SimpleTestDAG.defaultResource);
Vertex v2 =
Vertex.create("v2", TestProcessor.getProcDesc(null), 2, SimpleTestDAG.defaultResource);
dag.addVertex(v1).addVertex(v2).addEdge(Edge.create(v1, v2,
EdgeProperty.create(DataMovementType.BROADCAST,
DataSourceType.PERSISTED,
SchedulingType.SEQUENTIAL,
TestOutput.getOutputDesc(null),
TestInput.getInputDesc(null))));