Module datarush.commons

Package com.pervasive.datarush.io

Class SingleSplitIterator

java.lang.Object

com.pervasive.datarush.io.SingleSplitIterator

All Implemented Interfaces:

SplitIterator

public class SingleSplitIterator
extends Object
implements SplitIterator

A split iterator containing a single split.

Constructor Summary

Constructors

Constructor	Description
SingleSplitIterator(DataSplit split)	Creates an iterator returning only the specified split with no locality data.
SingleSplitIterator(DataSplit split, List<String> locality)	Creates an iterator returning only the specified split and locality data.

Method Summary

Modifier and Type	Method	Description
List<String>	getLocalityInfo()	Get the list of machines for which access to the current split is local.
DataSplit	getSplit()	Get the current split in the iterated set.
boolean	next()	Advance to the next data split in the iterated set.

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleSplitIterator

public SingleSplitIterator(DataSplit split)

Creates an iterator returning only the specified split with no locality data.

Parameters:

split - the split to return

SingleSplitIterator

public SingleSplitIterator(DataSplit split,
                           List<String> locality)

Creates an iterator returning only the specified split and locality data.

Parameters:

split - the split to return

locality - locality data for the split

Method Detail

next

public boolean next()

Description copied from interface: SplitIterator

Advance to the next data split in the iterated set.

Specified by:

next in interface SplitIterator

Returns:

true if there is another split, otherwise false.

getSplit

public DataSplit getSplit()

Description copied from interface: SplitIterator

Get the current split in the iterated set.

Specified by:

getSplit in interface SplitIterator

Returns:

the split currently selected

getLocalityInfo

public List<String> getLocalityInfo()

Description copied from interface: SplitIterator

Get the list of machines for which access to the current split is local. An empty list indicates the split is local to no node (or all nodes).

Specified by:

getLocalityInfo in interface SplitIterator

Returns:

the machines where the currently selected split is local. If the split is local to no machine (or to all), this list is empty.