}
@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();
Tuple tuple = outputToTuple(key, value, output, exec.isTimedOut());
tupleCreationOverhead.stop();
return tuple;
}