_consumer.endDataSet();
    public void produce() throws DataSetException {        File dir = new File(_theDirectory);        if (!dir.isDirectory()) {            throw new DataSetException("'" + _theDirectory + "' should be a directory");        }        // @todo: move in a class by itself, somewhere        FilenameFilter filter = new FilenameFilter() {            public boolean accept(File dir, String name) {                return name.endsWith(".csv") && !dir.isFile();            }        };        _consumer.startDataSet();        File[] children = dir.listFiles(filter);        for (int i = 0; i < children.length; i++) {            try {                produceFromFile(children[i]);            } catch (CsvParserException e) {                throw new DataSetException(e);            }        }        _consumer.endDataSet();    }