edu.iu.dsc.tws.dataset

Class DataObjectImpl<T>

java.lang.Object

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

All Implemented Interfaces:

DataObject<T>, java.io.Serializable

Direct Known Subclasses:

DataSource

public class DataObjectImpl<T>
extends java.lang.Object
implements DataObject<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DataObjectImpl(Config conf)
DataObjectImpl(java.lang.String name, Config conf)

Method Summary

Modifier and Type	Method and Description
void	addPartition(DataPartition<T> partition) Add a partition to the data object
java.lang.String	getID() ID of the data object.
DataPartition<T>	getPartition(int partitionId) Get the partition with the specific partition id
int	getPartitionCount() Get the number of partitions currently in the DataObject
DataPartition<T>[]	getPartitions() Get the list of partitions for a process

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

DataObjectImpl

public DataObjectImpl(Config conf)

DataObjectImpl

public DataObjectImpl(java.lang.String name,
                      Config conf)

Method Detail

addPartition

public void addPartition(DataPartition<T> partition)

Description copied from interface: DataObject

Add a partition to the data object

Specified by:

addPartition in interface DataObject<T>

Parameters:

partition - the partition

getPartitions

public DataPartition<T>[] getPartitions()

Description copied from interface: DataObject

Get the list of partitions for a process

Specified by:

getPartitions in interface DataObject<T>

Returns:

the partitions

getPartition

public DataPartition<T> getPartition(int partitionId)

Description copied from interface: DataObject

Get the partition with the specific partition id

Specified by:

getPartition in interface DataObject<T>

Parameters:

partitionId - partition id

Returns:

DataPartition

getPartitionCount

public int getPartitionCount()

Description copied from interface: DataObject

Get the number of partitions currently in the DataObject

Specified by:

getPartitionCount in interface DataObject<T>

Returns:

the number of partitions

getID

public java.lang.String getID()

Description copied from interface: DataObject

ID of the data object. The ID needs to be deterministic

Specified by:

getID in interface DataObject<T>

Returns:

ID