Modifier and Type | Field and Description |
---|---|
private java.lang.String |
current |
private static int |
EcoFSBufferSize |
private Order<Row.Entry> |
entryOrder |
private boolean |
exceed134217727 |
private long |
fileAgeLimit |
private long |
fileSizeLimit |
private java.io.File |
path |
private java.lang.String |
prefix |
private Row |
rowdef |
private java.util.Map<java.lang.String,Index> |
tables |
private boolean |
useTailCache |
Modifier | Constructor and Description |
---|---|
|
SplitTable(java.io.File path,
java.lang.String tablename,
Row rowdef,
boolean useTailCache,
boolean exceed134217727) |
private |
SplitTable(java.io.File path,
java.lang.String tablename,
Row rowdef,
long fileAgeLimit,
long fileSizeLimit,
boolean useTailCache,
boolean exceed134217727) |
Modifier and Type | Method and Description |
---|---|
void |
addUnique(Row.Entry row) |
private Index |
checkTable(Index table) |
void |
clear() |
void |
close() |
boolean |
delete(byte[] key) |
static void |
delete(java.io.File path,
java.lang.String tablename) |
void |
deleteOnExit() |
java.lang.String |
filename() |
Row.Entry |
get(byte[] key,
boolean forcecopy) |
java.util.Map<byte[],Row.Entry> |
get(java.util.Collection<byte[]> keys,
boolean forcecopy) |
boolean |
has(byte[] key) |
private void |
init() |
boolean |
isEmpty() |
java.util.Iterator<Row.Entry> |
iterator() |
private Index |
keeperOf(byte[] key) |
CloneableIterator<byte[]> |
keys(boolean up,
byte[] firstKey) |
byte[] |
largestKey() |
long |
mem() |
private java.lang.String |
newFilename() |
private Index |
newTable() |
void |
optimize() |
boolean |
put(Row.Entry row)
Adds the row to the index.
|
java.util.List<Row.Entry> |
random(int count) |
Row.Entry |
remove(byte[] key) |
java.util.List<RowCollection> |
removeDoubles() |
Row.Entry |
removeOne() |
Row.Entry |
replace(Row.Entry row) |
Row |
row() |
CloneableIterator<Row.Entry> |
rows() |
CloneableIterator<Row.Entry> |
rows(boolean up,
byte[] firstKey) |
int |
size() |
byte[] |
smallestKey() |
java.util.List<Row.Entry> |
top(int count) |
int |
writeBufferSize() |
private static final int EcoFSBufferSize
private java.util.Map<java.lang.String,Index> tables
private final Row rowdef
private final java.io.File path
private final java.lang.String prefix
private java.lang.String current
private final long fileAgeLimit
private final long fileSizeLimit
private final boolean useTailCache
private final boolean exceed134217727
public SplitTable(java.io.File path, java.lang.String tablename, Row rowdef, boolean useTailCache, boolean exceed134217727)
private SplitTable(java.io.File path, java.lang.String tablename, Row rowdef, long fileAgeLimit, long fileSizeLimit, boolean useTailCache, boolean exceed134217727)
public final byte[] smallestKey()
smallestKey
in interface Index
public final byte[] largestKey()
largestKey
in interface Index
private java.lang.String newFilename()
private void init()
public void clear() throws java.io.IOException
public static void delete(java.io.File path, java.lang.String tablename)
public int writeBufferSize()
public Row.Entry get(byte[] key, boolean forcecopy) throws java.io.IOException
public java.util.Map<byte[],Row.Entry> get(java.util.Collection<byte[]> keys, boolean forcecopy) throws java.io.IOException, java.lang.InterruptedException
private Index newTable()
public Row.Entry replace(Row.Entry row) throws java.io.IOException, SpaceExceededException
replace
in interface Index
java.io.IOException
SpaceExceededException
public boolean put(Row.Entry row) throws java.io.IOException, SpaceExceededException
put
in interface Index
row
- a index rowjava.io.IOException
SpaceExceededException
private Index keeperOf(byte[] key)
public void addUnique(Row.Entry row) throws java.io.IOException, SpaceExceededException
addUnique
in interface Index
java.io.IOException
SpaceExceededException
public java.util.List<RowCollection> removeDoubles() throws java.io.IOException, SpaceExceededException
removeDoubles
in interface Index
java.io.IOException
SpaceExceededException
public boolean delete(byte[] key) throws java.io.IOException
public Row.Entry remove(byte[] key) throws java.io.IOException
public Row.Entry removeOne() throws java.io.IOException
public java.util.List<Row.Entry> top(int count) throws java.io.IOException
public java.util.List<Row.Entry> random(int count) throws java.io.IOException
public CloneableIterator<byte[]> keys(boolean up, byte[] firstKey) throws java.io.IOException
public CloneableIterator<Row.Entry> rows(boolean up, byte[] firstKey) throws java.io.IOException
public java.util.Iterator<Row.Entry> iterator()
public CloneableIterator<Row.Entry> rows() throws java.io.IOException
public void deleteOnExit()
deleteOnExit
in interface Index