どのように大規模なXMLファイルをストリームするようにオブジェクトのストリームのようなjava8

Question

Hy、 私はfooのリストで（非常に）大きなXMLファイル（100GB）を持っている、私はそれを紹介するようなストリームに変換したいオブジェクトのJava 8に：

libまたはコードサンプルのアイデア？最後に

<foos> 
    <foo>...</foo> 
    <foo>...</foo> 
</foos> 

：初めに

Stream<Foo> foosStream = ????("foo.xml") 
streamFoos.forEach(foo->foo.doFooStuffs()); 

編集： お礼を@Pierre、ここではあなたのソリューションの実装です：

try { 
      XMLEventReader reader = XMLInputFactory.newInstance(). 
        createXMLEventReader(stream); 
      final Unmarshaller unmarshaller = JAXBContext.newInstance(XXXXX.class).createUnmarshaller(); 

      Iterator<XXXXX> it = new XmlIterator<>(reader, unmarshaller, "xxxxxx"); 
      return StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, Spliterator.ORDERED), false); 
     } catch (XMLStreamException e1) { 
      logger.error("XMLStreamException", e1); 
     } catch (JAXBException e) { 
      logger.error("JAXBException", e); 
     } 

および

public class XmlIterator<T> implements Iterator<T> { 

    private final Logger logger = LoggerFactory.getLogger(this.getClass()); 

    XMLEventReader reader; 

    XMLEvent event; 

    Unmarshaller unmarshaller; 
    String name; 

    public XmlIterator(XMLEventReader reader, Unmarshaller unmarshaller, String name) { 
     this.reader = reader; 
     this.unmarshaller = unmarshaller; 
     this.name = name; 
     try { 
      reader.next(); 
      this.event = reader.peek(); 
     } catch (XMLStreamException e) { 
      logger.error("", e); 
      event = null; 
     } 
    } 

    @Override 
    public boolean hasNext() { 
     try { 
      while (event != null && !(event.isStartElement() && name.equals(event.asStartElement().getName().getLocalPart()))) { 
       Object a = reader.next(); 
       event = reader.peek(); 
      } 
      return event != null; 

     } catch (XMLStreamException e) { 
      logger.error("", e); 
      event = null; 
     } 
     return event != null; 
    } 

    @Override 
    public T next() { 
     try { 
      T next = ((JAXBElement<T>) unmarshaller.unmarshal(reader)).getValue(); 
      event = reader.peek(); 
      return next; 
     } catch (JAXBException e) { 
      logger.error("error during unmarshalling ", e); 
      return null; 
     } catch (XMLStreamException e) { 
      logger.error("error during stream ", e); 
      return null; 
     } 
    } 
} 

Answer 1

• あなたのオブジェクト解析するスタックスリーダーを使用し、（https://docs.oracle.com/javase/7/docs/api/javax/xml/stream/XMLEventReader.html#peek()を使用して）

• あなたがタグ「foo」を見るたびに、あなたのxmlファイル読み込みスタックスイベントリーダーhttps://docs.oracle.com/javase/tutorial/jaxp/stax/example.htmlを作成し、構築Foo

  Foo readFoo(XMLEventReader xmlIn) throws XMLStreamException { 
      (...) 
      return foo; 
  } 
  

• フー

• はSTRに、このイテレータを変換する「）（次の」戻るには前の関数を使用しますするjava.util.Iteratorを実装eam How to create a Java 8 Stream from an iterator?