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.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.factories |
Package of factories for creating types, for example the user's graph types.
|
org.apache.giraph.jython.factories |
Jython factories.
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
Modifier and Type | Field and Description |
---|---|
protected MessageValueFactory<M> |
SendMessageCache.messageValueFactory
Cached message value factory
|
Modifier and Type | Field and Description |
---|---|
protected MessageValueFactory<M> |
SimpleMessageStore.messageValueFactory
Message class
|
Modifier and Type | Method and Description |
---|---|
protected MessageStore<I,M> |
InMemoryMessageStoreFactory.newStoreWithCombiner(Class<M> messageClass,
MessageValueFactory<M> messageValueFactory,
MessageCombiner<? super I,M> messageCombiner)
MessageStore to be used when combiner is enabled
|
protected MessageStore<I,M> |
InMemoryMessageStoreFactory.newStoreWithoutCombiner(Class<M> messageClass,
MessageValueFactory<M> messageValueFactory,
MessageEncodeAndStoreType encodeAndStore)
MessageStore to be used when combiner is not enabled
|
Modifier and Type | Field and Description |
---|---|
protected MessageValueFactory<M> |
IdByteArrayMessageStore.messageValueFactory
Message value factory
|
Constructor and Description |
---|
IdByteArrayMessageStore(MessageValueFactory<M> messageValueFactory,
PartitionSplitInfo<I> partitionInfo,
ImmutableClassesGiraphConfiguration<I,?,?> config)
Constructor
|
IdOneMessagePerVertexStore(MessageValueFactory<M> messageValueFactory,
PartitionSplitInfo<I> partitionInfo,
MessageCombiner<? super I,M> messageCombiner,
ImmutableClassesGiraphConfiguration<I,?,?> config)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected MessageValueFactory<M> |
LongAbstractStore.messageValueFactory
Message value factory
|
Constructor and Description |
---|
LongAbstractListStore(MessageValueFactory<M> messageValueFactory,
PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo,
ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config)
Constructor
|
LongAbstractStore(MessageValueFactory<M> messageValueFactory,
PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo,
ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config)
Constructor
|
LongPointerListPerVertexStore(MessageValueFactory<M> messageValueFactory,
PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo,
ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config)
Constructor
|
Modifier and Type | Field and Description |
---|---|
static ClassConfOption<MessageValueFactory> |
GiraphConstants.OUTGOING_MESSAGE_VALUE_FACTORY_CLASS
Outgoing message value factory class - optional
|
Modifier and Type | Method and Description |
---|---|
<M extends org.apache.hadoop.io.Writable> |
ImmutableClassesGiraphConfiguration.createIncomingMessageValueFactory()
Create new incoming message value factory
|
MessageValueFactory<M> |
DefaultMessageClasses.createMessageValueFactory(ImmutableClassesGiraphConfiguration conf) |
MessageValueFactory<M> |
MessageClasses.createMessageValueFactory(ImmutableClassesGiraphConfiguration conf)
Create new instance of MessageValueFactory
|
<M extends org.apache.hadoop.io.Writable> |
ImmutableClassesGiraphConfiguration.createOutgoingMessageValueFactory()
Create new outgoing message value factory
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMessageClasses.setMessageValueFactoryClass(Class<? extends MessageValueFactory<M>> messageValueFactoryClass) |
Constructor and Description |
---|
DefaultMessageClasses(Class<M> messageClass,
Class<? extends MessageValueFactory<M>> messageValueFactoryClass,
Class<? extends MessageCombiner<? super I,M>> messageCombinerClass,
MessageEncodeAndStoreType messageEncodeAndStoreType)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultMessageValueFactory<M extends org.apache.hadoop.io.Writable>
Factory class to create default message values.
|
class |
TestMessageValueFactory<M extends org.apache.hadoop.io.Writable>
Message Factory class that allows setting the message value class
|
Modifier and Type | Class and Description |
---|---|
class |
JythonMessageValueFactory<M extends org.apache.hadoop.io.Writable>
MessageValueFactory that creates
message values which are Jython classes. |
class |
JythonOutgoingMessageValueFactory<M extends org.apache.hadoop.io.Writable>
MessageValueFactory that
creates outgoing message values which are Jython classes. |
Constructor and Description |
---|
ByteArrayOneMessageToManyIds(MessageValueFactory<M> messageValueFactory)
Constructor.
|
ByteArrayVertexIdMessages(MessageValueFactory<M> messageValueFactory)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.