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

Class Updates

java.lang.Object

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

public final class Updates
extends Object

Utility class for working with Update instances.

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.common.base.Function<Long,Update>	LONG_TO_PUTS

Constructor Summary

Constructors

Constructor and Description
Updates()

Method Summary

Methods

Modifier and Type	Method and Description
static Update	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 NavigableMap<byte[],NavigableMap<Long,byte[]>>	rowToBytes(NavigableMap<byte[],NavigableMap<Long,Update>> row) Returns a new NavigableMap with the underlying updates represented as byte[].

Methods inherited from class java.lang.Object

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

Field Detail

LONG_TO_PUTS

public static final com.google.common.base.Function<Long,Update> LONG_TO_PUTS

Constructor Detail

Updates

public Updates()

Method Detail

rowToBytes

public static NavigableMap<byte[],NavigableMap<Long,byte[]>> rowToBytes(NavigableMap<byte[],NavigableMap<Long,Update>> row)

Returns a new NavigableMap with the underlying updates represented as byte[].

Note: the map returned is not thread safe.

mergeUpdates

public static Update 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)

Parameters:

base - The currently stored or buffered update

modifier - The new update to combine

Returns:

A new update combining the base update and modifier, according to the rules above