Package org.apache.hadoop.ozone.container.keyvalue.impl

Class FilePerChunkStrategy

java.lang.Object

org.apache.hadoop.ozone.container.keyvalue.impl.FilePerChunkStrategy

All Implemented Interfaces:

ChunkManager

public class FilePerChunkStrategy
extends Object
implements ChunkManager

This class is for performing chunk related operations.

Constructor Summary

Constructors

Constructor	Description
FilePerChunkStrategy(boolean sync, BlockManager manager)

Method Summary

Modifier and Type	Method	Description
void	deleteChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info)	Deletes a given chunk.
void	deleteChunks(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)
org.apache.hadoop.ozone.common.ChunkBufferToByteString	readChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info, DispatcherContext dispatcherContext)	reads the data defined by a chunk.
void	writeChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info, org.apache.hadoop.ozone.common.ChunkBuffer data, DispatcherContext dispatcherContext)	writes a given chunk.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.ozone.container.keyvalue.interfaces.ChunkManager

finalizeWriteChunk, finishWriteChunks, getStreamDataChannel, shutdown, streamInit, writeChunk

Constructor Details

FilePerChunkStrategy

public FilePerChunkStrategy(boolean sync,
 BlockManager manager)

Method Details

writeChunk

public void writeChunk(Container container,
 org.apache.hadoop.hdds.client.BlockID blockID,
 org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info,
 org.apache.hadoop.ozone.common.ChunkBuffer data,
 DispatcherContext dispatcherContext)
                throws org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

writes a given chunk.

Specified by:

writeChunk in interface ChunkManager

Parameters:

container - - Container for the chunk

blockID - - ID of the block

info - - ChunkInfo

data - - data of the chunk

dispatcherContext - - dispatcherContextInfo

Throws:

org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

readChunk

public org.apache.hadoop.ozone.common.ChunkBufferToByteString readChunk(Container container,
 org.apache.hadoop.hdds.client.BlockID blockID,
 org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info,
 DispatcherContext dispatcherContext)
                                                                 throws org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

reads the data defined by a chunk.

Specified by:

readChunk in interface ChunkManager

Parameters:

container - - Container for the chunk

blockID - - ID of the block.

info - - ChunkInfo.

dispatcherContext - dispatcher context info.

Returns:

byte array

Throws:

org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException - TODO: Right now we do not support partial reads and writes of chunks. TODO: Explore if we need to do that for ozone.

deleteChunk

public void deleteChunk(Container container,
 org.apache.hadoop.hdds.client.BlockID blockID,
 org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info)
                 throws org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

Deletes a given chunk.

Specified by:

deleteChunk in interface ChunkManager

Parameters:

container - - Container for the chunk

blockID - - ID of the block

info - - Chunk Info

Throws:

org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

deleteChunks

public void deleteChunks(Container container,
 org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)
                  throws org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

Specified by:

deleteChunks in interface ChunkManager

Throws:

org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException