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.messages.primitives |
Package of message stores specialized for a certain type of vertex ids,
messages and combiner.
|
org.apache.giraph.comm.messages.primitives.long_id |
Message store based off of primitives when I = LongWritable
|
org.apache.giraph.comm.messages.queue |
Package for message store queue, that decouples netty threads from
threads processing messages.
|
org.apache.giraph.comm.requests |
Package for requests.
|
org.apache.giraph.ooc.data |
Package of classes related to data structures used for an out-of-core
mechanism
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
Modifier and Type | Method and Description |
---|---|
VertexIdMessages<I,M> |
SendMessageCache.createVertexIdData() |
Modifier and Type | Method and Description |
---|---|
protected PairList<Integer,VertexIdMessages<I,M>> |
SendMessageCache.removeWorkerMessages(WorkerInfo workerInfo)
Gets the messages for a worker and removes it from the cache.
|
Modifier and Type | Method and Description |
---|---|
void |
PointerListPerVertexStore.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages) |
void |
OneMessagePerVertexStore.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages) |
void |
ByteArrayMessagesPerVertexStore.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages) |
void |
MessageStore.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages)
Adds messages for partition
|
Modifier and Type | Method and Description |
---|---|
void |
IdOneMessagePerVertexStore.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages) |
void |
IdByteArrayMessageStore.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages) |
void |
IntFloatMessageStore.addPartitionMessages(int partitionId,
VertexIdMessages<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable> messages) |
void |
LongDoubleMessageStore.addPartitionMessages(int partitionId,
VertexIdMessages<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable> messages) |
Modifier and Type | Method and Description |
---|---|
void |
LongPointerListPerVertexStore.addPartitionMessages(int partitionId,
VertexIdMessages<org.apache.hadoop.io.LongWritable,M> messages) |
Modifier and Type | Method and Description |
---|---|
VertexIdMessages<I,M> |
PartitionMessage.getMessage()
Message
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncMessageStoreWrapper.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages) |
Constructor and Description |
---|
PartitionMessage(int partitionId,
VertexIdMessages<I,M> message)
Constructs wrapper from partitino id and vertext message
object.
|
Modifier and Type | Method and Description |
---|---|
VertexIdMessages<I,M> |
SendWorkerMessagesRequest.createVertexIdData() |
Constructor and Description |
---|
SendWorkerMessagesRequest(PairList<Integer,VertexIdMessages<I,M>> partVertMsgs)
Constructor used to send request.
|
Modifier and Type | Method and Description |
---|---|
protected VertexIdMessages<I,M> |
DiskBackedMessageStore.readNextEntry(DataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
DiskBackedMessageStore.addEntryToInMemoryPartitionData(int partitionId,
VertexIdMessages<I,M> messages) |
void |
DiskBackedMessageStore.addPartitionMessages(int partitionId,
VertexIdMessages<I,M> messages) |
protected int |
DiskBackedMessageStore.entrySerializedSize(VertexIdMessages<I,M> messages) |
protected void |
DiskBackedMessageStore.writeEntry(VertexIdMessages<I,M> messages,
DataOutput out) |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayOneMessageToManyIds<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Stores a message and a list of target vertex ids.
|
class |
ByteArrayVertexIdMessages<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Stores vertex id and message pairs in a single byte array.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.