org.apache.accumulo.server.tabletserver.log
Class DfsLogger
java.lang.Object
org.apache.accumulo.server.tabletserver.log.DfsLogger
public class DfsLogger
- extends Object
Wrap a connection to a logger.
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()
|
DfsLogger
public DfsLogger(DfsLogger.ServerResources conf)
throws IOException
- Throws:
IOException
DfsLogger
public DfsLogger(DfsLogger.ServerResources conf,
String logger,
String filename)
throws IOException
- Throws:
IOException
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.