class InvalidDocumentFilter extends AbstractFilter<ArrayNode, ArrayNode> {

	@Override
	protected ArrayNode doFilter(ArrayNode data) {
		Iterator<JsonNode> iterator = data.elements();
		while (iterator.hasNext()) {
			if (!iterator.next().isObject()) iterator.remove();
		}
		return data;
	}

	@Inject  InvalidDocumentFilter(@Assisted DataSource source, MetricRegistry registry);

}