Package | Description |
---|---|
org.apache.giraph.block_app.framework.block |
Block interface as a composable unit of execution, and its common
implementations.
|
org.apache.giraph.block_app.library |
Core library of Pieces and Suppliers, providing most common usages.
|
org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
org.apache.giraph.block_app.reducers.array |
Reducers for collecting arrays of objects.
|
org.apache.giraph.block_app.test_setup |
Utilities for unit tests.
|
org.apache.giraph.block_app.test_setup.graphs |
Common Graphs for unit tests.
|
org.apache.giraph.function |
Package for interfaces representing different functions,
that all extends Serializable in order for Kryo to be able
to serialize them.
|
Modifier and Type | Method and Description |
---|---|
static Block |
RepeatUntilBlock.unlimited(Block block,
Supplier<Boolean> toQuit)
Repeat unlimited number of times, until toQuit supplier returns true.
|
Constructor and Description |
---|
IfBlock(Supplier<Boolean> condition,
Block thenBlock) |
IfBlock(Supplier<Boolean> condition,
Block thenBlock,
Block elseBlock) |
RepeatUntilBlock(int repeatTimes,
Block block,
Supplier<Boolean> toQuit) |
Modifier and Type | Method and Description |
---|---|
static <S,R extends org.apache.hadoop.io.Writable,I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Pieces.reduceAndBroadcastWithArrayOfHandles(String name,
int numHandles,
Supplier<ReduceOperation<S,R>> reduceOp,
SupplierFromVertex<I,V,E,Long> handleHashSupplier,
SupplierFromVertex<I,V,E,S> valueSupplier,
ConsumerWithVertex<I,V,E,R> reducedValueConsumer)
Like reduceAndBroadcast, but uses array of handles for reducers and
broadcasts, to make it feasible and performant when values are large.
|
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,MR extends org.apache.hadoop.io.Writable,MS extends org.apache.hadoop.io.Writable> |
MigrationPiece.createMigrationPiece(Class<? extends MigrationAbstractComputation<I,V,E,MR,MS>> computationClass,
MigrationMasterCompute masterCompute,
Supplier<Iterable<MR>> previousMessagesSupplier,
Consumer<Iterable<MS>> currentMessagesConsumer,
Class<MS> messageClass,
Class<? extends MessageCombiner<? super I,MS>> messageCombinerClass) |
Constructor and Description |
---|
ArrayOfBroadcasts(int count,
Supplier<BroadcastHandle<T>> broadcastHandleFactory) |
ArrayOfHandles(int count,
Supplier<H> reduceHandleFactory) |
ArrayOfReducers(int count,
Supplier<ReducerHandle<S,R>> reduceHandleFactory) |
Modifier and Type | Method and Description |
---|---|
static Supplier<org.apache.hadoop.io.DoubleWritable> |
TestGraphUtils.doubleSupplier(double value) |
static Supplier<org.apache.hadoop.io.NullWritable> |
TestGraphUtils.nullSupplier() |
Modifier and Type | Method and Description |
---|---|
void |
NumericTestGraph.addVertex(Number vertexId,
V vertexValue,
Supplier<E> edgeSupplier,
Number... outEdges)
Add Vertex with a given id and a given Vertex Value to the graph,
with listed outgoing edges, all initialized to same provided
edgeSupplier . |
void |
NumericTestGraph.initializeVertex(Vertex<I,V,E> v,
I id,
Supplier<V> valueSupplier,
List<Edge<I,E>> edgesList) |
Vertex<I,V,E> |
NumericTestGraph.makeVertex(Number vertexId,
V vertexValue,
Supplier<E> edgeSupplier,
Number... edges)
Creates a new Vertex object, without adding it into the graph.
|
Modifier and Type | Field and Description |
---|---|
protected Supplier<E> |
SyntheticGraphInit.edgeSupplier |
Constructor and Description |
---|
Small1GraphInit(Supplier<E> edgeSupplier) |
Small2GraphInit(Supplier<E> edgeSupplier) |
SmallDirectedForestGraphInit(Supplier<E> edgeSupplier) |
SmallDirectedTreeGraphInit(Supplier<E> edgeSupplier) |
SyntheticGraphInit(Supplier<E> edgeSupplier) |
Modifier and Type | Class and Description |
---|---|
class |
ObjectHolder<T>
Default object holder, intermediary between producers and consumers.
|
class |
ObjectTransfer<T>
Default object transfer, intermediary between producers and consumers.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.