Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece.global_comm.internal |
Reducer and Broadcast Handles internal implementation for automatic handling
of global communication within Pieces, hiding a lot of it's complexities.
|
Modifier and Type | Class and Description |
---|---|
class |
ReducersForPieceHandler
All logic for transforming Giraph's reducer API to reducer handles.
|
class |
ReducersForPieceHandler.GlobalReduceHandle<S,R extends org.apache.hadoop.io.Writable>
Global Reduce Handle is implementation of ReducerHandle, that will keep
only one value for each worker, and each call to reduce will have
to obtain a global lock, and incur synchronization costs.
|
class |
ReducersForPieceHandler.LocalReduceHandle<S,R extends org.apache.hadoop.io.Writable>
Local Reduce Handle is implementation of ReducerHandle, that will make a
partially reduced value on each worker thread, which are at the end
reduced all together.
|
class |
ReducersForPieceHandler.ReduceHandleImpl<S,R extends org.apache.hadoop.io.Writable>
Parent implementation of ReducerHandle
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.