Uses of Interface
org.apache.hadoop.ozone.container.common.interfaces.Container

Packages that use Container

Package	Description
org.apache.hadoop.ozone.container.common.impl	This package is contains Ozone container implementation.
org.apache.hadoop.ozone.container.common.interfaces	This package contains common ozone container interfaces.
org.apache.hadoop.ozone.container.keyvalue	This package contains classes for KeyValue container type.
org.apache.hadoop.ozone.container.keyvalue.helpers	This package contains utility classes for KeyValue container type.
org.apache.hadoop.ozone.container.keyvalue.impl	Chunk manager and block manager implementations for keyvalue container type.
org.apache.hadoop.ozone.container.keyvalue.interfaces	Chunk manager and block manager interfaces for keyvalue container type.
org.apache.hadoop.ozone.container.keyvalue.statemachine.background	Tasks running in the background.
org.apache.hadoop.ozone.container.ozoneimpl	Ozone main that calls into the container layer.

Uses of Container in org.apache.hadoop.ozone.container.common.impl

Fields in org.apache.hadoop.ozone.container.common.impl with type parameters of type Container

Modifier and Type	Field	Description
static final Comparator<Container<?>>	ContainerDataScanOrder.INSTANCE

Methods in org.apache.hadoop.ozone.container.common.impl that return Container

Modifier and Type	Method	Description
Container<?>	ContainerSet.getContainer(long containerId)	Returns the Container with specified containerId.
Container	HddsDispatcher.getContainer(long containerID)

Methods in org.apache.hadoop.ozone.container.common.impl that return types with arguments of type Container

Modifier and Type	Method	Description
Iterator<Container<?>>	ContainerSet.getContainerIterator(HddsVolume volume)	Return an iterator of containers associated with the specified volume.
Map<Long,Container<?>>	ContainerSet.getContainerMap()
Map<Long,Container<?>>	ContainerSet.getContainerMapCopy()	Return a copy of the containerMap.
Iterator<Map.Entry<Long,Container<?>>>	ContainerSet.getContainerMapIterator()	Return an containerMap iterator over ContainerSet.containerMap.
Iterator<Container<?>>	ContainerSet.iterator()

Methods in org.apache.hadoop.ozone.container.common.impl with parameters of type Container

Modifier and Type	Method	Description
boolean	ContainerSet.addContainer(Container<?> container)	Add Container to container map.
boolean	ContainerSet.addContainerByOverwriteMissingContainer(Container<?> container)	Add Container to container map.
int	ContainerDataScanOrder.compare(Container<?> o1, Container<?> o2)

Uses of Container in org.apache.hadoop.ozone.container.common.interfaces

Methods in org.apache.hadoop.ozone.container.common.interfaces that return Container

Modifier and Type	Method	Description
abstract Container	Handler.importContainer(ContainerData containerData, InputStream rawContainerStream, TarContainerPacker packer)	Imports container from a raw input stream.

Methods in org.apache.hadoop.ozone.container.common.interfaces with parameters of type Container

Modifier and Type	Method	Description
abstract void	Handler.addFinalizedBlock(Container container, long localID)
abstract void	Handler.closeContainer(Container container)	Moves the Container to CLOSED state.
abstract void	Handler.deleteBlock(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)	Deletes the given files associated with a block of the container.
abstract void	Handler.deleteContainer(Container container, boolean force)	Deletes the given container.
abstract void	Handler.deleteUnreferenced(Container container, long localID)	Deletes the possible onDisk but unreferenced blocks/chunks with localID in the container.
abstract void	Handler.exportContainer(Container container, OutputStream outputStream, TarContainerPacker packer)	Exports container to the output stream.
abstract org.apache.ratis.statemachine.StateMachine.DataChannel	Handler.getStreamDataChannel(Container container, org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandRequestProto msg)
abstract org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandResponseProto	Handler.handle(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandRequestProto msg, Container container, DispatcherContext dispatcherContext)
abstract boolean	Handler.isFinalizedBlockExist(Container container, long localID)
abstract void	Handler.markContainerForClose(Container container)	Marks the container for closing.
abstract void	Handler.markContainerUnhealthy(Container container, ScanResult reason)	Marks the container Unhealthy.
void	ContainerPacker.pack(Container<CONTAINERDATA> container, OutputStream destination)	Compress all the container data (chunk data, metadata db AND container descriptor) to one single archive.
default void	ContainerPacker.persistCustomContainerState(Container<? extends ContainerData> container, byte[] descriptorContent, org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerDataProto.State state, Path containerMetadataPath)	Persists the custom state for a container.
abstract void	Handler.quasiCloseContainer(Container container, String reason)	Moves the Container to QUASI_CLOSED state.
abstract void	Handler.reconcileContainer(DNContainerOperationClient dnClient, Container<?> container, Collection<org.apache.hadoop.hdds.protocol.DatanodeDetails> peers)	Triggers reconciliation of this container replica's data with its peers.
protected void	Handler.sendDeferredICR(Container container)	This should be called when there is no state change.
protected void	Handler.sendICR(Container container)	This should be called whenever there is state change.
byte[]	ContainerPacker.unpackContainerData(Container<CONTAINERDATA> container, InputStream inputStream, Path tmpDir, Path destContainerDir)	Extract the container data to the path defined by the container.
abstract void	Handler.updateContainerChecksum(Container container, ContainerMerkleTreeWriter treeWriter)	Updates the container checksum information on disk and in memory and sends an ICR if the container checksum was changed from its previous value.

Method parameters in org.apache.hadoop.ozone.container.common.interfaces with type arguments of type Container

Modifier and Type	Method	Description
static Handler	Handler.getHandlerForContainerType(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerType containerType, org.apache.hadoop.hdds.conf.ConfigurationSource config, String datanodeId, ContainerSet contSet, VolumeSet volumeSet, VolumeChoosingPolicy volumeChoosingPolicy, ContainerMetrics metrics, IncrementalReportSender<Container> icrSender, ContainerChecksumTreeManager checksumManager)

Constructor parameters in org.apache.hadoop.ozone.container.common.interfaces with type arguments of type Container

Modifier	Constructor	Description
protected	Handler(org.apache.hadoop.hdds.conf.ConfigurationSource config, String datanodeId, ContainerSet contSet, VolumeSet volumeSet, ContainerMetrics containerMetrics, IncrementalReportSender<Container> icrSender)

Uses of Container in org.apache.hadoop.ozone.container.keyvalue

Classes in org.apache.hadoop.ozone.container.keyvalue that implement Container

Modifier and Type	Class	Description
class	KeyValueContainer	Class to perform KeyValue Container operations.

Methods in org.apache.hadoop.ozone.container.keyvalue that return Container

Modifier and Type	Method	Description
Container	KeyValueHandler.importContainer(ContainerData originalContainerData, InputStream rawContainerStream, TarContainerPacker packer)

Methods in org.apache.hadoop.ozone.container.keyvalue with parameters of type Container

Modifier and Type	Method	Description
void	KeyValueHandler.addFinalizedBlock(Container container, long localID)
void	KeyValueHandler.closeContainer(Container container)
void	KeyValueHandler.deleteBlock(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)	Called by BlockDeletingService to delete all the chunks in a block before proceeding to delete the block info from DB.
void	KeyValueHandler.deleteContainer(Container container, boolean force)
void	KeyValueHandler.deleteUnreferenced(Container container, long localID)
void	KeyValueHandler.exportContainer(Container container, OutputStream outputStream, TarContainerPacker packer)
org.apache.ratis.statemachine.StateMachine.DataChannel	KeyValueHandler.getStreamDataChannel(Container container, org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandRequestProto msg)
org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandResponseProto	KeyValueHandler.handle(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerCommandRequestProto request, Container container, DispatcherContext dispatcherContext)
boolean	KeyValueHandler.isFinalizedBlockExist(Container container, long localID)
void	KeyValueHandler.markContainerForClose(Container container)
void	KeyValueHandler.markContainerUnhealthy(Container container, ScanResult reason)
void	TarContainerPacker.pack(Container<KeyValueContainerData> container, OutputStream output)	Given a containerData include all the required container data/metadata in a tar file.
void	KeyValueHandler.quasiCloseContainer(Container container, String reason)
void	KeyValueHandler.reconcileContainer(DNContainerOperationClient dnClient, Container<?> container, Collection<org.apache.hadoop.hdds.protocol.DatanodeDetails> peers)
byte[]	TarContainerPacker.unpackContainerData(Container<KeyValueContainerData> container, InputStream input, Path tmpDir, Path destContainerDir)	Given an input stream (tar file) extract the data to the specified directories.
void	KeyValueHandler.updateContainerChecksum(Container container, ContainerMerkleTreeWriter treeWriter)

Constructor parameters in org.apache.hadoop.ozone.container.keyvalue with type arguments of type Container

Modifier	Constructor	Description
	KeyValueHandler(org.apache.hadoop.hdds.conf.ConfigurationSource config, String datanodeId, ContainerSet contSet, VolumeSet volSet, ContainerMetrics metrics, IncrementalReportSender<Container> icrSender, ContainerChecksumTreeManager checksumManager)
	KeyValueHandler(org.apache.hadoop.hdds.conf.ConfigurationSource config, String datanodeId, ContainerSet contSet, VolumeSet volSet, VolumeChoosingPolicy volumeChoosingPolicy, ContainerMetrics metrics, IncrementalReportSender<Container> icrSender, Clock clock, ContainerChecksumTreeManager checksumManager)

Uses of Container in org.apache.hadoop.ozone.container.keyvalue.helpers

Methods in org.apache.hadoop.ozone.container.keyvalue.helpers with parameters of type Container

Modifier and Type	Method	Description
static void	BlockUtils.verifyBCSId(Container container, org.apache.hadoop.hdds.client.BlockID blockID)	Verify if request block BCSID is supported.
static void	BlockUtils.verifyReplicaIdx(Container container, org.apache.hadoop.hdds.client.BlockID blockID)	Verify if request's replicaIndex matches with containerData.

Uses of Container in org.apache.hadoop.ozone.container.keyvalue.impl

Methods in org.apache.hadoop.ozone.container.keyvalue.impl with parameters of type Container

Modifier and Type	Method	Description
boolean	BlockManagerImpl.blockExists(Container container, org.apache.hadoop.hdds.client.BlockID blockID)
void	BlockManagerImpl.deleteBlock(Container container, org.apache.hadoop.hdds.client.BlockID blockID)	Deletes an existing block.
void	ChunkManagerDispatcher.deleteChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info)
void	ChunkManagerDummyImpl.deleteChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info)
void	FilePerBlockStrategy.deleteChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info)
void	FilePerChunkStrategy.deleteChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info)	Deletes a given chunk.
void	ChunkManagerDispatcher.deleteChunks(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)
void	ChunkManagerDummyImpl.deleteChunks(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)
void	FilePerBlockStrategy.deleteChunks(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)
void	FilePerChunkStrategy.deleteChunks(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)
void	BlockManagerImpl.finalizeBlock(Container container, org.apache.hadoop.hdds.client.BlockID blockId)
org.apache.hadoop.ozone.container.common.helpers.BlockData	BlockManagerImpl.getBlock(Container container, org.apache.hadoop.hdds.client.BlockID blockID)
long	BlockManagerImpl.getCommittedBlockLength(Container container, org.apache.hadoop.hdds.client.BlockID blockID)
org.apache.ratis.statemachine.StateMachine.DataChannel	ChunkManagerDispatcher.getStreamDataChannel(Container container, org.apache.hadoop.hdds.client.BlockID blockID, ContainerMetrics metrics)
org.apache.ratis.statemachine.StateMachine.DataChannel	FilePerBlockStrategy.getStreamDataChannel(Container container, org.apache.hadoop.hdds.client.BlockID blockID, ContainerMetrics metrics)
List<org.apache.hadoop.ozone.container.common.helpers.BlockData>	BlockManagerImpl.listBlock(Container container, long startLocalID, int count)
long	BlockManagerImpl.putBlock(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData data)
long	BlockManagerImpl.putBlock(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData data, boolean endOfBlock)
long	BlockManagerImpl.putBlockForClosedContainer(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData data, boolean overwriteBcsId)	Persists the block data for a closed container.
org.apache.hadoop.ozone.common.ChunkBufferToByteString	ChunkManagerDispatcher.readChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info, DispatcherContext dispatcherContext)
org.apache.hadoop.ozone.common.ChunkBuffer	ChunkManagerDummyImpl.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.
org.apache.hadoop.ozone.common.ChunkBufferToByteString	FilePerBlockStrategy.readChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info, DispatcherContext dispatcherContext)
org.apache.hadoop.ozone.common.ChunkBufferToByteString	FilePerChunkStrategy.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.
String	ChunkManagerDispatcher.streamInit(Container container, org.apache.hadoop.hdds.client.BlockID blockID)
String	FilePerBlockStrategy.streamInit(Container container, org.apache.hadoop.hdds.client.BlockID blockID)
void	ChunkManagerDispatcher.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)
void	ChunkManagerDummyImpl.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)
void	FilePerBlockStrategy.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)
void	FilePerChunkStrategy.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.

Uses of Container in org.apache.hadoop.ozone.container.keyvalue.interfaces

Methods in org.apache.hadoop.ozone.container.keyvalue.interfaces with parameters of type Container

Modifier and Type	Method	Description
boolean	BlockManager.blockExists(Container container, org.apache.hadoop.hdds.client.BlockID blockID)	Check if a block exists in the container.
void	BlockManager.deleteBlock(Container container, org.apache.hadoop.hdds.client.BlockID blockID)	Deletes an existing block.
void	ChunkManager.deleteChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info)	Deletes a given chunk.
void	ChunkManager.deleteChunks(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData blockData)
void	BlockManager.finalizeBlock(Container container, org.apache.hadoop.hdds.client.BlockID blockId)
org.apache.hadoop.ozone.container.common.helpers.BlockData	BlockManager.getBlock(Container container, org.apache.hadoop.hdds.client.BlockID blockID)	Gets an existing block.
long	BlockManager.getCommittedBlockLength(Container container, org.apache.hadoop.hdds.client.BlockID blockID)	Returns last committed length of the block.
default org.apache.ratis.statemachine.StateMachine.DataChannel	ChunkManager.getStreamDataChannel(Container container, org.apache.hadoop.hdds.client.BlockID blockID, ContainerMetrics metrics)
List<org.apache.hadoop.ozone.container.common.helpers.BlockData>	BlockManager.listBlock(Container container, long startLocalID, int count)	List blocks in a container.
long	BlockManager.putBlock(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData data)	Puts or overwrites a block.
long	BlockManager.putBlock(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData data, boolean endOfBlock)	Puts or overwrites a block.
long	BlockManager.putBlockForClosedContainer(Container container, org.apache.hadoop.ozone.container.common.helpers.BlockData data, boolean overwriteBcsId)	Persists the block data for a closed container.
org.apache.hadoop.ozone.common.ChunkBufferToByteString	ChunkManager.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.
default String	ChunkManager.streamInit(Container container, org.apache.hadoop.hdds.client.BlockID blockID)
default void	ChunkManager.writeChunk(Container container, org.apache.hadoop.hdds.client.BlockID blockID, org.apache.hadoop.ozone.container.common.helpers.ChunkInfo info, ByteBuffer data, DispatcherContext dispatcherContext)
void	ChunkManager.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.

Uses of Container in org.apache.hadoop.ozone.container.keyvalue.statemachine.background

Methods in org.apache.hadoop.ozone.container.keyvalue.statemachine.background with parameters of type Container

Modifier and Type	Method	Description
org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult	BlockDeletingTask.deleteViaSchema1(DBHandle meta, Container container, File dataDir, long startTime)
org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult	BlockDeletingTask.deleteViaSchema2(DBHandle meta, Container container, File dataDir, long startTime)
org.apache.hadoop.ozone.container.keyvalue.statemachine.background.BlockDeletingTask.ContainerBackgroundTaskResult	BlockDeletingTask.deleteViaSchema3(DBHandle meta, Container container, File dataDir, long startTime)

Uses of Container in org.apache.hadoop.ozone.container.ozoneimpl

Methods in org.apache.hadoop.ozone.container.ozoneimpl that return Container

Modifier and Type	Method	Description
Container	ContainerController.getContainer(long containerId)	Returns the Container given a container id.
Container	ContainerController.importContainer(ContainerData containerData, InputStream rawContainerStream, TarContainerPacker packer)

Methods in org.apache.hadoop.ozone.container.ozoneimpl that return types with arguments of type Container

Modifier and Type	Method	Description
abstract Iterator<Container<?>>	AbstractBackgroundContainerScanner.getContainerIterator()
Iterator<Container<?>>	BackgroundContainerDataScanner.getContainerIterator()
Iterator<Container<?>>	BackgroundContainerMetadataScanner.getContainerIterator()
Iterable<Container<?>>	ContainerController.getContainers()
Iterator<Container<?>>	ContainerController.getContainers(HddsVolume volume)	Return an iterator of containers which are associated with the specified volume.

Methods in org.apache.hadoop.ozone.container.ozoneimpl with parameters of type Container

Modifier and Type	Method	Description
abstract void	AbstractBackgroundContainerScanner.scanContainer(Container<?> c)
void	BackgroundContainerDataScanner.scanContainer(Container<?> c)
void	BackgroundContainerMetadataScanner.scanContainer(Container<?> container)
Optional<Future<?>>	OnDemandContainerScanner.scanContainer(Container<?> container, String reasonForScan)	Triggers an on-demand scan of this container.
Optional<Future<?>>	OnDemandContainerScanner.scanContainerWithoutGap(Container<?> container, String reasonForScan)	Triggers an on-demand scan of this container regardless of whether it was recently scanned.
void	ContainerScanHelper.scanData(Container<?> container, org.apache.hadoop.hdfs.util.DataTransferThrottler throttler, org.apache.hadoop.hdfs.util.Canceler canceler)
void	ContainerScanHelper.scanMetadata(Container<?> container)
boolean	ContainerScanHelper.shouldScanData(Container<?> container)
boolean	ContainerScanHelper.shouldScanMetadata(Container<?> container)