Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
Modifier and Type | Class and Description |
---|---|
class |
SendEdgeCache<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Aggregates the edges to be sent to workers so they can be sent
in bulk.
|
class |
SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Aggregates the messages to be sent to workers so they can be sent
in bulk.
|
class |
SendOneMessageToManyCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Aggregates the messages to be sent to workers so they can be sent
in bulk.
|
class |
SendPartitionCache<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Caches partition vertices prior to sending.
|
class |
SendVertexIdDataCache<I extends org.apache.hadoop.io.WritableComparable,T,B extends VertexIdData<I,T>>
An abstract structure for caching data indexed by vertex id,
to be sent to workers in bulk.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.