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

Class InMemoryTableService

java.lang.Object

co.cask.cdap.data2.dataset2.lib.table.inmemory.InMemoryTableService

public class InMemoryTableService
extends Object

Holds all in-memory tables for InMemoryTable.

Field Summary

Fields

Modifier and Type	Field and Description
static Comparator<Long>	VERSIONED_VALUE_MAP_COMPARATOR

Constructor Summary

Constructors

Constructor and Description
InMemoryTableService()

Method Summary

Methods

Modifier and Type	Method and Description
static void	create(String tableName)
static void	delete(String tableName, byte[] rowPrefix)
static void	delete(String tableName, Iterable<byte[]> rows)
static void	deleteColumns(String tableName, byte[] row, byte[] column)
static void	drop(String tableName)
static boolean	exists(String tableName)
static NavigableMap<byte[],NavigableMap<Long,byte[]>>	get(String tableName, byte[] row, Long version)
static NavigableMap<byte[],NavigableMap<byte[],NavigableMap<Long,byte[]>>>	getRowRange(String tableName, byte[] startRow, byte[] stopRow, Long version)
static Map<byte[],Long>	increment(String tableName, byte[] row, Map<byte[],Long> increments) Deprecated.
static Collection<String>	list()
static void	merge(String tableName, SortedMap<byte[],? extends SortedMap<byte[],? extends Update>> changes, long version)
static void	reset()
static boolean	swap(String tableName, byte[] row, byte[] column, byte[] oldValue, byte[] newValue)
static void	truncate(String tableName)
static void	undo(String tableName, NavigableMap<byte[],NavigableMap<byte[],Update>> changes, long version)

Methods inherited from class java.lang.Object

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

Field Detail

VERSIONED_VALUE_MAP_COMPARATOR

public static final Comparator<Long> VERSIONED_VALUE_MAP_COMPARATOR

Constructor Detail

InMemoryTableService

public InMemoryTableService()

Method Detail

exists

public static boolean exists(String tableName)

create

public static void create(String tableName)

truncate

public static void truncate(String tableName)

drop

public static void drop(String tableName)

reset

public static void reset()

merge

public static void merge(String tableName,
         SortedMap<byte[],? extends SortedMap<byte[],? extends Update>> changes,
         long version)

increment

@Deprecated
public static Map<byte[],Long> increment(String tableName,
                                    byte[] row,
                                    Map<byte[],Long> increments)

Deprecated.

swap

public static boolean swap(String tableName,
           byte[] row,
           byte[] column,
           byte[] oldValue,
           byte[] newValue)

undo

public static void undo(String tableName,
        NavigableMap<byte[],NavigableMap<byte[],Update>> changes,
        long version)

delete

public static void delete(String tableName,
          Iterable<byte[]> rows)

deleteColumns

public static void deleteColumns(String tableName,
                 byte[] row,
                 byte[] column)

delete

public static void delete(String tableName,
          byte[] rowPrefix)

get

public static NavigableMap<byte[],NavigableMap<Long,byte[]>> get(String tableName,
                                                 byte[] row,
                                                 Long version)

getRowRange

public static NavigableMap<byte[],NavigableMap<byte[],NavigableMap<Long,byte[]>>> getRowRange(String tableName,
                                                                              byte[] startRow,
                                                                              byte[] stopRow,
                                                                              Long version)

list

public static Collection<String> list()