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<DfsLogger> logs,
KeyExtent extent,
int id)
|
void |
config(String hostname)
|
int |
createLogId(KeyExtent tablet)
|
double |
getAverageFilesPerTablet()
|
String |
getClientAddressString()
|
long |
getEntries()
|
long |
getEntriesInMemory()
|
double |
getHoldTime()
|
long |
getIngest()
|
int |
getMajorCompactions()
|
int |
getMajorCompactionsQueued()
|
protected String |
getMetricsPrefix()
|
int |
getMinorCompactions()
|
int |
getMinorCompactionsQueued()
|
String |
getName()
|
protected ObjectName |
getObjectName()
|
int |
getOnlineCount()
|
int |
getOpeningCount()
|
long |
getQueries()
|
DfsLogger.ServerResources |
getServerConfig()
|
TabletServerStatus |
getStats(Map<String,MapCounter<org.apache.accumulo.server.tabletserver.ScanRunState>> scanCounts)
|
TabletStatsKeeper |
getStatsKeeper()
|
AccumuloConfiguration |
getSystemConfiguration()
|
TableConfiguration |
getTableConfiguration(KeyExtent extent)
|
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)
|
static void |
recoverLocalWriteAheadLogs(org.apache.hadoop.fs.FileSystem fs,
ServerConfiguration serverConf)
Copy local walogs into HDFS on an upgrade |
void |
run()
|
static Pair<org.apache.hadoop.io.Text,KeyExtent> |
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(ServerConfiguration conf,
org.apache.hadoop.fs.FileSystem fs)
getSystemConfiguration
public AccumuloConfiguration getSystemConfiguration()
getStatsKeeper
public TabletStatsKeeper getStatsKeeper()
addLoggersToMetadata
public void addLoggersToMetadata(List<DfsLogger> logs,
KeyExtent extent,
int id)
run
public void run()
verifyTabletInformation
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
- Throws:
AccumuloSecurityException
DistributedStoreException
AccumuloException
getClientAddressString
public String getClientAddressString()
config
public void config(String hostname)
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
recoverLocalWriteAheadLogs
public static void recoverLocalWriteAheadLogs(org.apache.hadoop.fs.FileSystem fs,
ServerConfiguration serverConf)
throws IOException
- Copy local walogs into HDFS on an upgrade
- 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
getTableConfiguration
public TableConfiguration getTableConfiguration(KeyExtent extent)
getServerConfig
public DfsLogger.ServerResources getServerConfig()
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.