Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.comm.messages |
Package of classes for storing messages.
|
org.apache.giraph.comm.netty |
Package for netty implementations.
|
org.apache.giraph.comm.requests |
Package for requests.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
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 |
---|---|
void |
ServerData.resolvePartitionMutation(Partition<I,V,E> partition)
Resolve mutations specific for a partition.
|
void |
WorkerClientRequestProcessor.sendPartitionRequest(WorkerInfo workerInfo,
Partition<I,V,E> partition)
Send a partition request (no batching).
|
Modifier and Type | Method and Description |
---|---|
Partition |
PartitionSplitInfo.getNextPartition()
|
Modifier and Type | Method and Description |
---|---|
void |
PartitionSplitInfo.putPartition(Partition partition)
|
Modifier and Type | Method and Description |
---|---|
void |
NettyWorkerClientRequestProcessor.sendPartitionRequest(WorkerInfo workerInfo,
Partition<I,V,E> partition) |
Constructor and Description |
---|
SendVertexRequest(Partition<I,V,E> partition)
Constructor for sending a request.
|
Modifier and Type | Field and Description |
---|---|
static ClassConfOption<Partition> |
GiraphConstants.PARTITION_CLASS
Partition class - optional
|
protected Class<? extends Partition<I,V,E>> |
GiraphClasses.partitionClass
Partition class - cached for fast accesss
|
Modifier and Type | Method and Description |
---|---|
Partition<I,V,E> |
ImmutableClassesGiraphConfiguration.createPartition(int id,
org.apache.hadoop.util.Progressable progressable)
Create a partition
|
Modifier and Type | Method and Description |
---|---|
Class<? extends Partition<I,V,E>> |
GiraphClasses.getPartitionClass()
Get Partition
|
Class<? extends Partition> |
GiraphConfiguration.getPartitionClass()
Get Partition class used
|
Modifier and Type | Method and Description |
---|---|
GiraphClasses |
GiraphClasses.setPartitionClass(Class<? extends Partition<I,V,E>> partitionClass)
Set Partition class to use
|
void |
GiraphConfiguration.setPartitionClass(Class<? extends Partition> partitionClass)
Set the partition class (optional)
|
Modifier and Type | Method and Description |
---|---|
Partition<I,V,E> |
DiskBackedPartitionStore.getNextPartition() |
Partition<I,V,E> |
DiskBackedPartitionStore.removePartition(Integer partitionId) |
Modifier and Type | Method and Description |
---|---|
boolean |
DiskBackedPartitionStore.addPartition(Partition<I,V,E> partition) |
void |
DiskBackedPartitionStore.putPartition(Partition<I,V,E> partition) |
Modifier and Type | Interface and Description |
---|---|
interface |
ReusesObjectsPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Empty interface to characterize
Partition implementations that
don't keep references to the Vertex objects they are passed. |
Modifier and Type | Class and Description |
---|---|
class |
BasicPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Basic partition class for other partitions to extend.
|
class |
ByteArrayPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Byte array based partition.
|
class |
SimplePartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
A simple map-based container that stores vertices.
|
Modifier and Type | Method and Description |
---|---|
Partition<I,V,E> |
SimplePartitionStore.getNextPartition() |
Partition<I,V,E> |
PartitionStore.getNextPartition()
Return the next partition in iteration for the current superstep.
|
Partition<I,V,E> |
SimplePartitionStore.removePartition(Integer partitionId) |
Partition<I,V,E> |
PartitionStore.removePartition(Integer partitionId)
Remove a partition and return it.
|
Modifier and Type | Method and Description |
---|---|
void |
ByteArrayPartition.addPartition(Partition<I,V,E> partition) |
void |
SimplePartition.addPartition(Partition<I,V,E> partition) |
boolean |
SimplePartitionStore.addPartition(Partition<I,V,E> partition) |
void |
Partition.addPartition(Partition<I,V,E> partition)
Add a partition's vertices.
|
boolean |
PartitionStore.addPartition(Partition<I,V,E> partition)
Add a *new* partition to the store.
|
void |
SimplePartitionStore.putPartition(Partition<I,V,E> partition) |
void |
PartitionStore.putPartition(Partition<I,V,E> partition)
Put a partition back to the store.
|
Modifier and Type | Method and Description |
---|---|
Partition |
BspServiceWorker.getNextPartition() |
Modifier and Type | Method and Description |
---|---|
void |
BspServiceWorker.putPartition(Partition partition) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.