Interface | Description |
---|---|
MasterAggregatorUsage |
Master compute can access and change aggregators through this interface
|
MasterGlobalCommUsage |
All global master communication
|
MasterGlobalCommUsageAggregators |
Master compute can access reduce and broadcast methods
through this interface, from masterCompute method.
|
MasterObserver |
Observer for Master.
|
Class | Description |
---|---|
AggregatorBroadcast<A extends org.apache.hadoop.io.Writable> |
Writable representation of aggregated value
|
AggregatorReduceOperation<A extends org.apache.hadoop.io.Writable> |
Translates aggregation operation to reduce operations.
|
AggregatorToGlobalCommTranslation |
Class that translates aggregator handling on the master to
reduce and broadcast operations supported by the MasterAggregatorHandler.
|
BspServiceMaster<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
ZooKeeper-based implementation of
CentralizedServiceMaster . |
DefaultMasterCompute |
A dumb implementation of
MasterCompute . |
DefaultMasterObserver |
A no-op implementation of MasterObserver to make it easier for users.
|
MasterAggregatorHandler |
Handler for reduce/broadcast on the master
|
MasterCompute |
Interface for defining a master vertex that can perform centralized
computation between supersteps.
|
MasterGlobalCommHandler |
Handler for all master communications
|
MasterInfo |
Information about the master that is sent to other workers.
|
MasterProgress |
Stores information about master progress
|
MasterThread<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Master thread that will coordinate the activities of the tasks.
|
SuperstepClasses |
Holds Computation and MessageCombiner class.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.