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

Class ObjectStoreDataset.ObjectScanner

java.lang.Object

co.cask.cdap.api.data.batch.SplitReader<byte[],T>

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

Enclosing class:

ObjectStoreDataset<T>

public class ObjectStoreDataset.ObjectScanner
extends co.cask.cdap.api.data.batch.SplitReader<byte[],T>

The split reader for objects is reading a table split using the underlying KeyValueTable's split reader.

Constructor Summary

Constructors

Constructor and Description
ObjectStoreDataset.ObjectScanner(co.cask.cdap.api.data.batch.SplitReader<byte[],byte[]> reader)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
byte[]	getCurrentKey()
T	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

ObjectStoreDataset.ObjectScanner

public ObjectStoreDataset.ObjectScanner(co.cask.cdap.api.data.batch.SplitReader<byte[],byte[]> reader)

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[],T>

Throws:

InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws InterruptedException

Specified by:

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

Throws:

InterruptedException

getCurrentKey

public byte[] getCurrentKey()
                     throws InterruptedException

Specified by:

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

Throws:

InterruptedException

getCurrentValue

public T getCurrentValue()
                  throws InterruptedException

Specified by:

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

Throws:

InterruptedException

close

public void close()

Specified by:

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