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

Class ObjectMappedTableDataset<T>

java.lang.Object

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

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

Type Parameters:

T - the type of objects in the table

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.data.batch.RecordScannable<co.cask.cdap.api.data.format.StructuredRecord>, co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.lib.ObjectMappedTable<T>, co.cask.cdap.api.dataset.metrics.MeteredDataset, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

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

Default implementation for ObjectMappedTable.

Constructor Summary

Constructors

Constructor and Description
ObjectMappedTableDataset(String name, co.cask.cdap.api.dataset.table.Table table, TypeRepresentation typeRep, co.cask.cdap.api.data.schema.Schema objectSchema, 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.data.format.StructuredRecord>	createSplitRecordScanner(co.cask.cdap.api.data.batch.Split split)
void	delete(byte[] key)
void	delete(String 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)
co.cask.cdap.api.dataset.lib.CloseableIterator<co.cask.cdap.api.dataset.lib.KeyValue<byte[],T>>	scan(String startRow, String 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

ObjectMappedTableDataset

public ObjectMappedTableDataset(String name,
                        co.cask.cdap.api.dataset.table.Table table,
                        TypeRepresentation typeRep,
                        co.cask.cdap.api.data.schema.Schema objectSchema,
                        @Nullable
                        ClassLoader classLoader)

Method Detail

write

public void write(String key,
         T object)

Specified by:

write in interface co.cask.cdap.api.dataset.lib.ObjectMappedTable<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.ObjectMappedTable<T>

read

public T read(String key)

Specified by:

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

read

public T read(byte[] key)

Specified by:

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

scan

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

Specified by:

scan in interface co.cask.cdap.api.dataset.lib.ObjectMappedTable<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.ObjectMappedTable<T>

delete

public void delete(String key)

Specified by:

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

delete

public void delete(byte[] key)

Specified by:

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

getRecordType

public Type getRecordType()

Specified by:

getRecordType in interface co.cask.cdap.api.data.batch.RecordScannable<co.cask.cdap.api.data.format.StructuredRecord>

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>

Specified by:

getSplits in interface co.cask.cdap.api.data.batch.RecordScannable<co.cask.cdap.api.data.format.StructuredRecord>

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.ObjectMappedTable<T>

createSplitRecordScanner

public co.cask.cdap.api.data.batch.RecordScanner<co.cask.cdap.api.data.format.StructuredRecord> createSplitRecordScanner(co.cask.cdap.api.data.batch.Split split)

Specified by:

createSplitRecordScanner in interface co.cask.cdap.api.data.batch.RecordScannable<co.cask.cdap.api.data.format.StructuredRecord>

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>