Examples of AccumulatorManager

eu.stratosphere.nephele.jobmanager.accumulators.AccumulatorManager
This class manages the accumulators for different jobs. Either the jobs are running and new accumulator results have to be merged in, or the jobs are no longer running and the results shall be still available for the client or the web interface. Accumulators for older jobs are automatically removed when new arrive, based on a maximum number of entries. All functions are thread-safe and thus can be called directly from JobManager.
org.apache.flink.runtime.jobmanager.accumulators.AccumulatorManager
This class manages the accumulators for different jobs. Either the jobs are running and new accumulator results have to be merged in, or the jobs are no longer running and the results shall be still available for the client or the web interface. Accumulators for older jobs are automatically removed when new arrive, based on a maximum number of entries. All functions are thread-safe and thus can be called directly from JobManager.

Examples of eu.stratosphere.nephele.jobmanager.accumulators.AccumulatorManager

    
    // Create the accumulator manager, with same archiving limit as web
    // interface. We need to store the accumulators for at least one job.
    // Otherwise they might be deleted before the client requested the
    // accumulator results.
    this.accumulatorManager = new AccumulatorManager(Math.min(1, archived_items));


    // Load the input split manager
    this.inputSplitManager = new InputSplitManager();


    // Determine own RPC address

View Full Code Here

Examples of org.apache.flink.runtime.jobmanager.accumulators.AccumulatorManager

    
    // Create the accumulator manager, with same archiving limit as web
    // interface. We need to store the accumulators for at least one job.
    // Otherwise they might be deleted before the client requested the
    // accumulator results.
    this.accumulatorManager = new AccumulatorManager(Math.min(1, archived_items));




    // Determine own RPC address
    final InetSocketAddress rpcServerAddress = new InetSocketAddress(ipcAddress, ipcPort);

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.