@Override
public Tuple processFile(Text key, BytesWritable value, File binaryFile) throws IOException{
ProgramExector exec = new ProgramExector(getCommand(binaryFile), timeoutMS);
exec.start();
waitOnProgramExecutor(exec);
String output = StreamUtils.drainInputStream(exec.getStdout());
exec.closeStreams();
tupleCreationOverhead.start();