net.tomp2p.mapreduce
Class MapReducePeer

java.lang.Object
  extended by net.tomp2p.p2p.Peer
      extended by net.tomp2p.mapreduce.MapReducePeer

public class MapReducePeer
extends Peer


Field Summary
 
Fields inherited from class net.tomp2p.p2p.Peer
BLOOMFILTER_SIZE
 
Constructor Summary
MapReducePeer(Number160 nodeId)
           
 
Method Summary
 FutureMapReduce map(Number160 createHash, Data data, Mapper map)
           
 FutureReduce reduce(Number160 createHash, Data data, Reducer reducer)
           
 
Methods inherited from class net.tomp2p.p2p.Peer
add, add, add, add, add, addIndirectReplicaiton, addPeerListener, addToTracker, adjustConfiguration, bootstrap, bootstrap, bootstrap, bootstrap, bootstrapBroadcast, bootstrapBroadcast, createPeerConnection, customLoggerMessage, digest, digest, digest, digest, digest, digestAll, digestAll, digestAll, discover, get, get, get, get, get, getAll, getAll, getAll, getConnectionBean, getConnectionConfiguration, getConnectionHandler, getDHT, getDirectDataRPC, getFromTracker, getFromTracker, getFromTrackerCreateBloomfilter1, getFromTrackerCreateBloomfilter2, getHandshakeRPC, getP2PConfiguration, getP2PID, getPeerAddress, getPeerBean, getPeerExchangeRPC, getPeerID, getPendingFutures, getQuitRPC, getRouting, getStoreRPC, getTracker, getTrackerRPC, init, isListening, isRunning, listen, listen, listen, listen, listen, listen, listen, listen, parallelRequests, parallelRequests, ping, put, put, put, put, put, release, remove, remove, remove, remove, remove, remove, removeAll, removeAll, removeAll, removePeerListener, reserve, reserve, reserve, send, send, send, send, send, send, send, send, send, send, setDefaultStorageReplication, setFutureTimeout, setObjectDataReply, setPeerMap, setRawDataReply, setupPortForwanding, setupPortForwandingUPNP, shutdown
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MapReducePeer

public MapReducePeer(Number160 nodeId)
Method Detail

map

public FutureMapReduce map(Number160 createHash,
                           Data data,
                           Mapper map)

reduce

public FutureReduce reduce(Number160 createHash,
                           Data data,
                           Reducer reducer)


Copyright © 2012. All Rights Reserved.