@Test
public void testSetReadFrom() throws IOException {

    when(connectorMock.getInputStream(anyMap()))
            .thenReturn(new ByteArrayInputStream("k1,k2,k3\nr1c1,r1c2,r1c3\nr2c1,r2c2,r2c3".getBytes()));
    model.addProperty(CsvExtractorFactory.READ_FROM_PROPERTY, "2");
    RowReader reader = extractorFactory.createExtractor(connectorMock, model).getReader(Collections.emptyMap());
    doCheck(reader);
}