@Test
public void testDirectRead() {

	Set<String> inputSet = new HashSet<>(Arrays.asList(inputArray));
	List<Row> collected = DirectReader.directRead(input);
	Assert.assertEquals(inputSet.size(), collected.size());
	for (Row r : collected) {
		Assert.assertTrue(inputSet.contains(r.getField(0)));
	}
}