Package | Description |
---|---|
org.apache.giraph.comm.messages |
Package of classes for storing messages.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.master |
Package of all the master related things.
|
Modifier and Type | Method and Description |
---|---|
MessageStore<I,M> |
InMemoryMessageStoreFactory.newStore(MessageClasses<I,M> messageClasses) |
MessageStore<I,M> |
ByteArrayMessagesPerVertexStore.Factory.newStore(MessageClasses<I,M> messageClasses) |
MS |
MessageStoreFactory.newStore(MessageClasses<I,M> messageClasses)
Creates new message store.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultMessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Default implementation of MessageClasses
|
Modifier and Type | Field and Description |
---|---|
protected MessageClasses<I,? extends org.apache.hadoop.io.Writable> |
GiraphClasses.incomingMessageClasses
Incoming message classes
|
protected MessageClasses<I,? extends org.apache.hadoop.io.Writable> |
GiraphClasses.outgoingMessageClasses
Outgoing message classes
|
Modifier and Type | Method and Description |
---|---|
MessageClasses<I,M> |
DefaultMessageClasses.createCopyForNewSuperstep() |
MessageClasses<I,M> |
MessageClasses.createCopyForNewSuperstep()
Creates a fresh copy of this object,
to be used and changed for new superstep.
|
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> |
GiraphClasses.getIncomingMessageClasses() |
<M extends org.apache.hadoop.io.Writable> |
ImmutableClassesGiraphConfiguration.getIncomingMessageClasses()
Get incoming message classes
|
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> |
GiraphClasses.getOutgoingMessageClasses() |
<M extends org.apache.hadoop.io.Writable> |
ImmutableClassesGiraphConfiguration.getOutgoingMessageClasses()
Get outgoing message classes
|
Modifier and Type | Method and Description |
---|---|
GiraphClasses |
GiraphClasses.setIncomingMessageClasses(MessageClasses<I,? extends org.apache.hadoop.io.Writable> incomingMessageClasses)
Set incoming Message Value class held - messages which have been sent in
the previous superstep and are processed in the current one
|
GiraphClasses |
GiraphClasses.setOutgoingMessageClasses(MessageClasses<I,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses)
Set outgoing Message Value class held - messages which are going to be sent
during current superstep
|
Modifier and Type | Method and Description |
---|---|
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> |
SuperstepClasses.getOutgoingMessageClasses() |
Modifier and Type | Method and Description |
---|---|
void |
SuperstepClasses.setOutgoingMessageClasses(MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses)
Set's outgoing MessageClasses for next superstep.
|
void |
MasterCompute.setOutgoingMessageClasses(MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses)
Set outgoing message classes to be used
|
Constructor and Description |
---|
SuperstepClasses(ImmutableClassesGiraphConfiguration conf,
Class<? extends Computation> computationClass,
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> incomingMessageClasses,
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses)
Constructor
|
SuperstepClasses(ImmutableClassesGiraphConfiguration conf,
Class<? extends Computation> computationClass,
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> incomingMessageClasses,
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.