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

Class AbstractTable.TableScanner

java.lang.Object

co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>

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

Enclosing class:

AbstractTable

public class AbstractTable.TableScanner
extends co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>

Implements a split reader for a key range of a table, based on the Scanner implementation of the underlying table implementation.

Constructor Summary

Constructors

Constructor and Description
AbstractTable.TableScanner()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
byte[]	getCurrentKey()
co.cask.cdap.api.dataset.table.Row	getCurrentValue()
void	initialize(co.cask.cdap.api.data.batch.Split split)
boolean	nextKeyValue()

Methods inherited from class co.cask.cdap.api.data.batch.SplitReader

getProgress

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTable.TableScanner

public AbstractTable.TableScanner()

Method Detail

initialize

public void initialize(co.cask.cdap.api.data.batch.Split split)
                throws InterruptedException

Specified by:

initialize in class co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>

Throws:

InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws InterruptedException

Specified by:

nextKeyValue in class co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>

Throws:

InterruptedException

getCurrentKey

public byte[] getCurrentKey()
                     throws InterruptedException

Specified by:

getCurrentKey in class co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>

Throws:

InterruptedException

getCurrentValue

public co.cask.cdap.api.dataset.table.Row getCurrentValue()
                                                   throws InterruptedException

Specified by:

getCurrentValue in class co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>

Throws:

InterruptedException

close

public void close()

Specified by:

close in class co.cask.cdap.api.data.batch.SplitReader<byte[],co.cask.cdap.api.dataset.table.Row>