Package org.apache.solr.hdfs.store

Class HdfsLocalityReporter

java.lang.Object

org.apache.solr.hdfs.store.HdfsLocalityReporter

All Implemented Interfaces:

AutoCloseable, SolrInfoBean, SolrMetricProducer

public class HdfsLocalityReporter
extends Object
implements SolrInfoBean

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.core.SolrInfoBean

SolrInfoBean.Category, SolrInfoBean.Group

Field Summary

Fields

Modifier and Type	Field	Description
static String	LOCALITY_BLOCKS_LOCAL
static String	LOCALITY_BLOCKS_RATIO
static String	LOCALITY_BLOCKS_TOTAL
static String	LOCALITY_BYTES_LOCAL
static String	LOCALITY_BYTES_RATIO
static String	LOCALITY_BYTES_TOTAL

Constructor Summary

Constructors

Constructor	Description
HdfsLocalityReporter()

Method Summary

Modifier and Type	Method	Description
SolrInfoBean.Category	getCategory()
String	getDescription()
String	getName()
SolrMetricsContext	getSolrMetricsContext()
void	initializeMetrics(SolrMetricsContext parentContext, String scope)	Provide statistics on HDFS block locality, both in terms of bytes and block counts.
void	registerDirectory(HdfsDirectory dir)	Add a directory for block locality reporting.
void	setHost(String hostname)	Set the host name to use when determining locality

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.solr.metrics.SolrMetricProducer

close

Field Detail

LOCALITY_BYTES_TOTAL

public static final String LOCALITY_BYTES_TOTAL

See Also:

Constant Field Values

LOCALITY_BYTES_LOCAL

public static final String LOCALITY_BYTES_LOCAL

See Also:

Constant Field Values

LOCALITY_BYTES_RATIO

public static final String LOCALITY_BYTES_RATIO

See Also:

Constant Field Values

LOCALITY_BLOCKS_TOTAL

public static final String LOCALITY_BLOCKS_TOTAL

See Also:

Constant Field Values

LOCALITY_BLOCKS_LOCAL

public static final String LOCALITY_BLOCKS_LOCAL

See Also:

Constant Field Values

LOCALITY_BLOCKS_RATIO

public static final String LOCALITY_BLOCKS_RATIO

See Also:

Constant Field Values

Constructor Detail

HdfsLocalityReporter

public HdfsLocalityReporter()

Method Detail

setHost

public void setHost(String hostname)

Set the host name to use when determining locality

Parameters:

hostname - The name of this host; should correspond to what HDFS Data Nodes think this is.

getName

public String getName()

Specified by:

getName in interface SolrInfoBean

getDescription

public String getDescription()

Specified by:

getDescription in interface SolrInfoBean

getCategory

public SolrInfoBean.Category getCategory()

Specified by:

getCategory in interface SolrInfoBean

getSolrMetricsContext

public SolrMetricsContext getSolrMetricsContext()

Specified by:

getSolrMetricsContext in interface SolrMetricProducer

initializeMetrics

public void initializeMetrics(SolrMetricsContext parentContext,
                              String scope)

Provide statistics on HDFS block locality, both in terms of bytes and block counts.

Specified by:

initializeMetrics in interface SolrMetricProducer

registerDirectory

public void registerDirectory(HdfsDirectory dir)

Add a directory for block locality reporting. This directory will continue to be checked until its close method has been called.

Parameters:

dir - The directory to keep metrics on.