package com.cloudera.flume.handlers.debug;
import java.io.IOException;
import org.junit.Assert;
import org.junit.Test;
import com.cloudera.flume.ExampleData;
import com.cloudera.flume.core.Event;
import com.cloudera.flume.core.EventSource;
@Test
EventSource src = new TextFileSource(TEST);
src.open();
int count = 0;
while (true) {
Event e = src.next();
if (e == null)
break;
count++;
System.out.println(e);
}
System.out.println("read " + count + " lines");
Assert.assertEquals(56, count);
src.close();
}
}