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

Class InMemoryMetricsTable

java.lang.Object

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

All Implemented Interfaces:

co.cask.cdap.api.dataset.Dataset, MetricsTable, Closeable, AutoCloseable

public class InMemoryMetricsTable
extends Object
implements MetricsTable

Implements the metrics table API in-memory.

Constructor Summary

Constructors

Constructor and Description
InMemoryMetricsTable(co.cask.cdap.api.dataset.DatasetContext datasetContext, String name, CConfiguration cConf) To be used in tests that need namespaces
InMemoryMetricsTable(String name) To be used in tests that do not need namespaces

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	delete(byte[] row, byte[][] columns) Deletes specified columns of the specified row.
byte[]	get(byte[] row, byte[] column) Read single column of a row
void	increment(byte[] row, Map<byte[],Long> increments) Atomic increment of multiple columns of a row.
void	increment(NavigableMap<byte[],NavigableMap<byte[],Long>> updates) Batch increment multiple rows each with multiple columns and increments
long	incrementAndGet(byte[] row, byte[] column, long delta) Increment a single column of a row and return the new value.
void	put(SortedMap<byte[],? extends SortedMap<byte[],Long>> updates) Write multiple rows, each with multiple individual columns to write.
co.cask.cdap.api.dataset.table.Scanner	scan(byte[] start, byte[] stop, FuzzyRowFilter filter) Get a scanner for a table.
boolean	swap(byte[] row, byte[] column, byte[] oldValue, byte[] newValue) Atomically compare a single column of a row with a expected value, and if it matches, replace it with a new value.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryMetricsTable

public InMemoryMetricsTable(co.cask.cdap.api.dataset.DatasetContext datasetContext,
                    String name,
                    CConfiguration cConf)

To be used in tests that need namespaces

InMemoryMetricsTable

public InMemoryMetricsTable(String name)

To be used in tests that do not need namespaces

Method Detail

get

public byte[] get(byte[] row,
         byte[] column)

Description copied from interface: MetricsTable

Read single column of a row

Specified by:

get in interface MetricsTable

put

public void put(SortedMap<byte[],? extends SortedMap<byte[],Long>> updates)

Description copied from interface: MetricsTable

Write multiple rows, each with multiple individual columns to write.

Specified by:

put in interface MetricsTable

swap

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

Description copied from interface: MetricsTable

Atomically compare a single column of a row with a expected value, and if it matches, replace it with a new value.

Specified by:

swap in interface MetricsTable

oldValue - the expected value of the column. If null, this means that the column must not exist.

newValue - the new value of the column. If null, the effect to delete the column if the comparison succeeds.

Returns:

whether the write happened, that is, whether the existing value of the column matched the expected value.

increment

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

Description copied from interface: MetricsTable

Atomic increment of multiple columns of a row. If a column does not exist prior to the increment, its value is assumed zero. Increments are only guaranteed atomic with respect to other increments.

Specified by:

increment in interface MetricsTable

increments - Map from each column key to the value it should be incremented by.

increment

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

Description copied from interface: MetricsTable

Batch increment multiple rows each with multiple columns and increments

Specified by:

increment in interface MetricsTable

incrementAndGet

public long incrementAndGet(byte[] row,
                   byte[] column,
                   long delta)

Description copied from interface: MetricsTable

Increment a single column of a row and return the new value.

Specified by:

incrementAndGet in interface MetricsTable

Returns:

the new value after the increment.

delete

public void delete(byte[] row,
          byte[][] columns)

Description copied from interface: MetricsTable

Deletes specified columns of the specified row.

Specified by:

delete in interface MetricsTable

Parameters:

row - row to delete from

columns - names of columns to delete

scan

public co.cask.cdap.api.dataset.table.Scanner scan(@Nullable
                                          byte[] start,
                                          @Nullable
                                          byte[] stop,
                                          @Nullable
                                          FuzzyRowFilter filter)

Description copied from interface: MetricsTable

Get a scanner for a table.

Specified by:

scan in interface MetricsTable

Parameters:

start - the row key of the first row to scan. If null, the scan begins at the first row of the table.

stop - the row key of the last row to scan. If null, the scan goes to the last row of the table.

filter - if non-null, a fuzzy row filter used to efficiently skip over entire rows.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable