Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece.messages |
Utility classes for handling of messages within Pieces
|
org.apache.giraph.block_app.library |
Core library of Pieces and Suppliers, providing most common usages.
|
org.apache.giraph.block_app.library.striping |
Utilities for striping.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SupplierFromConf<T>
Supplier from configuration
|
Modifier and Type | Class and Description |
---|---|
static class |
SupplierFromConf.DefaultMessageFactorySupplierFromConf<M extends org.apache.hadoop.io.Writable>
Supplier from configuration returning DefaultMessageValueFactory instances.
|
static class |
SupplierFromConf.SupplierFromConfByCopy<T>
Supplier from configuration, by copying given instance every time.
|
Modifier and Type | Method and Description |
---|---|
Block |
SendMessageChain.endCustom(Function<SupplierFromVertex<I,V,E,P>,Block> createBlockToAttach)
End chain by providing a function that will produce Block to be attached
to the end of current chain, given a supplier of messages received
within the last link in the chain.
|
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,P extends org.apache.hadoop.io.Writable> |
SendMessageChain.startCustom(Function<ConsumerWithVertex<I,V,E,P>,Block> createStartingBlock)
Start chain by providing a function that will produce Block representing
beginning of the chain, given a consumer of messages send
by the last link in the created block.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable> |
StripingUtils.createSingleStripeBySendersFunction(Block block)
Given a block, creates a function that will given a predicate filter
calls to vertexSend function based on that predicate.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable> |
StripingUtils.generateStripedBlock(int stripes,
Function<Predicate<I>,Block> blockGenerator,
Int2ObjFunction<Int2ObjFunction<Predicate<I>>> stripeSupplier)
Generate striped block, with given number of
stripes ,
using given blockGenerator to generate block for each stripe,
and using striping based on given stripeSupplier . |
static Block |
StripingUtils.generateStripedBlock(int stripes,
Function<Predicate<org.apache.hadoop.io.LongWritable>,Block> blockGenerator)
Generate striped block, with given number of
stripes ,
using given blockGenerator to generate block for each stripe. |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.