package com.cloudera.flume.agent.durability;
import java.io.File;
import java.io.IOException;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.cloudera.flume.core.Event;
import com.cloudera.flume.core.EventImpl;
import com.cloudera.flume.core.EventSink;
import com.cloudera.flume.handlers.hdfs.SeqfileEventSink;
import com.cloudera.util.BenchmarkHarness;
public static final Logger LOG = LoggerFactory
.getLogger(TestNaiveFileWALHandles.class);
@Test
BenchmarkHarness.setupLocalWriteDir();
File tmp = BenchmarkHarness.tmpdir;
for (int i = 0; i < 3000; i++) {
File path = new File(tmp, "" + i);
EventSink snk = new SeqfileEventSink(path);
snk.open();
Event e = new EventImpl(("foo " + i).getBytes());
snk.append(e);
snk.close();
}
}
}