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

Class DatanodeStoreSchemaTwoImpl

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

org.apache.hadoop.ozone.container.metadata.DatanodeStoreSchemaTwoImpl

All Implemented Interfaces:

AutoCloseable, DatanodeStore, DBStoreManager, DeleteTransactionStore<Long>, org.apache.ratis.util.UncheckedAutoCloseable

public class DatanodeStoreSchemaTwoImpl
extends DatanodeStoreWithIncrementalChunkList
implements DeleteTransactionStore<Long>

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
DatanodeStoreSchemaTwoImpl(org.apache.hadoop.hdds.conf.ConfigurationSource config, String dbPath, boolean openReadOnly)	Constructs the datanode store and starts the DB Services.

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hdds.utils.db.Table<Long,org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.DeletedBlocksTransaction>	getDeleteTransactionTable()

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

getCompleteBlockData, putBlockByID

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

DatanodeStoreSchemaTwoImpl

public DatanodeStoreSchemaTwoImpl(org.apache.hadoop.hdds.conf.ConfigurationSource config,
 String dbPath,
 boolean openReadOnly)
                           throws IOException

Constructs the datanode store and starts the DB Services.

Parameters:

config - - Ozone Configuration.

Throws:

IOException - - on Failure.

Method Details

getDeleteTransactionTable

public org.apache.hadoop.hdds.utils.db.Table<Long,org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.DeletedBlocksTransaction> getDeleteTransactionTable()

Specified by:

getDeleteTransactionTable in interface DeleteTransactionStore<Long>