Package | Description |
---|---|
org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem . |
org.apache.hadoop.hdfs.net |
Modifier and Type | Method and Description |
---|---|
Peer |
RemoteBlockReader2.getPeer() |
Modifier and Type | Method and Description |
---|---|
static BlockReader |
BlockReaderFactory.newBlockReader(DFSClient.Conf conf,
String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
boolean verifyChecksum,
String clientName,
Peer peer,
DatanodeID datanodeID,
org.apache.hadoop.hdfs.DomainSocketFactory domSockFactory,
org.apache.hadoop.hdfs.PeerCache peerCache,
org.apache.hadoop.hdfs.FileInputStreamCache fisCache,
boolean allowShortCircuitLocalReads,
CachingStrategy cachingStrategy)
Create a new BlockReader specifically to satisfy a read.
|
static BlockReader |
RemoteBlockReader2.newBlockReader(String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
boolean verifyChecksum,
String clientName,
Peer peer,
DatanodeID datanodeID,
org.apache.hadoop.hdfs.PeerCache peerCache,
CachingStrategy cachingStrategy)
Create a new BlockReader specifically to satisfy a read.
|
static RemoteBlockReader |
RemoteBlockReader.newBlockReader(String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
int bufferSize,
boolean verifyChecksum,
String clientName,
Peer peer,
DatanodeID datanodeID,
org.apache.hadoop.hdfs.PeerCache peerCache,
CachingStrategy cachingStrategy)
Deprecated.
Create a new BlockReader specifically to satisfy a read.
|
Constructor and Description |
---|
RemoteBlockReader2(String file,
String bpid,
long blockId,
DataChecksum checksum,
boolean verifyChecksum,
long startOffset,
long firstChunkOffset,
long bytesToRead,
Peer peer,
DatanodeID datanodeID,
org.apache.hadoop.hdfs.PeerCache peerCache) |
Modifier and Type | Class and Description |
---|---|
class |
DomainPeer
Represents a peer that we communicate with by using blocking I/O
on a UNIX domain socket.
|
class |
EncryptedPeer
Represents a peer that we communicate with by using an encrypted
communications medium.
|
Modifier and Type | Method and Description |
---|---|
Peer |
TcpPeerServer.accept() |
Peer |
PeerServer.accept()
Listens for a connection to be made to this server and accepts
it.
|
Peer |
DomainPeerServer.accept() |
static Peer |
TcpPeerServer.peerFromSocket(Socket socket) |
static Peer |
TcpPeerServer.peerFromSocketAndKey(Socket s,
DataEncryptionKey key) |
Constructor and Description |
---|
EncryptedPeer(Peer enclosedPeer,
DataEncryptionKey key) |
Copyright © 2013 Apache Software Foundation. All rights reserved.