Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.ooc |
Package of out-of-core related classes.
|
org.apache.giraph.ooc.command |
Package of classes related to IO commands in out-of-core mechanism
|
org.apache.giraph.ooc.data |
Package of classes related to data structures used for an out-of-core
mechanism
|
org.apache.giraph.ooc.policy |
Package of classes related to out-of-core policy
|
Modifier and Type | Method and Description |
---|---|
OutOfCoreEngine |
ServerData.getOocEngine()
Return the out-of-core engine for this worker.
|
Constructor and Description |
---|
OutOfCoreIOCallable(OutOfCoreEngine oocEngine,
int diskId)
Constructor
|
OutOfCoreIOCallableFactory(OutOfCoreEngine oocEngine,
int numIOThreads,
Thread.UncaughtExceptionHandler uncaughtExceptionHandler)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected OutOfCoreEngine |
IOCommand.oocEngine
Out-of-core engine
|
Constructor and Description |
---|
IOCommand(OutOfCoreEngine oocEngine,
int partitionId)
Constructor
|
LoadPartitionIOCommand(OutOfCoreEngine oocEngine,
int partitionId,
long superstep)
Constructor
|
StoreDataBufferIOCommand(OutOfCoreEngine oocEngine,
int partitionId,
StoreDataBufferIOCommand.DataBufferType type)
Constructor
|
StoreIncomingMessageIOCommand(OutOfCoreEngine oocEngine,
int partitionId)
Constructor
|
StorePartitionIOCommand(OutOfCoreEngine oocEngine,
int partitionId)
Constructor
|
WaitIOCommand(OutOfCoreEngine oocEngine,
long waitDuration)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected OutOfCoreEngine |
DiskBackedDataStore.oocEngine
Out-of-core engine
|
Constructor and Description |
---|
DiskBackedEdgeStore(EdgeStore<I,V,E> edgeStore,
ImmutableClassesGiraphConfiguration<I,V,E> conf,
OutOfCoreEngine oocEngine)
Constructor
|
DiskBackedMessageStore(ImmutableClassesGiraphConfiguration<I,?,?> config,
OutOfCoreEngine oocEngine,
MessageStore<I,M> messageStore,
boolean useMessageCombiner,
long superstep)
Constructor
|
DiskBackedPartitionStore(PartitionStore<I,V,E> partitionStore,
ImmutableClassesGiraphConfiguration<I,V,E> conf,
org.apache.hadoop.mapreduce.Mapper.Context context,
OutOfCoreEngine oocEngine)
Constructor.
|
MetaPartitionManager(int numIOThreads,
OutOfCoreEngine oocEngine)
Constructor
|
Constructor and Description |
---|
FixedPartitionsOracle(ImmutableClassesGiraphConfiguration conf,
OutOfCoreEngine oocEngine)
Constructor
|
MemoryEstimatorOracle(ImmutableClassesGiraphConfiguration conf,
OutOfCoreEngine oocEngine)
Constructor.
|
SimpleGCMonitoringOracle(ImmutableClassesGiraphConfiguration conf,
OutOfCoreEngine oocEngine)
Constructor
|
ThresholdBasedOracle(ImmutableClassesGiraphConfiguration conf,
OutOfCoreEngine oocEngine)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.