Module datarush.commons

Package com.pervasive.datarush.io

Class CompressionSplitIterator

java.lang.Object

com.pervasive.datarush.io.CompressionSplitIterator

All Implemented Interfaces:

SplitIterator

public class CompressionSplitIterator
extends Object
implements SplitIterator

Constructor Summary

Constructors

Constructor	Description
CompressionSplitIterator(SplitIterator baseIterator, CompressionFormat format)

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

CompressionSplitIterator

public CompressionSplitIterator(SplitIterator baseIterator,
                                CompressionFormat format)

Method Detail

next

public boolean next()
             throws IOException

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.

Throws:

IOException

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.