edu.iu.dsc.tws.dataset

Class DataSource<T,O extends InputSplit<T>>

java.lang.Object

edu.iu.dsc.tws.dataset.DataObjectImpl<T>

edu.iu.dsc.tws.dataset.DataSource<T,O>

Type Parameters:

T - type of the data

O - type of InputSplit used for splitting the data

All Implemented Interfaces:

DataObject<T>, java.io.Serializable

public class DataSource<T,O extends InputSplit<T>>
extends DataObjectImpl<T>

A distributed data source

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DataSource(Config cfg, InputPartitioner<T,O> input, int numSplits)

Method Summary

Modifier and Type	Method and Description
InputSplit<T>	getNextSplit(int id)

Methods inherited from class edu.iu.dsc.tws.dataset.DataObjectImpl

addPartition, getID, getPartition, getPartitionCount, getPartitions

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.dataset.DataObject

getAnyPartition, getLowestPartition

Constructor Detail

DataSource

public DataSource(Config cfg,
                  InputPartitioner<T,O> input,
                  int numSplits)

Method Detail

getNextSplit

public InputSplit<T> getNextSplit(int id)