package com.example.salesapp;

import org.apache.hadoop.conf.Configuration;

import com.datatorrent.api.annotation.ApplicationAnnotation;
import com.datatorrent.api.StreamingApplication;
import com.datatorrent.api.DAG;

import org.apache.apex.malhar.lib.fs.LineByLineFileInputOperator;

@ApplicationAnnotation(name = "file2file")
public class Application implements StreamingApplication {
	
	@Override
	public void populateDAG(DAG dag, Configuration conf) {
		LineByLineFileInputOperator fileIn = dag.addOperator("fileIn",
				LineByLineFileInputOperator.class);
		
		LineOutputOperator fileOut = dag.addOperator("fileOut",	LineOutputOperator.class);
		
		dag.addStream("data", fileIn.output, fileOut.input);
	}
}