Package com.ikanow.infinit.e.processing.generic.aggregation

Examples of com.ikanow.infinit.e.processing.generic.aggregation.AggregationManager.doAggregation()

757
758
759
760
761
762
763
764
765
766
767
      perSourceAggregation = new AggregationManager();
    }
   
    // 1+2]
    if (null != perSourceAggregation) {
      perSourceAggregation.doAggregation(toAdd, toDelete);
      perSourceAggregation.createOrUpdateFeatureEntries();
    }
   
    // Save feeds to feeds collection in MongoDb
    // (second field determines if content gets saved)
View Full Code Here
405
406
407
408
409
410
411
412
413
414
415
  //___________________________________________________________________________________________________
 
  private void doAggregation(Map<ObjectId, LinkedList<DocumentPojo>> communityList, LinkedList<DocumentPojo> singleList) {
    if (null == communityList) { // just one community this one is easy
      AggregationManager aggManager = new AggregationManager();
      aggManager.doAggregation(singleList, new LinkedList<DocumentPojo>());     
      aggManager.createOrUpdateFeatureEntries();        
      aggManager.applyAggregationToDocs(singleList);
      aggManager.runScheduledDocumentUpdates();
      aggManager.runScheduledSynchronization();
    }
View Full Code Here
414
415
416
417
418
419
420
421
422
423
424
      aggManager.runScheduledSynchronization();
    }
    else {         
      for (Map.Entry<ObjectId, LinkedList<DocumentPojo>> entry: communityList.entrySet()) {
        AggregationManager aggManager = new AggregationManager();
        aggManager.doAggregation(entry.getValue(), new LinkedList<DocumentPojo>());
        aggManager.createOrUpdateFeatureEntries();
        aggManager.applyAggregationToDocs(entry.getValue());
        aggManager.runScheduledDocumentUpdates();
        aggManager.runScheduledSynchronization();
      }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.