| 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.