Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.ooc.data |
Package of classes related to data structures used for an out-of-core
mechanism
|
org.apache.giraph.partition |
Package of partitioning related objects.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
PartitionStore<I,V,E> |
CentralizedServiceWorker.getPartitionStore()
Get the partition store for this worker.
|
Modifier and Type | Method and Description |
---|---|
PartitionStore<I,V,E> |
ServerData.getPartitionStore()
Return the partition store for this worker.
|
Modifier and Type | Class and Description |
---|---|
class |
DiskBackedPartitionStore<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Implementation of a partition-store used for out-of-core mechanism.
|
Constructor and Description |
---|
DiskBackedPartitionStore(PartitionStore<I,V,E> partitionStore,
ImmutableClassesGiraphConfiguration<I,V,E> conf,
org.apache.hadoop.mapreduce.Mapper.Context context,
OutOfCoreEngine oocEngine)
Constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
SimplePartitionStore<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
A simple in-memory partition store.
|
Modifier and Type | Method and Description |
---|---|
Collection<PartitionStats> |
WorkerGraphPartitionerImpl.finalizePartitionStats(Collection<PartitionStats> workerPartitionStats,
PartitionStore<I,V,E> partitionStore) |
Collection<PartitionStats> |
WorkerGraphPartitioner.finalizePartitionStats(Collection<PartitionStats> workerPartitionStats,
PartitionStore<I,V,E> partitionStore)
At the end of a superstep, workers have
PartitionStats generated
for each of their partitions. |
Modifier and Type | Method and Description |
---|---|
PartitionStore<I,V,E> |
BspServiceWorker.getPartitionStore() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.