org.apache.accumulo.server.tabletserver.log
Class TabletServerLogger
java.lang.Object
org.apache.accumulo.server.tabletserver.log.TabletServerLogger
public class TabletServerLogger
- extends Object
Central logging facility for the TServerInfo.
Forwards in-memory updates to remote logs, carefully writing the same data to every log, while maintaining the maximum thread parallelism for greater
performance. As new logs are used and minor compactions are performed, the metadata table is kept up-to-date.
Method Summary |
int |
defineTablet(Tablet.CommitSession commitSession)
|
void |
getLoggers(Set<String> loggersOut)
|
int |
log(Tablet.CommitSession commitSession,
int tabletSeq,
Mutation m)
|
int |
logManyTablets(Map<Tablet.CommitSession,List<Mutation>> mutations)
|
void |
minorCompactionFinished(Tablet.CommitSession commitSession,
String fullyQualifiedFileName,
int walogSeq)
|
int |
minorCompactionStarted(Tablet.CommitSession commitSession,
int seq,
String fullyQualifiedFileName)
|
void |
recover(Tablet tablet,
List<String> logs,
Set<String> tabletFiles,
MutationReceiver mr)
|
void |
resetLoggers()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TabletServerLogger
public TabletServerLogger(TabletServer tserver,
long maxSize)
getLoggers
public void getLoggers(Set<String> loggersOut)
resetLoggers
public void resetLoggers()
throws IOException
- Throws:
IOException
defineTablet
public int defineTablet(Tablet.CommitSession commitSession)
throws IOException
- Throws:
IOException
log
public int log(Tablet.CommitSession commitSession,
int tabletSeq,
Mutation m)
throws IOException
- Throws:
IOException
logManyTablets
public int logManyTablets(Map<Tablet.CommitSession,List<Mutation>> mutations)
throws IOException
- Throws:
IOException
minorCompactionFinished
public void minorCompactionFinished(Tablet.CommitSession commitSession,
String fullyQualifiedFileName,
int walogSeq)
throws IOException
- Throws:
IOException
minorCompactionStarted
public int minorCompactionStarted(Tablet.CommitSession commitSession,
int seq,
String fullyQualifiedFileName)
throws IOException
- Throws:
IOException
recover
public void recover(Tablet tablet,
List<String> logs,
Set<String> tabletFiles,
MutationReceiver mr)
throws IOException
- Throws:
IOException
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.