Package | Description |
---|---|
org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem . |
org.apache.hadoop.hdfs.protocol.datatransfer | |
org.apache.hadoop.hdfs.server.datanode | |
org.apache.hadoop.hdfs.server.datanode.fsdataset | |
org.apache.hadoop.util |
Common utilities.
|
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 | Method and Description |
---|---|
static DataChecksum |
DataTransferProtoUtil.fromProto(DataTransferProtos.ChecksumProto proto) |
Modifier and Type | Method and Description |
---|---|
static DataTransferProtos.ChecksumProto |
DataTransferProtoUtil.toProto(DataChecksum checksum) |
void |
Sender.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy) |
void |
DataTransferProtocol.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy)
Write a block to a datanode pipeline.
|
Modifier and Type | Method and Description |
---|---|
DataChecksum |
BlockMetadataHeader.getChecksum()
Get the checksum
|
Modifier and Type | Method and Description |
---|---|
ReplicaOutputStreams |
ReplicaInPipeline.createStreams(boolean isCreate,
DataChecksum requestedChecksum) |
ReplicaOutputStreams |
ReplicaInPipelineInterface.createStreams(boolean isCreate,
DataChecksum requestedChecksum)
Create output streams for writing to this replica,
one for block file and one for CRC file
|
Modifier and Type | Method and Description |
---|---|
DataChecksum |
ReplicaOutputStreams.getChecksum() |
Constructor and Description |
---|
ReplicaOutputStreams(OutputStream dataOut,
OutputStream checksumOut,
DataChecksum checksum)
Create an object with a data output stream, a checksum output stream
and a checksum.
|
Modifier and Type | Method and Description |
---|---|
static DataChecksum |
DataChecksum.newDataChecksum(byte[] bytes,
int offset)
Creates a DataChecksum from HEADER_LEN bytes from arr[offset].
|
static DataChecksum |
DataChecksum.newDataChecksum(DataChecksum.Type type,
int bytesPerChecksum) |
static DataChecksum |
DataChecksum.newDataChecksum(DataInputStream in)
This constructucts a DataChecksum by reading HEADER_LEN bytes from
input stream in
|
Copyright © 2013 Apache Software Foundation. All rights reserved.