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

Class ContainerScanHelper

java.lang.Object

org.apache.hadoop.ozone.container.ozoneimpl.ContainerScanHelper

public final class ContainerScanHelper
extends Object

Mixin to handle common data and metadata scan operations among background and on-demand scanners.

Method Summary

Modifier and Type	Method	Description
void	handleUnhealthyScanResult(ContainerData containerData, ScanResult result)
void	scanData(Container<?> container, org.apache.hadoop.hdfs.util.DataTransferThrottler throttler, org.apache.hadoop.hdfs.util.Canceler canceler)
void	scanMetadata(Container<?> container)
boolean	shouldScanData(Container<?> container)
boolean	shouldScanMetadata(Container<?> container)
void	triggerVolumeScan(ContainerData containerData)
static ContainerScanHelper	withoutScanGap(org.slf4j.Logger log, ContainerController controller, AbstractContainerScannerMetrics metrics)
static ContainerScanHelper	withScanGap(org.slf4j.Logger log, ContainerController controller, AbstractContainerScannerMetrics metrics, ContainerScannerConfiguration conf)

Methods inherited from class java.lang.Object

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

Method Details

withoutScanGap

public static ContainerScanHelper withoutScanGap(org.slf4j.Logger log,
 ContainerController controller,
 AbstractContainerScannerMetrics metrics)

withScanGap

public static ContainerScanHelper withScanGap(org.slf4j.Logger log,
 ContainerController controller,
 AbstractContainerScannerMetrics metrics,
 ContainerScannerConfiguration conf)

scanData

public void scanData(Container<?> container,
 org.apache.hadoop.hdfs.util.DataTransferThrottler throttler,
 org.apache.hadoop.hdfs.util.Canceler canceler)
              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

scanMetadata

public void scanMetadata(Container<?> container)
                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

handleUnhealthyScanResult

public void handleUnhealthyScanResult(ContainerData containerData,
 ScanResult result)
                               throws IOException

Throws:

IOException

triggerVolumeScan

public void triggerVolumeScan(ContainerData containerData)

shouldScanMetadata

public boolean shouldScanMetadata(Container<?> container)

shouldScanData

public boolean shouldScanData(Container<?> container)