| Package | Description | 
|---|---|
| org.apache.reef.io.naming | |
| org.apache.reef.io.network | 
 Licensed to the Apache Software Foundation (ASF) under one
 or more contributor license agreements. 
 | 
| org.apache.reef.io.network.impl | 
 Licensed to the Apache Software Foundation (ASF) under one
 or more contributor license agreements. 
 | 
| org.apache.reef.io.network.naming | 
 Licensed to the Apache Software Foundation (ASF) under one
 or more contributor license agreements. 
 | 
| org.apache.reef.io.network.naming.serialization | 
 Contains naming serialization codecs 
 | 
| org.apache.reef.io.network.util | 
 Licensed to the Apache Software Foundation (ASF) under one
 or more contributor license agreements. 
 | 
| org.apache.reef.wake | |
| org.apache.reef.wake.impl | |
| org.apache.reef.wake.remote | |
| org.apache.reef.wake.remote.impl | |
| org.apache.reef.wake.storage | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
NameAssignment.getIdentifier()
Returns an identifier of this object 
 | 
| Modifier and Type | Method and Description | 
|---|---|
InetSocketAddress | 
NamingLookup.lookup(Identifier id)
Lookup an Address for a given Identifier. 
 | 
void | 
NamingRegistry.register(Identifier id,
                InetSocketAddress addr)
Register the given Address for the given Identifier 
 | 
void | 
NamingRegistry.unregister(Identifier id)
Unregister the given Identifier from the registry 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
Message.getDestId()
Gets a destination identifier 
 | 
Identifier | 
Message.getSrcId()
Gets a source identifier 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Connection<T> | 
ConnectionFactory.newConnection(Identifier destId)
Creates a new connection 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
NSMessage.getDestId()
Gets a destination identifier 
 | 
Identifier | 
NetworkService.getMyId()  | 
Identifier | 
NSMessage.getSrcId()
Gets a source identifier 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Connection<T> | 
NetworkService.newConnection(Identifier destId)  | 
void | 
NetworkService.registerId(Identifier id)  | 
void | 
NetworkService.unregisterId(Identifier id)  | 
| Constructor and Description | 
|---|
NSMessage(Identifier srcId,
                  Identifier destId,
                  List<T> data)
Constructs a network service message 
 | 
NSMessage(Identifier srcId,
                  Identifier destId,
                  T data)
Constructs a network service message 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
NameAssignmentTuple.getIdentifier()
Gets an identifier 
 | 
| Modifier and Type | Method and Description | 
|---|---|
InetSocketAddress | 
NameCache.get(Identifier key,
      Callable<InetSocketAddress> valueFetcher)
Gets an address for an identifier 
 | 
void | 
NameCache.invalidate(Identifier key)
Invalidates the entry for an identifier 
 | 
InetSocketAddress | 
NameClient.lookup(Identifier id)
Finds an address for an identifier 
 | 
InetSocketAddress | 
NameServerImpl.lookup(Identifier id)
Finds an address for an identifier locally 
 | 
InetSocketAddress | 
NameLookupClient.lookup(Identifier id)
Finds an address for an identifier 
 | 
InetSocketAddress | 
NameServer.lookup(Identifier id)
Finds an address for an identifier locally 
 | 
void | 
NameClient.register(Identifier id,
                InetSocketAddress addr)
Registers an (identifier, address) mapping 
 | 
void | 
NameServerImpl.register(Identifier id,
                InetSocketAddress addr)
Registers an (identifier, address) mapping locally 
 | 
void | 
NameRegistryClient.register(Identifier id,
                InetSocketAddress addr)
Registers an (identifier, address) mapping 
 | 
void | 
NameServer.register(Identifier id,
                InetSocketAddress addr)
Registers an (identifier, address) mapping locally 
 | 
InetSocketAddress | 
NameClient.remoteLookup(Identifier id)
Retrieves an address for an identifier remotely 
 | 
InetSocketAddress | 
NameLookupClient.remoteLookup(Identifier id)
Retrieves an address for an identifier remotely 
 | 
void | 
NameClient.unregister(Identifier id)
Unregisters an identifier 
 | 
void | 
NameServerImpl.unregister(Identifier id)
Unregisters an identifier locally 
 | 
void | 
NameRegistryClient.unregister(Identifier id)
Unregisters an identifier 
 | 
void | 
NameServer.unregister(Identifier id)
Unregisters an identifier locally 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<NameAssignment> | 
NameServerImpl.lookup(Iterable<Identifier> identifiers)
Finds addresses for identifiers locally 
 | 
List<NameAssignment> | 
NameServer.lookup(Iterable<Identifier> identifiers)
Finds addresses for identifiers locally 
 | 
| Constructor and Description | 
|---|
NameAssignmentTuple(Identifier id,
                                      InetSocketAddress addr)
Constructs a name assignment tuple 
 | 
| Constructor and Description | 
|---|
NameClient(String serverAddr,
                    int serverPort,
                    IdentifierFactory factory,
                    int retryCount,
                    int retryTimeout,
                    Cache<Identifier,InetSocketAddress> cache)
Constructs a naming client 
 | 
NameClient(String serverAddr,
                    int serverPort,
                    long timeout,
                    IdentifierFactory factory,
                    int retryCount,
                    int retryTimeout,
                    Cache<Identifier,InetSocketAddress> cache)
Constructs a naming client 
 | 
NameLookupClient(String serverAddr,
                                int serverPort,
                                IdentifierFactory factory,
                                int retryCount,
                                int retryTimeout,
                                Cache<Identifier,InetSocketAddress> cache)
Constructs a naming lookup client 
 | 
NameLookupClient(String serverAddr,
                                int serverPort,
                                long timeout,
                                IdentifierFactory factory,
                                int retryCount,
                                int retryTimeout,
                                Cache<Identifier,InetSocketAddress> cache)
Constructs a naming lookup client 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
NamingUnregisterRequest.getIdentifier()
Gets an identifier 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Iterable<Identifier> | 
NamingLookupRequest.getIdentifiers()
Gets identifiers 
 | 
| Constructor and Description | 
|---|
NamingUnregisterRequest(Identifier id)
Constructs a naming un-registration request 
 | 
| Constructor and Description | 
|---|
NamingLookupRequest(Iterable<Identifier> ids)
Constructs a naming lookup request 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
StringIdentifier
String identifier 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
StringIdentifierFactory.getNewInstance(String s)
Creates a StringIdentifier object 
 | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
StringIdentifier.compareTo(Identifier o)  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ComparableIdentifier
Identifier that can be totally ordered. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
Identifiable.getId()
Returns an identifier of this object 
 | 
Identifier | 
IdentifierFactory.getNewInstance(String str)
Creates a RemoteIdentifier object 
 | 
Identifier | 
IdentifierParser.newInstance()  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
OpaqueLocalIdentifier  | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
DefaultIdentifierFactory.getNewInstance(String str)
Creates a new remote identifier instance 
 | 
| Constructor and Description | 
|---|
DefaultIdentifierFactory(Map<String,Class<? extends Identifier>> typeToClazzMap)
Constructs a default remote identifier factory 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
RemoteIdentifier
Wake remote identifier 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SocketRemoteIdentifier
Remote identifier based on a socket address 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
StorageIdentifier  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
FileIdentifier  | 
| Modifier and Type | Method and Description | 
|---|---|
Identifier | 
ReadRequest.getId()  | 
| Constructor and Description | 
|---|
ReadRequest(StorageIdentifier f,
                      long offset,
                      byte[] buf,
                      Identifier id)  | 
ReadResponse(byte[] buf,
                        int bytesRead,
                        Identifier reqId)  | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.