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

Class AbstractTable

java.lang.Object

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

All Implemented Interfaces:

co.cask.cdap.api.data.batch.BatchReadable<byte[],co.cask.cdap.api.dataset.table.Row>, co.cask.cdap.api.data.batch.BatchWritable<byte[],co.cask.cdap.api.dataset.table.Put>, co.cask.cdap.api.data.batch.RecordScannable<co.cask.cdap.api.data.format.StructuredRecord>, co.cask.cdap.api.data.batch.RecordWritable<co.cask.cdap.api.data.format.StructuredRecord>, co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.table.Table, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

Direct Known Subclasses:

BufferingTable

public abstract class AbstractTable
extends Object
implements co.cask.cdap.api.dataset.table.Table, co.cask.tephra.TransactionAware

Implements some of the methods in a generic way (not necessarily in most efficient way).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AbstractTable.TableScanner Implements a split reader for a key range of a table, based on the Scanner implementation of the underlying table implementation.

Field Summary

Fields

Modifier and Type	Field and Description
protected static NavigableMap<byte[],byte[]>	EMPTY_ROW_MAP

Fields inherited from interface co.cask.cdap.api.dataset.table.Table

PROPERTY_COLUMN_FAMILY, PROPERTY_CONFLICT_LEVEL, PROPERTY_READLESS_INCREMENT, PROPERTY_SCHEMA, PROPERTY_SCHEMA_ROW_FIELD, PROPERTY_TTL

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractTable(co.cask.cdap.api.data.schema.Schema tableSchema, String rowFieldName)

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>	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[] row, byte[] column)
void	delete(co.cask.cdap.api.dataset.table.Delete delete)
byte[]	get(byte[] row, byte[] column)
co.cask.cdap.api.dataset.table.Row	get(co.cask.cdap.api.dataset.table.Get get)
List<co.cask.cdap.api.dataset.table.Row>	get(List<co.cask.cdap.api.dataset.table.Get> gets)
Type	getRecordType()
List<co.cask.cdap.api.data.batch.Split>	getSplits()
void	increment(byte[] row, byte[] column, long amount)
void	increment(co.cask.cdap.api.dataset.table.Increment increment)
long	incrementAndGet(byte[] row, byte[] column, long amount)
co.cask.cdap.api.dataset.table.Row	incrementAndGet(co.cask.cdap.api.dataset.table.Increment increment)
void	put(byte[] row, byte[] column, byte[] value)
void	put(co.cask.cdap.api.dataset.table.Put put)
void	write(byte[] key, co.cask.cdap.api.dataset.table.Put put)
void	write(co.cask.cdap.api.data.format.StructuredRecord structuredRecord)

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.api.dataset.table.Table

compareAndSwap, delete, delete, get, get, get, getSplits, increment, incrementAndGet, put, scan, scan

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface co.cask.tephra.TransactionAware

commitTx, getTransactionAwareName, getTxChanges, postTxCommit, rollbackTx, startTx, updateTx

Field Detail

EMPTY_ROW_MAP

protected static final NavigableMap<byte[],byte[]> EMPTY_ROW_MAP

Constructor Detail

AbstractTable

protected AbstractTable(@Nullable
             co.cask.cdap.api.data.schema.Schema tableSchema,
             @Nullable
             String rowFieldName)

Method Detail

get

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

Specified by:

get in interface co.cask.cdap.api.dataset.table.Table

get

public co.cask.cdap.api.dataset.table.Row get(co.cask.cdap.api.dataset.table.Get get)

Specified by:

get in interface co.cask.cdap.api.dataset.table.Table

get

public List<co.cask.cdap.api.dataset.table.Row> get(List<co.cask.cdap.api.dataset.table.Get> gets)

Specified by:

get in interface co.cask.cdap.api.dataset.table.Table

put

public void put(byte[] row,
       byte[] column,
       byte[] value)

Specified by:

put in interface co.cask.cdap.api.dataset.table.Table

put

public void put(co.cask.cdap.api.dataset.table.Put put)

Specified by:

put in interface co.cask.cdap.api.dataset.table.Table

incrementAndGet

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

Specified by:

incrementAndGet in interface co.cask.cdap.api.dataset.table.Table

incrementAndGet

public co.cask.cdap.api.dataset.table.Row incrementAndGet(co.cask.cdap.api.dataset.table.Increment increment)

Specified by:

incrementAndGet in interface co.cask.cdap.api.dataset.table.Table

increment

public void increment(byte[] row,
             byte[] column,
             long amount)

Specified by:

increment in interface co.cask.cdap.api.dataset.table.Table

increment

public void increment(co.cask.cdap.api.dataset.table.Increment increment)

Specified by:

increment in interface co.cask.cdap.api.dataset.table.Table

delete

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

Specified by:

delete in interface co.cask.cdap.api.dataset.table.Table

delete

public void delete(co.cask.cdap.api.dataset.table.Delete delete)

Specified by:

delete in interface co.cask.cdap.api.dataset.table.Table

write

public void write(byte[] key,
         co.cask.cdap.api.dataset.table.Put put)

Specified by:

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

Specified by:

write in interface co.cask.cdap.api.dataset.table.Table

getSplits

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

Specified by:

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

Specified by:

getSplits 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[],co.cask.cdap.api.dataset.table.Row> createSplitReader(co.cask.cdap.api.data.batch.Split split)

Specified by:

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

getRecordType

public Type getRecordType()

Specified by:

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

Specified by:

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

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>

write

public void write(co.cask.cdap.api.data.format.StructuredRecord structuredRecord)
           throws IOException

Specified by:

write in interface co.cask.cdap.api.data.batch.RecordWritable<co.cask.cdap.api.data.format.StructuredRecord>

Throws:

IOException