gistfile1.java

private class Indexer {
   public void consumes(Iterator<Tuple> entityTuples) {
      while (Tuple tuple = entityTuples.next() != null) {
         Entry entry = convertToEntry(tuple);
         pushToExecutorQueue(entry);
      }
      
      
      //pushToExecutorQueue, execute method
      public execute() {
         DocumentBuilder db = sf.getDocumentBuilderForEntry( e );
         org.apache.luceneDocument transformation = db.buildDocument(db);
         //apply sharding logic:
         IndexManager targetIndex = sf.getIndexManager( ... )
         targetIndex.writeAsBatchWork( transformation );
      }
      
   }

private static class Indexer implements Consumer {

   private final SearchFactory sf;
   //ctors

   //invoked concurrently on some GridDialect implementations:
   public void consume(Entry e) {
       DocumentBuilder db = sf.getDocumentBuilderForEntry( e );
       org.apache.luceneDocument transformation = db.buildDocument(db);
       //apply sharding logic:
       IndexManager targetIndex = sf.getIndexManager( ... )
       targetIndex.writeAsBatchWork( transformation );
   }

}