org.apache.accumulo.server.tabletserver.log
Class TabletServerLogger

java.lang.Object
  extended by 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.


Constructor Summary
TabletServerLogger(TabletServer tserver, long maxSize)
           
 
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
 

Constructor Detail

TabletServerLogger

public TabletServerLogger(TabletServer tserver,
                          long maxSize)
Method Detail

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 © 2012 The Apache Software Foundation. All Rights Reserved.