org.apache.accumulo.server.tabletserver.log
public class DfsLogger extends Object
Modifier and Type | Class and Description |
---|---|
static class |
DfsLogger.LogClosedException |
static class |
DfsLogger.LoggerOperation |
static interface |
DfsLogger.ServerResources |
Constructor and Description |
---|
DfsLogger(DfsLogger.ServerResources conf) |
DfsLogger(DfsLogger.ServerResources conf,
String logger,
String filename) |
Modifier and Type | Method and Description |
---|---|
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) |
DfsLogger.LoggerOperation |
minorCompactionFinished(int seq,
int tid,
String fqfn) |
DfsLogger.LoggerOperation |
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() |
public DfsLogger(DfsLogger.ServerResources conf) throws IOException
IOException
public DfsLogger(DfsLogger.ServerResources conf, String logger, String filename) throws IOException
IOException
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
IOException
public void open(String address) throws IOException
IOException
public String getLogger()
public String getFileName()
public void close() throws IOException
IOException
public void defineTablet(int seq, int tid, KeyExtent tablet) throws IOException
IOException
public DfsLogger.LoggerOperation log(int seq, int tid, Mutation mutation) throws IOException
IOException
public DfsLogger.LoggerOperation logManyTablets(List<TabletMutations> mutations) throws IOException
IOException
public DfsLogger.LoggerOperation minorCompactionFinished(int seq, int tid, String fqfn) throws IOException
IOException
public DfsLogger.LoggerOperation minorCompactionStarted(int seq, int tid, String fqfn) throws IOException
IOException
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.