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

Class ChunkManagerDummyImpl

java.lang.Object

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

All Implemented Interfaces:

ChunkManager

public class ChunkManagerDummyImpl
extends Object
implements ChunkManager

Implementation of ChunkManager built for running performance tests. Chunks are not written to disk, Reads are returned with zero-filled buffers

Constructor Summary

Constructors

Constructor	Description
ChunkManagerDummyImpl()

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.ChunkBuffer	readChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info, DispatcherContext dispatcherContext)	return a zero-filled buffer.
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

ChunkManagerDummyImpl

public ChunkManagerDummyImpl()

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

Description copied from interface: ChunkManager

writes a given chunk.

Specified by:

writeChunk in interface ChunkManager

Parameters:

container - - Container for the chunk

blockID - - ID of the block.

info - - ChunkInfo.

data -

dispatcherContext - - dispatcher context info.

Throws:

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

readChunk

public org.apache.hadoop.ozone.common.ChunkBuffer 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

return a zero-filled buffer.

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)

Description copied from interface: ChunkManager

Deletes a given chunk.

Specified by:

deleteChunk in interface ChunkManager

Parameters:

container - - Container for the chunk

blockID - - ID of the block.

info - - Chunk Info

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