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 Details

    • 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 Details

    • 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.