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

java.lang.Object
  extended by org.apache.accumulo.server.tabletserver.log.DfsLogger

public class DfsLogger
extends Object

Wrap a connection to a logger.


Nested Class Summary
static class DfsLogger.LogClosedException
           
static class DfsLogger.LoggerOperation
           
static interface DfsLogger.ServerResources
           
 
Constructor Summary
DfsLogger(DfsLogger.ServerResources conf)
           
DfsLogger(DfsLogger.ServerResources conf, String logger, String filename)
           
 
Method Summary
 void close()
           
 void defineTablet(int seq, int tid, KeyExtent tablet)
           
 boolean equals(Object obj)
           
 String getFileName()
           
 String getLogger()
           
 int hashCode()
           
 DfsLogger.LoggerOperation log(int seq, int tid, Mutation mutation)
           
 DfsLogger.LoggerOperation logManyTablets(List<TabletMutations> mutations)
           
 void minorCompactionFinished(int seq, int tid, String fqfn)
           
 void minorCompactionStarted(int seq, int tid, String fqfn)
           
 void open(String address)
           
static org.apache.hadoop.fs.FSDataInputStream readHeader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, Map<String,String> opts)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

DfsLogger

public DfsLogger(DfsLogger.ServerResources conf)
          throws IOException
Throws:
IOException

DfsLogger

public DfsLogger(DfsLogger.ServerResources conf,
                 String logger,
                 String filename)
          throws IOException
Throws:
IOException
Method Detail

equals

public boolean equals(Object obj)
Overrides:
equals in class Object

hashCode

public int hashCode()
Overrides:
hashCode in class Object

readHeader

public static org.apache.hadoop.fs.FSDataInputStream readHeader(org.apache.hadoop.fs.FileSystem fs,
                                                                org.apache.hadoop.fs.Path path,
                                                                Map<String,String> opts)
                                                         throws IOException
Throws:
IOException

open

public void open(String address)
          throws IOException
Throws:
IOException

toString

public String toString()
Overrides:
toString in class Object

getLogger

public String getLogger()

getFileName

public String getFileName()

close

public void close()
           throws IOException
Throws:
IOException

defineTablet

public void defineTablet(int seq,
                         int tid,
                         KeyExtent tablet)
                  throws IOException
Throws:
IOException

log

public DfsLogger.LoggerOperation log(int seq,
                                     int tid,
                                     Mutation mutation)
                              throws IOException
Throws:
IOException

logManyTablets

public DfsLogger.LoggerOperation logManyTablets(List<TabletMutations> mutations)
                                         throws IOException
Throws:
IOException

minorCompactionFinished

public void minorCompactionFinished(int seq,
                                    int tid,
                                    String fqfn)
                             throws IOException
Throws:
IOException

minorCompactionStarted

public void minorCompactionStarted(int seq,
                                   int tid,
                                   String fqfn)
                            throws IOException
Throws:
IOException


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.