See: Description
Class | Description |
---|---|
AbstractPiece<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> |
Parent of all Pieces, contains comprehensive list of methods Piece
can support.
|
DefaultParentPiece<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> |
Additional abstract implementations for all pieces to be used.
|
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)
|
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.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.