Package | Description |
---|---|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Class and Description |
---|---|
class |
WorkerAggregatorHandler
Handler for reduce/broadcast on the workers
|
class |
WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage
Not thread-safe implementation of
WorkerThreadGlobalCommUsage . |
Modifier and Type | Method and Description |
---|---|
WorkerThreadGlobalCommUsage |
WorkerAggregatorHandler.newThreadAggregatorUsage()
Create new aggregator usage which will be used by one of the compute
threads.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.