Package org.apache.hadoop.ozone.container.metadata

Class DatanodeStoreWithIncrementalChunkList

java.lang.Object

org.apache.hadoop.ozone.container.metadata.AbstractRDBStore<AbstractDatanodeDBDefinition>

org.apache.hadoop.ozone.container.metadata.AbstractDatanodeStore

org.apache.hadoop.ozone.container.metadata.DatanodeStoreWithIncrementalChunkList

All Implemented Interfaces:

AutoCloseable, DatanodeStore, DBStoreManager, org.apache.ratis.util.UncheckedAutoCloseable

Direct Known Subclasses:

DatanodeStoreSchemaThreeImpl, DatanodeStoreSchemaTwoImpl

public class DatanodeStoreWithIncrementalChunkList
extends AbstractDatanodeStore

Constructs a datanode store in accordance with schema version 2, which uses three column families/tables: 1. A block data table. 2. A metadata table. 3. A Delete Transaction Table.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.ozone.container.metadata.AbstractDatanodeStore

AbstractDatanodeStore.KeyValueBlockIterator, AbstractDatanodeStore.KeyValueBlockLocalIdIterator

Field Summary

Fields inherited from class org.apache.hadoop.ozone.container.metadata.AbstractDatanodeStore

LOG

Fields inherited from interface org.apache.hadoop.ozone.container.metadata.DatanodeStore

NO_SUCH_BLOCK_ERR_MSG

Constructor Summary

Constructors

Constructor	Description
DatanodeStoreWithIncrementalChunkList(org.apache.hadoop.hdds.conf.ConfigurationSource config, AbstractDatanodeDBDefinition dbDef, boolean openReadOnly)	Constructs the metadata store and starts the DB services.

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.ozone.container.common.helpers.BlockData	getCompleteBlockData(org.apache.hadoop.ozone.container.common.helpers.BlockData blockData, org.apache.hadoop.hdds.client.BlockID blockID, String blockKey)
void	putBlockByID(org.apache.hadoop.hdds.utils.db.BatchOperation batch, boolean incremental, long localID, org.apache.hadoop.ozone.container.common.helpers.BlockData data, KeyValueContainerData containerData, boolean endOfBlock)

Methods inherited from class org.apache.hadoop.ozone.container.metadata.AbstractDatanodeStore

getBlockDataTable, getBlockDataTableWithIterator, getBlockIterator, getBlockIterator, getDeletedBlocksTable, getFinalizeBlockIterator, getFinalizeBlocksTable, getFinalizeBlocksTableWithIterator, getLastChunkInfoTable, getMetadataTable, initDBStore

Methods inherited from class org.apache.hadoop.ozone.container.metadata.AbstractRDBStore

close, compactDB, flushDB, flushLog, getBatchHandler, getDbDef, getDbProfile, getStore, isClosed, stop

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.metadata.DatanodeStore

getBlockByID

Methods inherited from interface org.apache.hadoop.ozone.container.metadata.DBStoreManager

compactDB, compactionIfNeeded, flushDB, flushLog, getBatchHandler, getStore, isClosed, stop

Methods inherited from interface org.apache.ratis.util.UncheckedAutoCloseable

close

Constructor Details

DatanodeStoreWithIncrementalChunkList

public DatanodeStoreWithIncrementalChunkList(org.apache.hadoop.hdds.conf.ConfigurationSource config,
 AbstractDatanodeDBDefinition dbDef,
 boolean openReadOnly)
                                      throws IOException

Constructs the metadata store and starts the DB services.

Parameters:

config - - Ozone Configuration.

Throws:

IOException - - on Failure.

Method Details

getCompleteBlockData

public org.apache.hadoop.ozone.container.common.helpers.BlockData getCompleteBlockData(org.apache.hadoop.ozone.container.common.helpers.BlockData blockData,
 org.apache.hadoop.hdds.client.BlockID blockID,
 String blockKey)
                                                                                throws IOException

Throws:

IOException

putBlockByID

public void putBlockByID(org.apache.hadoop.hdds.utils.db.BatchOperation batch,
 boolean incremental,
 long localID,
 org.apache.hadoop.ozone.container.common.helpers.BlockData data,
 KeyValueContainerData containerData,
 boolean endOfBlock)
                  throws IOException

Throws:

IOException