Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece |
Single execution object - Piece, and related classes.
|
org.apache.giraph.block_app.library.gc |
GC utility pieces.
|
org.apache.giraph.block_app.library.internal |
Internal implementation of Pieces needed for Pieces utility class.
|
org.apache.giraph.block_app.library.iteration |
Utilities for having iteration within execution stage object.
|
org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
Modifier and Type | Class and Description |
---|---|
class |
Piece<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,S>
Piece that should be extended in common usecases, when we want to be:
- sending and then receiving messages from vertices
- sending data to be aggregated from workers to master
- sending values from master, via aggregators, to workers
(basically - we don't want to use WorkerContext)
|
class |
PieceWithWorkerContext<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,WV,WM extends org.apache.hadoop.io.Writable,S>
Piece that should be extended when WorkerContext is used.
|
Modifier and Type | Class and Description |
---|---|
class |
WorkerGCPiece
Dummy piece to hint System.gc()
|
Modifier and Type | Class and Description |
---|---|
class |
SendMessagePiece<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>
Piece that sends a message provided through messageProducer to given set of
neighbors, and passes them to messagesConsumer.
|
class |
SendMessageWithCombinerPiece<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>
Piece that sends a message provided through messageProducer to given set of
neighbors, uses a message combiner and passes them to messagesConsumer.
|
Modifier and Type | Class and Description |
---|---|
class |
IterationCounterPiece
Piece that increments execution stage iteration.
|
Modifier and Type | Class and Description |
---|---|
class |
MigrationPiece<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,MPrev extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>
Piece used when migrating applications to Blocks Framework.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.