Package | Description |
---|---|
org.apache.giraph.block_app.library |
Core library of Pieces and Suppliers, providing most common usages.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> |
Pieces.sendMessage(String name,
MessageCombiner<? super I,M> messageCombiner,
SupplierFromVertex<I,V,E,M> messageSupplier,
SupplierFromVertex<I,V,E,Iterator<I>> targetsSupplier,
ConsumerWithVertex<I,V,E,M> messagesConsumer)
Creates Piece that for each vertex, sends message provided by
messageSupplier to all targets provided by targetsSupplier,
and uses given messageCombiner to combine messages together.
|
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> |
Pieces.sendMessageToNeighbors(String name,
MessageCombiner<? super I,M> messageCombiner,
SupplierFromVertex<I,V,E,M> messageSupplier,
ConsumerWithVertex<I,V,E,M> messagesConsumer)
Creates Piece that for each vertex, sends message provided by
messageSupplier to all neighbors of current vertex,
and uses given messageCombiner to combine messages together.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.