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

Class InMemoryScanner

java.lang.Object

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

All Implemented Interfaces:

co.cask.cdap.api.dataset.table.Scanner

public class InMemoryScanner
extends Object
implements co.cask.cdap.api.dataset.table.Scanner

An in-memory implememtation of a scanner.

Constructor Summary

Constructors

Constructor and Description
InMemoryScanner(Iterator<Map.Entry<byte[],NavigableMap<byte[],byte[]>>> rows)
InMemoryScanner(Iterator<Map.Entry<byte[],NavigableMap<byte[],byte[]>>> rows, FuzzyRowFilter filter, byte[][] columnsToInclude)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
co.cask.cdap.api.dataset.table.Row	next()

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryScanner

public InMemoryScanner(Iterator<Map.Entry<byte[],NavigableMap<byte[],byte[]>>> rows)

InMemoryScanner

public InMemoryScanner(Iterator<Map.Entry<byte[],NavigableMap<byte[],byte[]>>> rows,
               FuzzyRowFilter filter,
               byte[][] columnsToInclude)

Method Detail

next

public co.cask.cdap.api.dataset.table.Row next()

Specified by:

next in interface co.cask.cdap.api.dataset.table.Scanner

close

public void close()

Specified by:

close in interface co.cask.cdap.api.dataset.table.Scanner