程序包 | 说明 |
---|---|
org.apache.hadoop.hdfs.server.datanode |
限定符和类型 | 方法和说明 |
---|---|
FSDatasetInterface.BlockWriteStreams |
FSDatasetInterface.writeToBlock(Block b,
boolean isRecovery,
boolean isReplicationRequest)
Creates the block and returns output streams to write data and CRC
|
FSDatasetInterface.BlockWriteStreams |
FSDataset.writeToBlock(Block b,
boolean isRecovery,
boolean replicationRequest)
Start writing to a block file
If isRecovery is true and the block pre-exists, then we kill all
volumeMap.put(b, v);
volumeMap.put(b, v);
other threads that might be writing to this block, and then reopen the file.
|
限定符和类型 | 方法和说明 |
---|---|
long |
FSDatasetInterface.getChannelPosition(Block b,
FSDatasetInterface.BlockWriteStreams stream)
Returns the current offset in the data stream.
|
long |
FSDataset.getChannelPosition(Block b,
FSDatasetInterface.BlockWriteStreams streams)
Retrieves the offset in the block to which the
the next write will write data to.
|
void |
FSDatasetInterface.setChannelPosition(Block b,
FSDatasetInterface.BlockWriteStreams stream,
long dataOffset,
long ckOffset)
Sets the file pointer of the data stream and checksum stream to
the specified values.
|
void |
FSDataset.setChannelPosition(Block b,
FSDatasetInterface.BlockWriteStreams streams,
long dataOffset,
long ckOffset)
Sets the offset in the block to which the
the next write will write data to.
|
Copyright © 2009 The Apache Software Foundation