class XmlExtractor implements Extractor {

	@Override
	public RowReader getReader(Map<String, ?> parameters) {
		try {
			InputSource inputSource = new InputSource(connector.getInputStream(parameters));
			NodeList nodes = (NodeList) expression.evaluate(inputSource, XPathConstants.NODESET);
			return new XmlRowReader(rowHeader, nodes);
		} catch (IOException | XPathExpressionException e) {
			throw new LmRuntimeException(e);
		}
	}

	public  XmlExtractor(StreamConnector connector, XmlRowAttribute[] rowHeader, XPathExpression expression);

}