org.apache.accumulo.server.tabletserver
Class TabletServer

java.lang.Object
  extended by org.apache.accumulo.server.metrics.AbstractMetricsImpl
      extended by org.apache.accumulo.server.tabletserver.TabletServer
All Implemented Interfaces:
TabletServerMBean

public class TabletServer
extends AbstractMetricsImpl
implements TabletServerMBean


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.accumulo.server.metrics.AbstractMetricsImpl
AbstractMetricsImpl.Metric
 
Field Summary
 Socket currentMaster
           
 long lastPingTime
           
protected  TabletServerMinCMetrics mincMetrics
           
 
Constructor Summary
TabletServer()
           
 
Method Summary
 void addLoggersToMetadata(List<RemoteLogger> logs, KeyExtent extent, int id)
           
 void config(String[] args)
           
 int createLogId(KeyExtent tablet)
           
 double getAverageFilesPerTablet()
           
 String getClientAddressString()
           
 long getEntries()
           
 long getEntriesInMemory()
           
 double getHoldTime()
           
 long getIngest()
           
 Set<String> getLoggers()
           
 int getMajorCompactions()
           
 int getMajorCompactionsQueued()
           
protected  String getMetricsPrefix()
           
 int getMinorCompactions()
           
 int getMinorCompactionsQueued()
           
 String getName()
           
protected  ObjectName getObjectName()
           
 int getOnlineCount()
           
 int getOpeningCount()
           
 long getQueries()
           
 TabletServerStatus getStats(Map<String,MapCounter<org.apache.accumulo.server.tabletserver.ScanRunState>> scanCounts)
           
 TabletStatsKeeper getStatsKeeper()
           
 long getTotalMinorCompactions()
           
 int getUnopenedCount()
           
static void main(String[] args)
           
 void minorCompactionFinished(Tablet.CommitSession tablet, String newDatafile, int walogSeq)
           
 void minorCompactionStarted(Tablet.CommitSession tablet, int lastUpdateSequence, String newMapfileLocation)
           
 void recover(Tablet tablet, List<MetadataTable.LogEntry> logEntries, Set<String> tabletFiles, MutationReceiver mutationReceiver)
           
 void run()
           
static SortedMap<KeyExtent,org.apache.hadoop.io.Text> verifyTabletInformation(KeyExtent extent, TServerInstance instance, SortedMap<Key,Value> tabletsKeyValues, String clientAddress, ZooLock lock)
           
 
Methods inherited from class org.apache.accumulo.server.metrics.AbstractMetricsImpl
add, createMetric, finalize, getMetric, getMetricAvg, getMetricCount, getMetricMax, getMetricMin, isEnabled, register, register
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

mincMetrics

protected TabletServerMinCMetrics mincMetrics

lastPingTime

public long lastPingTime

currentMaster

public Socket currentMaster
Constructor Detail

TabletServer

public TabletServer()
Method Detail

getStatsKeeper

public TabletStatsKeeper getStatsKeeper()

getLoggers

public Set<String> getLoggers()
                       throws org.apache.thrift.TException,
                              MasterNotRunningException,
                              ThriftSecurityException
Throws:
org.apache.thrift.TException
MasterNotRunningException
ThriftSecurityException

addLoggersToMetadata

public void addLoggersToMetadata(List<RemoteLogger> logs,
                                 KeyExtent extent,
                                 int id)

run

public void run()

verifyTabletInformation

public static SortedMap<KeyExtent,org.apache.hadoop.io.Text> verifyTabletInformation(KeyExtent extent,
                                                                                     TServerInstance instance,
                                                                                     SortedMap<Key,Value> tabletsKeyValues,
                                                                                     String clientAddress,
                                                                                     ZooLock lock)
                                                                              throws AccumuloSecurityException
Throws:
AccumuloSecurityException

getClientAddressString

public String getClientAddressString()

config

public void config(String[] args)
            throws UnknownHostException
Throws:
UnknownHostException

getStats

public TabletServerStatus getStats(Map<String,MapCounter<org.apache.accumulo.server.tabletserver.ScanRunState>> scanCounts)

main

public static void main(String[] args)
                 throws IOException
Throws:
IOException

minorCompactionFinished

public void minorCompactionFinished(Tablet.CommitSession tablet,
                                    String newDatafile,
                                    int walogSeq)
                             throws IOException
Throws:
IOException

minorCompactionStarted

public void minorCompactionStarted(Tablet.CommitSession tablet,
                                   int lastUpdateSequence,
                                   String newMapfileLocation)
                            throws IOException
Throws:
IOException

recover

public void recover(Tablet tablet,
                    List<MetadataTable.LogEntry> logEntries,
                    Set<String> tabletFiles,
                    MutationReceiver mutationReceiver)
             throws IOException
Throws:
IOException

createLogId

public int createLogId(KeyExtent tablet)

getEntries

public long getEntries()
Specified by:
getEntries in interface TabletServerMBean

getEntriesInMemory

public long getEntriesInMemory()
Specified by:
getEntriesInMemory in interface TabletServerMBean

getIngest

public long getIngest()
Specified by:
getIngest in interface TabletServerMBean

getMajorCompactions

public int getMajorCompactions()
Specified by:
getMajorCompactions in interface TabletServerMBean

getMajorCompactionsQueued

public int getMajorCompactionsQueued()
Specified by:
getMajorCompactionsQueued in interface TabletServerMBean

getMinorCompactions

public int getMinorCompactions()
Specified by:
getMinorCompactions in interface TabletServerMBean

getMinorCompactionsQueued

public int getMinorCompactionsQueued()
Specified by:
getMinorCompactionsQueued in interface TabletServerMBean

getOnlineCount

public int getOnlineCount()
Specified by:
getOnlineCount in interface TabletServerMBean

getOpeningCount

public int getOpeningCount()
Specified by:
getOpeningCount in interface TabletServerMBean

getQueries

public long getQueries()
Specified by:
getQueries in interface TabletServerMBean

getUnopenedCount

public int getUnopenedCount()
Specified by:
getUnopenedCount in interface TabletServerMBean

getName

public String getName()
Specified by:
getName in interface TabletServerMBean

getTotalMinorCompactions

public long getTotalMinorCompactions()
Specified by:
getTotalMinorCompactions in interface TabletServerMBean

getHoldTime

public double getHoldTime()
Specified by:
getHoldTime in interface TabletServerMBean

getAverageFilesPerTablet

public double getAverageFilesPerTablet()
Specified by:
getAverageFilesPerTablet in interface TabletServerMBean

getObjectName

protected ObjectName getObjectName()
Specified by:
getObjectName in class AbstractMetricsImpl

getMetricsPrefix

protected String getMetricsPrefix()
Specified by:
getMetricsPrefix in class AbstractMetricsImpl


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.