org.apache.accumulo.server.tabletserver
public class TabletServer extends AbstractMetricsImpl implements TabletServerMBean
AbstractMetricsImpl.Metric
Modifier and Type | Field and Description |
---|---|
Socket |
currentMaster |
long |
lastPingTime |
protected TabletServerMinCMetrics |
mincMetrics |
Constructor and Description |
---|
TabletServer(ServerConfiguration conf,
org.apache.hadoop.fs.FileSystem fs) |
add, createMetric, finalize, getMetric, getMetricAvg, getMetricCount, getMetricMax, getMetricMin, isEnabled, register, register
protected TabletServerMinCMetrics mincMetrics
public long lastPingTime
public Socket currentMaster
public TabletServer(ServerConfiguration conf, org.apache.hadoop.fs.FileSystem fs)
public AccumuloConfiguration getSystemConfiguration()
public TabletStatsKeeper getStatsKeeper()
public void addLoggersToMetadata(List<DfsLogger> logs, KeyExtent extent, int id)
public void run()
public static Pair<org.apache.hadoop.io.Text,KeyExtent> verifyTabletInformation(KeyExtent extent, TServerInstance instance, SortedMap<Key,Value> tabletsKeyValues, String clientAddress, ZooLock lock) throws AccumuloSecurityException, DistributedStoreException, AccumuloException
public String getClientAddressString()
public void config(String hostname)
public TabletServerStatus getStats(Map<String,MapCounter<org.apache.accumulo.server.tabletserver.ScanRunState>> scanCounts)
public static void main(String[] args) throws IOException
IOException
protected static void ensureHdfsSyncIsEnabled(org.apache.hadoop.fs.FileSystem fs)
public static void recoverLocalWriteAheadLogs(org.apache.hadoop.fs.FileSystem fs, ServerConfiguration serverConf) throws IOException
IOException
public void minorCompactionFinished(Tablet.CommitSession tablet, String newDatafile, int walogSeq) throws IOException
IOException
public void minorCompactionStarted(Tablet.CommitSession tablet, int lastUpdateSequence, String newMapfileLocation) throws IOException
IOException
public void recover(Tablet tablet, List<MetadataTable.LogEntry> logEntries, Set<String> tabletFiles, MutationReceiver mutationReceiver) throws IOException
IOException
public int createLogId(KeyExtent tablet)
public long getEntries()
getEntries
in interface TabletServerMBean
public long getEntriesInMemory()
getEntriesInMemory
in interface TabletServerMBean
public long getIngest()
getIngest
in interface TabletServerMBean
public int getMajorCompactions()
getMajorCompactions
in interface TabletServerMBean
public int getMajorCompactionsQueued()
getMajorCompactionsQueued
in interface TabletServerMBean
public int getMinorCompactions()
getMinorCompactions
in interface TabletServerMBean
public int getMinorCompactionsQueued()
getMinorCompactionsQueued
in interface TabletServerMBean
public int getOnlineCount()
getOnlineCount
in interface TabletServerMBean
public int getOpeningCount()
getOpeningCount
in interface TabletServerMBean
public long getQueries()
getQueries
in interface TabletServerMBean
public int getUnopenedCount()
getUnopenedCount
in interface TabletServerMBean
public String getName()
getName
in interface TabletServerMBean
public long getTotalMinorCompactions()
getTotalMinorCompactions
in interface TabletServerMBean
public double getHoldTime()
getHoldTime
in interface TabletServerMBean
public double getAverageFilesPerTablet()
getAverageFilesPerTablet
in interface TabletServerMBean
protected ObjectName getObjectName()
getObjectName
in class AbstractMetricsImpl
protected String getMetricsPrefix()
getMetricsPrefix
in class AbstractMetricsImpl
public TableConfiguration getTableConfiguration(KeyExtent extent)
public DfsLogger.ServerResources getServerConfig()
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.