private static void filterReducer(String realJvmCostDir, String reducerJvmCost, String filteredReducer, String dataflowName) {
		File input = new File(realJvmCostDir + reducerJvmCost);
		File output = new File(realJvmCostDir + filteredReducer);
		
		if(!output.exists())
			output.getParentFile().mkdirs();
		
		try {
			BufferedReader dfReader = new BufferedReader(new FileReader(new File(dataflowName)));
			String dfTitles = dfReader.readLine();
			String[] dfTitle = dfTitles.split("\t");
			
			
			BufferedReader jvmReader = new BufferedReader(new FileReader(input));
			PrintWriter writer = new PrintWriter(new BufferedWriter(new FileWriter(output)));
			
			String titles = jvmReader.readLine();
			String[] title = titles.split("\t");
			writer.println("XMS" + "\t" + titles + "\t" + dfTitles);
			
			String line;
			while((line = jvmReader.readLine()) != null) {
				String dfLine = dfReader.readLine();
				String[] dfValue = dfLine.split("\t");
				SplitReducerDataflow dataflow = new SplitReducerDataflow(dfTitle, dfValue);
				
				
				String[] jvmValue = line.split("\t");
				SplitReducerRealJvmCost jvmCost = new SplitReducerRealJvmCost(title, jvmValue);
				int xms = 0;
				if(jvmCost.getXms() == jvmCost.getXmx())
					xms = 1;
				
				if(!dataflow.getJobId().equals(jvmCost.getJobId()))
					System.err.println(dataflow.getJobId() + "\t" + jvmCost.getJobId());
				writer.println(xms + "\t" + line + "\t" + dfLine);
				
			}
			
			dfReader.close();
			jvmReader.close();
			writer.close();
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}