|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.accumulo.server.tabletserver.Tablet
public class Tablet
this class just provides an interface to read from a MapFile mostly takes care of reporting start and end keys need this because a single row extent can have multiple columns this manages all the columns (each handled by a store) for a single row-extent
Nested Class Summary | |
---|---|
class |
Tablet.CommitSession
|
static class |
Tablet.KVEntry
|
static interface |
Tablet.KVReceiver
|
static class |
Tablet.TabletClosedException
|
Field Summary | |
---|---|
Object |
bulkFileImportLock
|
TabletStatsKeeper |
timer
|
Constructor Summary | |
---|---|
Tablet(TabletServer tabletServer,
org.apache.hadoop.io.Text location,
KeyExtent extent,
TabletServerResourceManager.TabletResourceManager trm,
SortedMap<Key,Value> tabletsKeyValues)
|
|
Tablet(TabletServer tabletServer,
org.apache.hadoop.io.Text location,
KeyExtent extent,
TabletServerResourceManager.TabletResourceManager trm,
SortedMap<String,MetadataTable.DataFileValue> datafiles,
String time,
long initFlushID,
long initCompactID)
|
Method Summary | |
---|---|
void |
abortCommit(Tablet.CommitSession commitSession,
List<Mutation> value)
|
void |
chopFiles()
|
void |
close(boolean saveState)
Closes the mapfiles associated with a Tablet. |
void |
commit(Tablet.CommitSession commitSession,
List<Mutation> mutations)
|
void |
compactAll(long compactionId)
|
long |
estimateTabletSize()
Returns an int representing the total block size of the mapfiles served by this tablet. |
SortedMap<String,MetadataTable.DataFileValue> |
getDatafiles()
|
KeyExtent |
getExtent()
Returns a KeyExtent object representing this tablet's key range. |
org.apache.hadoop.fs.Path |
getLocation()
Returns a Path object representing the tablet's location on the DFS. |
int |
getLogCount()
|
int |
getLogId()
|
long |
getNumEntries()
|
long |
getNumEntriesInMemory()
|
long |
getSplitCreationTime()
|
void |
importMapFiles(long tid,
Map<String,MapFileInfo> fileMap,
boolean setTime)
|
double |
ingestByteRate()
|
double |
ingestRate()
|
boolean |
isCloseComplete()
|
boolean |
isClosed()
|
boolean |
isClosing()
|
boolean |
isMetadataTablet()
|
org.apache.accumulo.server.tabletserver.Tablet.LookupResult |
lookup(List<Range> ranges,
HashSet<Column> columns,
Authorizations authorizations,
ArrayList<Tablet.KVEntry> results,
long maxResultSize,
List<IterInfo> ssiList,
Map<String,Map<String,String>> ssio,
AtomicBoolean interruptFlag)
|
boolean |
majorCompactionQueued()
|
boolean |
majorCompactionRunning()
|
boolean |
minorCompactionQueued()
|
boolean |
minorCompactionRunning()
|
boolean |
needsMajorCompaction(org.apache.accumulo.server.tabletserver.Tablet.MajorCompactionReason reason)
Returns true if a major compaction should be performed on the tablet. |
boolean |
needsSplit()
Returns true if this tablet needs to be split |
Tablet.CommitSession |
prepareMutationsForCommit(org.apache.accumulo.server.tabletserver.TabletServer.TservConstraintEnv cenv,
List<Mutation> mutations)
|
double |
queryByteRate()
|
double |
queryRate()
|
TreeMap<KeyExtent,org.apache.accumulo.server.tabletserver.Tablet.SplitInfo> |
split(byte[] sp)
|
long |
totalIngest()
|
long |
totalQueries()
|
void |
updateRates(long now)
|
void |
waitForMinC()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public TabletStatsKeeper timer
public Object bulkFileImportLock
Constructor Detail |
---|
public Tablet(TabletServer tabletServer, org.apache.hadoop.io.Text location, KeyExtent extent, TabletServerResourceManager.TabletResourceManager trm, SortedMap<Key,Value> tabletsKeyValues) throws IOException
IOException
public Tablet(TabletServer tabletServer, org.apache.hadoop.io.Text location, KeyExtent extent, TabletServerResourceManager.TabletResourceManager trm, SortedMap<String,MetadataTable.DataFileValue> datafiles, String time, long initFlushID, long initCompactID) throws IOException
IOException
Method Detail |
---|
public int getLogId()
public boolean isMetadataTablet()
public org.apache.accumulo.server.tabletserver.Tablet.LookupResult lookup(List<Range> ranges, HashSet<Column> columns, Authorizations authorizations, ArrayList<Tablet.KVEntry> results, long maxResultSize, List<IterInfo> ssiList, Map<String,Map<String,String>> ssio, AtomicBoolean interruptFlag) throws IOException
IOException
public void waitForMinC()
public Tablet.CommitSession prepareMutationsForCommit(org.apache.accumulo.server.tabletserver.TabletServer.TservConstraintEnv cenv, List<Mutation> mutations) throws org.apache.accumulo.server.tabletserver.Tablet.TConstraintViolationException
org.apache.accumulo.server.tabletserver.Tablet.TConstraintViolationException
public void abortCommit(Tablet.CommitSession commitSession, List<Mutation> value)
public void commit(Tablet.CommitSession commitSession, List<Mutation> mutations)
public void close(boolean saveState) throws IOException
IOException
public org.apache.hadoop.fs.Path getLocation()
public boolean needsMajorCompaction(org.apache.accumulo.server.tabletserver.Tablet.MajorCompactionReason reason)
public long estimateTabletSize()
public boolean needsSplit()
public KeyExtent getExtent()
public long getNumEntries()
public long getNumEntriesInMemory()
public boolean isClosing()
public boolean isClosed()
public boolean isCloseComplete()
public boolean majorCompactionRunning()
public boolean minorCompactionQueued()
public boolean minorCompactionRunning()
public boolean majorCompactionQueued()
public TreeMap<KeyExtent,org.apache.accumulo.server.tabletserver.Tablet.SplitInfo> split(byte[] sp) throws IOException
IOException
public SortedMap<String,MetadataTable.DataFileValue> getDatafiles()
public double queryRate()
public double queryByteRate()
public double ingestRate()
public double ingestByteRate()
public long totalQueries()
public long totalIngest()
public void updateRates(long now)
public long getSplitCreationTime()
public void importMapFiles(long tid, Map<String,MapFileInfo> fileMap, boolean setTime) throws IOException
IOException
public int getLogCount()
public void chopFiles()
public void compactAll(long compactionId)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |