| 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.