org.apache.accumulo.server.tabletserver
Class TabletServer
java.lang.Object
org.apache.accumulo.server.metrics.AbstractMetricsImpl
org.apache.accumulo.server.tabletserver.TabletServer
- All Implemented Interfaces:
- TabletServerMBean
public class TabletServer
- extends AbstractMetricsImpl
- implements TabletServerMBean
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 |
mincMetrics
protected TabletServerMinCMetrics mincMetrics
lastPingTime
public long lastPingTime
currentMaster
public Socket currentMaster
TabletServer
public TabletServer()
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.