| Package | Description |
|---|---|
| co.cask.cdap.data2.dataset2.lib.table | |
| co.cask.cdap.data2.metadata.dataset | |
| co.cask.cdap.data2.registry.internal.keymaker | |
| co.cask.cdap.data2.registry.internal.pair |
| Modifier and Type | Method and Description |
|---|---|
MDSKey |
MDSKey.Builder.build() |
MDSKey |
MetadataStoreDataset.KeyValue.getKey() |
| Modifier and Type | Method and Description |
|---|---|
<T> Map<MDSKey,T> |
MetadataStoreDataset.listKV(MDSKey startId,
MDSKey stopId,
Type typeOfT,
int limit,
com.google.common.base.Predicate<T> filter) |
<T> Map<MDSKey,T> |
MetadataStoreDataset.listKV(MDSKey id,
Type typeOfT) |
<T> Map<MDSKey,T> |
MetadataStoreDataset.listKV(MDSKey id,
Type typeOfT,
int limit) |
| Modifier and Type | Method and Description |
|---|---|
MDSKey.Builder |
MDSKey.Builder.append(MDSKey mdsKey) |
void |
MetadataStoreDataset.deleteAll(MDSKey id) |
boolean |
MetadataStoreDataset.exists(MDSKey id) |
<T> T |
MetadataStoreDataset.get(MDSKey id,
Type typeOfT) |
<T> T |
MetadataStoreDataset.getFirst(MDSKey id,
Type typeOfT) |
<T> List<T> |
MetadataStoreDataset.list(MDSKey startId,
MDSKey stopId,
Type typeOfT,
int limit,
com.google.common.base.Predicate<T> filter) |
<T> List<T> |
MetadataStoreDataset.list(MDSKey id,
Type typeOfT) |
<T> List<T> |
MetadataStoreDataset.list(MDSKey id,
Type typeOfT,
int limit) |
<T> Map<MDSKey,T> |
MetadataStoreDataset.listKV(MDSKey startId,
MDSKey stopId,
Type typeOfT,
int limit,
com.google.common.base.Predicate<T> filter) |
<T> Map<MDSKey,T> |
MetadataStoreDataset.listKV(MDSKey id,
Type typeOfT) |
<T> Map<MDSKey,T> |
MetadataStoreDataset.listKV(MDSKey id,
Type typeOfT,
int limit) |
<T> void |
MetadataStoreDataset.scan(MDSKey startId,
MDSKey stopId,
Type typeOfT,
com.google.common.base.Function<MetadataStoreDataset.KeyValue<T>,Boolean> function)
Run a scan on MDS.
|
<T> void |
MetadataStoreDataset.write(MDSKey id,
T value) |
| Constructor and Description |
|---|
MDSKey.Builder(MDSKey start) |
MetadataStoreDataset.KeyValue(MDSKey key,
T value) |
| Modifier and Type | Method and Description |
|---|---|
static MDSKey |
MdsKey.getMDSIndexKey(Id.NamespacedId targetId,
String key,
String index)
Creates a key for metadata index row in the format:
[
MdsKey.INDEX_ROW_PREFIX][targetType][targetId][key][index] for value index rows |
static MDSKey |
MdsHistoryKey.getMdsKey(Id.NamespacedId targetId,
long time) |
static MDSKey |
MdsHistoryKey.getMdsScanEndKey(Id.NamespacedId targetId) |
static MDSKey |
MdsHistoryKey.getMdsScanStartKey(Id.NamespacedId targetId,
long time) |
static MDSKey |
MdsKey.getMDSValueKey(Id.NamespacedId targetId,
String key)
Creates a key for metadata value row in the format:
[
MdsKey.VALUE_ROW_PREFIX][targetType][targetId][key] for value index rows |
| Modifier and Type | Method and Description |
|---|---|
static String |
MdsKey.getNamespaceId(MDSKey key) |
| Modifier and Type | Method and Description |
|---|---|
MDSKey |
DatasetKeyMaker.getKey(Id.DatasetInstance datasetInstance) |
MDSKey |
ProgramKeyMaker.getKey(Id.Program programId) |
MDSKey |
StreamKeyMaker.getKey(Id.Stream streamId) |
| Modifier and Type | Method and Description |
|---|---|
MDSKey |
KeyMaker.getKey(T id)
Serializes Id as MDSKey.
|
MDSKey |
OrderedPair.makeKey(FIRST first,
SECOND second) |
MDSKey |
OrderedPair.makeScanKey(FIRST first) |
| Modifier and Type | Method and Description |
|---|---|
Set<SECOND> |
OrderedPair.getSecond(Set<MDSKey> mdsKeys) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.