@Test
public void testCSVReaderDataPoolPut() throws IOException {		

	File tempFile = FileHelper.extractResourceToTempFile(this.getClass(), "testCSVReaderDataPoolPut.csv");
	
	DataSet<?> pool = getDataPool(tempFile, true);
	
	ExecutorService threadPool = Executors.newCachedThreadPool();
	for(int i=0;i<5;i++) {
		threadPool.submit(() -> {
			DataPoolRow row = null;
			while((row=pool.next())!=null) {
				try {
					((SimpleStringMap)row.getValue()).put("Col4", "test");			
				} finally {
					if(row != null) {
						row.commit();
					}
				}
			}
		});
	}
	pool.close();
	
	PlanRunnerResultAssert.assertEquals(getClass(), "testCSVReaderDataPoolPut.expected.csv", tempFile);
}