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

Class ObjectStoreDataset<T>

java.lang.Object

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

co.cask.cdap.data2.dataset2.lib.table.ObjectStoreDataset<T>

Type Parameters:

T - the type of objects in the store

All Implemented Interfaces:

co.cask.cdap.api.data.batch.BatchReadable<byte[],T>, co.cask.cdap.api.data.batch.BatchWritable<byte[],T>, co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.lib.ObjectStore<T>, co.cask.cdap.api.dataset.metrics.MeteredDataset, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

@Beta
public class ObjectStoreDataset<T>
extends co.cask.cdap.api.dataset.lib.AbstractDataset
implements co.cask.cdap.api.dataset.lib.ObjectStore<T>

Default implementation for ObjectStore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ObjectStoreDataset.ObjectRecordMaker Scannables.RecordMaker for ObjectStoreDataset.
class	ObjectStoreDataset.ObjectScanner The split reader for objects is reading a table split using the underlying KeyValueTable's split reader.

Constructor Summary

Constructors

Constructor and Description
ObjectStoreDataset(String name, co.cask.cdap.api.dataset.lib.KeyValueTable kvTable, TypeRepresentation typeRep, co.cask.cdap.api.data.schema.Schema schema)
ObjectStoreDataset(String name, co.cask.cdap.api.dataset.lib.KeyValueTable kvTable, TypeRepresentation typeRep, co.cask.cdap.api.data.schema.Schema schema, ClassLoader classLoader)

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.api.data.batch.SplitReader<byte[],T>	createSplitReader(co.cask.cdap.api.data.batch.Split split)
co.cask.cdap.api.data.batch.RecordScanner<co.cask.cdap.api.dataset.lib.KeyValue<byte[],T>>	createSplitRecordScanner(co.cask.cdap.api.data.batch.Split split)
void	delete(byte[] key)
Type	getRecordType()
List<co.cask.cdap.api.data.batch.Split>	getSplits()
List<co.cask.cdap.api.data.batch.Split>	getSplits(int numSplits, byte[] start, byte[] stop)
T	read(byte[] key)
T	read(String key)
co.cask.cdap.api.dataset.lib.CloseableIterator<co.cask.cdap.api.dataset.lib.KeyValue<byte[],T>>	scan(byte[] startRow, byte[] stopRow)
void	write(byte[] key, T object)
void	write(String key, T object)

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

ObjectStoreDataset

public ObjectStoreDataset(String name,
                  co.cask.cdap.api.dataset.lib.KeyValueTable kvTable,
                  TypeRepresentation typeRep,
                  co.cask.cdap.api.data.schema.Schema schema,
                  @Nullable
                  ClassLoader classLoader)

ObjectStoreDataset

public ObjectStoreDataset(String name,
                  co.cask.cdap.api.dataset.lib.KeyValueTable kvTable,
                  TypeRepresentation typeRep,
                  co.cask.cdap.api.data.schema.Schema schema)

Method Detail

write

public void write(String key,
         T object)

Specified by:

write in interface co.cask.cdap.api.dataset.lib.ObjectStore<T>

write

public void write(byte[] key,
         T object)

Specified by:

write in interface co.cask.cdap.api.data.batch.BatchWritable<byte[],T>

Specified by:

write in interface co.cask.cdap.api.dataset.lib.ObjectStore<T>

read

public T read(String key)

Specified by:

read in interface co.cask.cdap.api.dataset.lib.ObjectStore<T>

scan

public co.cask.cdap.api.dataset.lib.CloseableIterator<co.cask.cdap.api.dataset.lib.KeyValue<byte[],T>> scan(byte[] startRow,
                                                                                                   byte[] stopRow)

Specified by:

scan in interface co.cask.cdap.api.dataset.lib.ObjectStore<T>

read

public T read(byte[] key)

Specified by:

read in interface co.cask.cdap.api.dataset.lib.ObjectStore<T>

delete

public void delete(byte[] key)

Specified by:

delete in interface co.cask.cdap.api.dataset.lib.ObjectStore<T>

createSplitRecordScanner

public co.cask.cdap.api.data.batch.RecordScanner<co.cask.cdap.api.dataset.lib.KeyValue<byte[],T>> createSplitRecordScanner(co.cask.cdap.api.data.batch.Split split)

getRecordType

public Type getRecordType()

getSplits

public List<co.cask.cdap.api.data.batch.Split> getSplits()

Specified by:

getSplits in interface co.cask.cdap.api.data.batch.BatchReadable<byte[],T>

getSplits

public List<co.cask.cdap.api.data.batch.Split> getSplits(int numSplits,
                                                byte[] start,
                                                byte[] stop)

Specified by:

getSplits in interface co.cask.cdap.api.dataset.lib.ObjectStore<T>

createSplitReader

public co.cask.cdap.api.data.batch.SplitReader<byte[],T> createSplitReader(co.cask.cdap.api.data.batch.Split split)

Specified by:

createSplitReader in interface co.cask.cdap.api.data.batch.BatchReadable<byte[],T>