Package org.apache.hadoop.ozone.container.ozoneimpl

Class OzoneContainer

java.lang.Object

org.apache.hadoop.ozone.container.ozoneimpl.OzoneContainer

public class OzoneContainer
extends Object

Ozone main class sets up the network servers and initializes the container layer.

Constructor Summary

Constructors

Constructor	Description
OzoneContainer(org.apache.hadoop.hdds.protocol.DatanodeDetails datanodeDetails, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, VolumeChoosingPolicy volumeChoosingPolicy)	Shorthand constructor used for testing in non-secure context.
OzoneContainer(HddsDatanodeService hddsDatanodeService, org.apache.hadoop.hdds.protocol.DatanodeDetails datanodeDetails, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certClient, org.apache.hadoop.hdds.security.symmetric.SecretKeyVerifierClient secretKeyClient, VolumeChoosingPolicy volumeChoosingPolicy)	Construct OzoneContainer object.

Method Summary

Modifier and Type	Method	Description
void	buildContainerSet()	Build's container map after volume format.
void	compactDb()
Long	gatherContainerUsages(HddsVolume storageVolume)
BlockDeletingService	getBlockDeletingService()
ContainerSet	getContainerSet()
ContainerController	getController()
MutableVolumeSet	getDbVolumeSet()
ContainerDispatcher	getDispatcher()
MutableVolumeSet	getMetaVolumeSet()
ContainerMetrics	getMetrics()
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto	getNodeReport()	Returns node report of container storage usage.
OnDemandContainerScanner	getOnDemandScanner()
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto	getPipelineReport()	Returns container report.
XceiverServerSpi	getReadChannel()
ReplicationServer	getReplicationServer()
org.apache.ratis.grpc.GrpcTlsConfig	getTlsClientConfig()
MutableVolumeSet	getVolumeSet()
WitnessedContainerMetadataStore	getWitnessedContainerMetadataStore()
XceiverServerSpi	getWriteChannel()
void	handleVolumeFailures()
void	pauseContainerScrub()
void	resumeContainerScrub()
void	start(String clusterId)	Starts serving requests to ozone container.
void	stop()	Stop Container Service on the datanode.

Methods inherited from class java.lang.Object

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

Constructor Details

OzoneContainer

public OzoneContainer(HddsDatanodeService hddsDatanodeService,
 org.apache.hadoop.hdds.protocol.DatanodeDetails datanodeDetails,
 org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 StateContext context,
 org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certClient,
 org.apache.hadoop.hdds.security.symmetric.SecretKeyVerifierClient secretKeyClient,
 VolumeChoosingPolicy volumeChoosingPolicy)
               throws IOException

Construct OzoneContainer object.

Parameters:

datanodeDetails -

conf -

certClient -

Throws:

org.apache.hadoop.util.DiskChecker.DiskOutOfSpaceException

IOException

OzoneContainer

public OzoneContainer(org.apache.hadoop.hdds.protocol.DatanodeDetails datanodeDetails,
 org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 StateContext context,
 VolumeChoosingPolicy volumeChoosingPolicy)
               throws IOException

Shorthand constructor used for testing in non-secure context.

Throws:

IOException

Method Details

getTlsClientConfig

public org.apache.ratis.grpc.GrpcTlsConfig getTlsClientConfig()

buildContainerSet

public void buildContainerSet()
                       throws IOException

Build's container map after volume format.

Throws:

IOException

pauseContainerScrub

public void pauseContainerScrub()

resumeContainerScrub

public void resumeContainerScrub()

getOnDemandScanner

public OnDemandContainerScanner getOnDemandScanner()

start

public void start(String clusterId)
           throws IOException

Starts serving requests to ozone container.

Throws:

IOException

stop

public void stop()

Stop Container Service on the datanode.

handleVolumeFailures

public void handleVolumeFailures()
                          throws org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException

Throws:

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

getContainerSet

public ContainerSet getContainerSet()

gatherContainerUsages

public Long gatherContainerUsages(HddsVolume storageVolume)

getPipelineReport

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.PipelineReportsProto getPipelineReport()

Returns container report.

Returns:

- container report.

getWriteChannel

public XceiverServerSpi getWriteChannel()

getReadChannel

public XceiverServerSpi getReadChannel()

getController

public ContainerController getController()

getNodeReport

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.NodeReportProto getNodeReport()
                                                                                                           throws IOException

Returns node report of container storage usage.

Throws:

IOException

getDispatcher

public ContainerDispatcher getDispatcher()

getVolumeSet

public MutableVolumeSet getVolumeSet()

getMetaVolumeSet

public MutableVolumeSet getMetaVolumeSet()

getDbVolumeSet

public MutableVolumeSet getDbVolumeSet()

getMetrics

public ContainerMetrics getMetrics()

getBlockDeletingService

public BlockDeletingService getBlockDeletingService()

getReplicationServer

public ReplicationServer getReplicationServer()

compactDb

public void compactDb()

getWitnessedContainerMetadataStore

public WitnessedContainerMetadataStore getWitnessedContainerMetadataStore()