package com.cloudera.flume.faults;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
public class DiskHog extends ResourceHog {
File path;
public DiskHog(File path,
int delay,
boolean random) {
super(delay, random);
this.path = path;
}
@Override
try {
File tmp = File.createTempFile("junk", ".tmp", path);
tmp.deleteOnExit();
FileOutputStream out = new FileOutputStream(tmp);
byte[] data = new byte[50 * 1024 * 1024];
out.write(data);
out.write(data);
out.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}