| Package | Description |
|---|---|
| co.cask.cdap.data2.dataset2.lib.table | |
| co.cask.cdap.data2.dataset2.lib.table.hbase |
This package contains HBase implementations of the table dataset.
|
| co.cask.cdap.data2.dataset2.lib.table.inmemory |
This package contains in-memory implementations of the table dataset.
|
| co.cask.cdap.data2.dataset2.lib.table.leveldb |
This package contains LevelDB implementations of the table dataset.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IncrementValue
Represents an incremental write to a datastore for in-memory buffering.
|
class |
PutValue
Represents a normal (full) write to a datastore for in-memory buffering, overwriting the previously stored value.
|
| Modifier and Type | Field and Description |
|---|---|
static com.google.common.base.Function<Long,Update> |
Updates.LONG_TO_PUTS |
| Modifier and Type | Method and Description |
|---|---|
Update<Long> |
IncrementValue.deepCopy() |
Update<byte[]> |
PutValue.deepCopy() |
Update<T> |
Update.deepCopy() |
static Update |
Updates.mergeUpdates(Update base,
Update modifier)
Merges together two Update instances:
Put a + Put b = Put b
Put a + Increment b = new Put(a + b)
Increment a + Put b = Put b
Increment a + Increment b = new Increment(a + b)
|
| Modifier and Type | Method and Description |
|---|---|
static Update |
Updates.mergeUpdates(Update base,
Update modifier)
Merges together two Update instances:
Put a + Put b = Put b
Put a + Increment b = new Put(a + b)
Increment a + Put b = Put b
Increment a + Increment b = new Increment(a + b)
|
static Update |
Updates.mergeUpdates(Update base,
Update modifier)
Merges together two Update instances:
Put a + Put b = Put b
Put a + Increment b = new Put(a + b)
Increment a + Put b = Put b
Increment a + Increment b = new Increment(a + b)
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
BufferingTable.persist(NavigableMap<byte[],NavigableMap<byte[],Update>> buff)
Persists in-memory buffer.
|
static NavigableMap<byte[],NavigableMap<Long,byte[]>> |
Updates.rowToBytes(NavigableMap<byte[],NavigableMap<Long,Update>> row)
Returns a new
NavigableMap with the underlying updates represented as byte[]. |
protected abstract void |
BufferingTable.undo(NavigableMap<byte[],NavigableMap<byte[],Update>> persisted)
Undos previously persisted changes.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
HBaseTable.persist(NavigableMap<byte[],NavigableMap<byte[],Update>> buff) |
protected void |
HBaseTable.undo(NavigableMap<byte[],NavigableMap<byte[],Update>> persisted) |
| Modifier and Type | Method and Description |
|---|---|
static void |
InMemoryTableService.merge(String tableName,
SortedMap<byte[],? extends SortedMap<byte[],? extends Update>> changes,
long version) |
protected void |
InMemoryTable.persist(NavigableMap<byte[],NavigableMap<byte[],Update>> buff) |
protected void |
InMemoryTable.undo(NavigableMap<byte[],NavigableMap<byte[],Update>> persisted) |
static void |
InMemoryTableService.undo(String tableName,
NavigableMap<byte[],NavigableMap<byte[],Update>> changes,
long version) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
LevelDBTable.persist(NavigableMap<byte[],NavigableMap<byte[],Update>> changes) |
protected void |
LevelDBTable.undo(NavigableMap<byte[],NavigableMap<byte[],Update>> persisted) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.