Modifier and Type | Method and Description |
---|---|
void |
GiraphMessenger.sendMessage(MessageScope messageScope,
M message) |
Modifier and Type | Class and Description |
---|---|
static class |
MessageScope.Global
A Global message is directed at an arbitrary vertex in the graph.
|
static class |
MessageScope.Local<M>
A Local message is directed to an adjacent (or "memory adjacent") vertex.
|
Modifier and Type | Method and Description |
---|---|
Set<MessageScope> |
VertexProgram.getMessageScopes(Memory memory)
This method returns all the
MessageScope possibilities for a particular iteration of the vertex program. |
Set<MessageScope> |
GraphComputerTest.VertexProgramB.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramC.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramD.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramE.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramA.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramF.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramG.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramH.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramI.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramJ.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramK.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramL.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.MultiScopeVertexProgram.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.MultiScopeVertexWithEdgeFunctionProgram.getMessageScopes(Memory memory) |
Set<MessageScope> |
GraphComputerTest.VertexProgramM.getMessageScopes(Memory memory) |
Modifier and Type | Method and Description |
---|---|
void |
Messenger.sendMessage(MessageScope messageScope,
M message)
The currently executing vertex can send a message with provided
MessageScope . |
Modifier and Type | Method and Description |
---|---|
Set<MessageScope> |
BulkDumperVertexProgram.getMessageScopes(Memory memory) |
Modifier and Type | Method and Description |
---|---|
Set<MessageScope> |
BulkLoaderVertexProgram.getMessageScopes(Memory memory) |
Modifier and Type | Method and Description |
---|---|
Set<MessageScope> |
PeerPressureVertexProgram.getMessageScopes(Memory memory) |
Modifier and Type | Method and Description |
---|---|
Set<MessageScope> |
PageRankVertexProgram.getMessageScopes(Memory memory) |
Modifier and Type | Method and Description |
---|---|
Set<MessageScope> |
TraversalVertexProgram.getMessageScopes(Memory memory) |
Modifier and Type | Method and Description |
---|---|
void |
SingleMessenger.sendMessage(MessageScope messageScope,
M message) |
Modifier and Type | Method and Description |
---|---|
Set<MessageScope> |
ProgramTest.TestProgram.getMessageScopes(Memory memory) |
Modifier and Type | Method and Description |
---|---|
void |
SparkMessenger.sendMessage(MessageScope messageScope,
M message) |
Modifier and Type | Method and Description |
---|---|
void |
TinkerMessenger.sendMessage(MessageScope messageScope,
M message) |
Copyright © 2013–2018 Apache Software Foundation. All rights reserved.