Edge edge = new Edge(stage1Vertex, stage2Vertex, new EdgeProperty(
DataMovementType.ONE_TO_ONE, DataSourceType.PERSISTED,
SchedulingType.SEQUENTIAL, new OutputDescriptor(
OnFileUnorderedKVOutput.class.getName()), new InputDescriptor(
ShuffledUnorderedKVInput.class.getName())));
dag.addVertex(stage1Vertex).addVertex(stage2Vertex).addEdge(edge);
LOG.info("Submitting DAG to Tez Session");
DAGClient dagClient = tezSession.submitDAG(dag);
LOG.info("Submitted DAG to Tez Session");