co.cask.cdap.data2.dataset2.lib.table.leveldb

Class LevelDBTableCore

java.lang.Object

co.cask.cdap.data2.dataset2.lib.table.leveldb.LevelDBTableCore

public class LevelDBTableCore
extends Object

Provides common operations for levelDB tables and queues.

Field Summary

Fields

Modifier and Type	Field and Description
protected static byte[]	DELETE_MARKER

Constructor Summary

Constructors

Constructor and Description
LevelDBTableCore(String tableName, LevelDBTableService service)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteColumn(byte[] row, byte[] column)
void	deleteRange(byte[] startRow, byte[] stopRow, FuzzyRowFilter filter, byte[][] columns)
void	deleteRows(byte[] prefix)
void	deleteRows(Collection<byte[]> toDelete) Delete a list of rows from the table entirely, disregarding transactions.
NavigableMap<byte[],byte[]>	getRow(byte[] row, byte[][] columns, byte[] startCol, byte[] stopCol, int limit, co.cask.tephra.Transaction tx) if columns are not null, then limit param is ignored and limit is columns.length
Map<byte[],Long>	increment(byte[] row, Map<byte[],Long> increments)
void	increment(NavigableMap<byte[],NavigableMap<byte[],Long>> updates)
void	persist(Map<byte[],? extends Map<byte[],byte[]>> changes, long version)
void	put(byte[] row, byte[] column, byte[] value, long version)
co.cask.cdap.api.dataset.table.Scanner	scan(byte[] startRow, byte[] stopRow, FuzzyRowFilter filter, byte[][] columns, co.cask.tephra.Transaction tx)
boolean	swap(byte[] row, byte[] column, byte[] oldValue, byte[] newValue)
void	undo(Map<byte[],? extends Map<byte[],?>> persisted, long version)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DELETE_MARKER

protected static final byte[] DELETE_MARKER

Constructor Detail

LevelDBTableCore

public LevelDBTableCore(String tableName,
                LevelDBTableService service)
                 throws IOException

Throws:

IOException

Method Detail

swap

public boolean swap(byte[] row,
           byte[] column,
           byte[] oldValue,
           byte[] newValue)
             throws IOException

Throws:

IOException

increment

public Map<byte[],Long> increment(byte[] row,
                         Map<byte[],Long> increments)
                           throws IOException

Throws:

IOException

increment

public void increment(NavigableMap<byte[],NavigableMap<byte[],Long>> updates)
               throws IOException

Throws:

IOException

persist

public void persist(Map<byte[],? extends Map<byte[],byte[]>> changes,
           long version)
             throws IOException

Throws:

IOException

put

public void put(byte[] row,
       byte[] column,
       byte[] value,
       long version)
         throws IOException

Throws:

IOException

undo

public void undo(Map<byte[],? extends Map<byte[],?>> persisted,
        long version)
          throws IOException

Throws:

IOException

scan

public co.cask.cdap.api.dataset.table.Scanner scan(byte[] startRow,
                                          byte[] stopRow,
                                          @Nullable
                                          FuzzyRowFilter filter,
                                          @Nullable
                                          byte[][] columns,
                                          @Nullable
                                          co.cask.tephra.Transaction tx)
                                            throws IOException

Throws:

IOException

getRow

public NavigableMap<byte[],byte[]> getRow(byte[] row,
                                 @Nullable
                                 byte[][] columns,
                                 byte[] startCol,
                                 byte[] stopCol,
                                 int limit,
                                 co.cask.tephra.Transaction tx)
                                   throws IOException

if columns are not null, then limit param is ignored and limit is columns.length

Throws:

IOException

deleteRows

public void deleteRows(byte[] prefix)
                throws IOException

Throws:

IOException

deleteRows

public void deleteRows(Collection<byte[]> toDelete)
                throws IOException

Delete a list of rows from the table entirely, disregarding transactions.

Parameters:

toDelete - the row keys to delete

Throws:

IOException

deleteRange

public void deleteRange(byte[] startRow,
               byte[] stopRow,
               @Nullable
               FuzzyRowFilter filter,
               @Nullable
               byte[][] columns)
                 throws IOException

Throws:

IOException

deleteColumn

public void deleteColumn(byte[] row,
                byte[] column)
                  throws IOException

Throws:

IOException