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

Class MetadataStoreDataset

java.lang.Object

co.cask.cdap.api.dataset.lib.AbstractDataset

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

All Implemented Interfaces:

co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.metrics.MeteredDataset, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

Direct Known Subclasses:

DatasetInstanceMDS, DatasetTypeMDS, NamespaceMDS, UsageDataset, ViewMetadataStoreDataset

public class MetadataStoreDataset
extends co.cask.cdap.api.dataset.lib.AbstractDataset

Handy dataset to be used for managing metadata

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	MetadataStoreDataset.KeyValue<T> Output value of a scan.

Constructor Summary

Constructors

Constructor and Description
MetadataStoreDataset(co.cask.cdap.api.dataset.table.Table table)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteAll(MDSKey id)
protected <T> T	deserialize(byte[] serialized, Type typeOfT)
boolean	exists(MDSKey id)
<T> T	get(MDSKey id, Type typeOfT)
<T> T	getFirst(MDSKey id, Type typeOfT)
<T> List<T>	list(MDSKey startId, MDSKey stopId, Type typeOfT, int limit, com.google.common.base.Predicate<T> filter)
<T> List<T>	list(MDSKey id, Type typeOfT)
<T> List<T>	list(MDSKey id, Type typeOfT, int limit)
<T> Map<MDSKey,T>	listKV(MDSKey startId, MDSKey stopId, Type typeOfT, int limit, com.google.common.base.Predicate<T> filter)
<T> Map<MDSKey,T>	listKV(MDSKey id, Type typeOfT)
<T> Map<MDSKey,T>	listKV(MDSKey id, Type typeOfT, int limit)
<T> void	scan(MDSKey startId, MDSKey stopId, Type typeOfT, com.google.common.base.Function<MetadataStoreDataset.KeyValue<T>,Boolean> function) Run a scan on MDS.
protected <T> byte[]	serialize(T value)
<T> void	write(MDSKey id, T value)

Methods inherited from class co.cask.cdap.api.dataset.lib.AbstractDataset

close, commitTx, getName, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, setMetricsCollector, startTx, toString, updateTx

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataStoreDataset

public MetadataStoreDataset(co.cask.cdap.api.dataset.table.Table table)

Method Detail

serialize

protected <T> byte[] serialize(T value)

deserialize

protected <T> T deserialize(byte[] serialized,
                Type typeOfT)

exists

public boolean exists(MDSKey id)

get

@Nullable
public <T> T get(MDSKey id,
                 Type typeOfT)

getFirst

@Nullable
public <T> T getFirst(MDSKey id,
                      Type typeOfT)

list

public <T> List<T> list(MDSKey id,
               Type typeOfT)

list

public <T> List<T> list(MDSKey id,
               Type typeOfT,
               int limit)

list

public <T> List<T> list(MDSKey startId,
               @Nullable
               MDSKey stopId,
               Type typeOfT,
               int limit,
               com.google.common.base.Predicate<T> filter)

listKV

public <T> Map<MDSKey,T> listKV(MDSKey id,
                       Type typeOfT)

listKV

public <T> Map<MDSKey,T> listKV(MDSKey id,
                       Type typeOfT,
                       int limit)

listKV

public <T> Map<MDSKey,T> listKV(MDSKey startId,
                       @Nullable
                       MDSKey stopId,
                       Type typeOfT,
                       int limit,
                       com.google.common.base.Predicate<T> filter)

scan

public <T> void scan(MDSKey startId,
            @Nullable
            MDSKey stopId,
            Type typeOfT,
            com.google.common.base.Function<MetadataStoreDataset.KeyValue<T>,Boolean> function)

Run a scan on MDS.

Type Parameters:

T - type of value

Parameters:

startId - scan start key

stopId - scan stop key

typeOfT - type of value

function - function to process each element returned from scan. If function.apply returns false then the scan is stopped. Also, function.apply should not return null.

deleteAll

public void deleteAll(MDSKey id)

write

public <T> void write(MDSKey id,
             T value)