List of runBatch() Examples

Examples of runBatch()

com.google.enterprise.connector.traversal.QueryTraverser.runBatch()
com.google.enterprise.connector.traversal.Traverser.runBatch()
Runs a batch of documents. The Traversal method may be hard (impossible?) to interrupt while it is executing runBatch(). It is expected that a thread loop running a traversal method would call runBatch(), then check for InterruptedException, then decide whether it wants to stop of itself, for scheduling reasons, or for a clean shutdown. It could then re-adjust the batch hint if desired, then repeat. @param batchSize A {@link BatchSize} instructs the traversal method toprocess approximately {@code batchSize.getHint()}, but no more than {@code batchSize.getMaximum()} number of documents in thisbatch. @return A {@link BatchResult} containing the actual number of documentsfrom this batch given to the feed and a possible policy to delay before requesting another batch.
com.stella.framework.scheduler.RunScheduler.runBatch()
com.stella.framework.scheduler.RunSchedulerImpl.runBatch()
org.apache.jetspeed.ajax.AjaxAction.runBatch()
Same as run method, but runs in batch mode, as a hint to the action that it is running a multiple action and can delay its update runBatch currently supports pageManager.updatePage @param requestContext The Jetspeed Request Context @param resultMap map of action parameters passed to the builder context @return success is true, failure is false @throws Exception

Examples of com.google.enterprise.connector.traversal.QueryTraverser.runBatch()

        int docsProcessed = 0;
        int totalDocsProcessed = 0;
        int batchNumber = 0;
        BatchSize batchSize = new BatchSize(batchHint);
        do {
            BatchResult result = traverser.runBatch(batchSize);
            docsProcessed = result.getCountProcessed();
            if (docsProcessed > 0) {
                totalDocsProcessed += docsProcessed;
            }
            System.out.println("Batch# " + batchNumber + " docs " +

View Full Code Here

Examples of com.google.enterprise.connector.traversal.QueryTraverser.runBatch()

        5, new SystemClock()));
    final Traverser traverser = new QueryTraverser(new MockPusher(System.out),
        traversalManager, instantiator.getTraversalStateStore(connectorName),
        connectorName, Context.getInstance().getTraversalContext(),
        new SystemClock());
    BatchResult result = traverser.runBatch(new BatchSize(10));
    int totalDocsProcessed = result.getCountProcessed();
    assertTrue(totalDocsProcessed > 0);
  }
}

View Full Code Here

Examples of com.google.enterprise.connector.traversal.Traverser.runBatch()

        int docsProcessed = 0;
        int totalDocsProcessed = 0;
        int batchNumber = 0;
        BatchSize batchSize = new BatchSize(batchHint);
        do {
            BatchResult result = traverser.runBatch(batchSize);
            docsProcessed = result.getCountProcessed();
            if (docsProcessed > 0) {
                totalDocsProcessed += docsProcessed;
            }
            System.out.println("Batch# " + batchNumber + " docs " +

View Full Code Here

Examples of com.google.enterprise.connector.traversal.Traverser.runBatch()

        5, new SystemClock()));
    final Traverser traverser = new QueryTraverser(new MockPusher(System.out),
        traversalManager, instantiator.getTraversalStateStore(connectorName),
        connectorName, Context.getInstance().getTraversalContext(),
        new SystemClock());
    BatchResult result = traverser.runBatch(new BatchSize(10));
    int totalDocsProcessed = result.getCountProcessed();
    assertTrue(totalDocsProcessed > 0);
  }
}

View Full Code Here

Examples of com.stella.framework.scheduler.RunScheduler.runBatch()

    jobImpls[7].addDependantJob(jobImpls[8]);
    
    jobImpls[8].addDependantJob(jobImpls[9]);
    
    logger.info("kicking off batch");
    runScheduler.runBatch(3);
    logger.info("completed");
  }
}

View Full Code Here

Examples of com.stella.framework.scheduler.RunSchedulerImpl.runBatch()

    jobImpls[7].addDependantJob(jobImpls[8]);
    
    jobImpls[8].addDependantJob(jobImpls[9]);
    
    logger.info("kicking off batch");
    runScheduler.runBatch(3);
    logger.info("completed");
  }
}

View Full Code Here

Examples of org.apache.jetspeed.ajax.AjaxAction.runBatch()

            Map a_oResultMap = new HashMap();
            boolean a_bSuccess;


            try
            {
                a_bSuccess = a_oAction.runBatch(a_oJetspeedRequestContext,
                        a_oResultMap);
            } catch (Exception e)
            {
                // Move the reason into the return map
                p_oResultMap.put(REASON, a_oResultMap.get(REASON));

View Full Code Here

Examples of org.apache.jetspeed.ajax.AjaxAction.runBatch()

            Map a_oResultMap = new HashMap();
            boolean a_bSuccess;


            try
            {
                a_bSuccess = a_oAction.runBatch(a_oJetspeedRequestContext,
                        a_oResultMap);
            } catch (Exception e)
            {
                // Move the reason into the return map
                p_oResultMap.put(REASON, a_oResultMap.get(REASON));

View Full Code Here

TOP

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.