org.apache.giraph.ooc

Class OutOfCoreIOCallableFactory

java.lang.Object

org.apache.giraph.ooc.OutOfCoreIOCallableFactory

public class OutOfCoreIOCallableFactory
extends Object

Factory class to create IO threads for out-of-core engine.

Constructor Summary

Constructors

Constructor and Description
OutOfCoreIOCallableFactory(OutOfCoreEngine oocEngine, int numIOThreads, Thread.UncaughtExceptionHandler uncaughtExceptionHandler) Constructor

Method Summary

Modifier and Type	Method and Description
void	createCallable() Creates/Launches IO threads
void	shutdown() Check whether all IO threads terminated gracefully.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OutOfCoreIOCallableFactory

public OutOfCoreIOCallableFactory(OutOfCoreEngine oocEngine,
                                  int numIOThreads,
                                  Thread.UncaughtExceptionHandler uncaughtExceptionHandler)

Constructor

Parameters:

oocEngine - Out-of-core engine

numIOThreads - Number of IO threads used

uncaughtExceptionHandler - Thread UncaughtExceptionHandler to use

Method Detail

createCallable

public void createCallable()

Creates/Launches IO threads

shutdown

public void shutdown()

Check whether all IO threads terminated gracefully.