edu.iu.dsc.tws.api.dataset

Interface DataObject<T>

Type Parameters:

T - the distributed set interface

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

DataObjectImpl, DataSource, EmptyDataObject

public interface DataObject<T>
extends java.io.Serializable

Distributed data set

Method Summary

Modifier and Type	Method and Description
void	addPartition(DataPartition<T> partition) Add a partition to the data object
default DataPartition<T>	getAnyPartition() Return any of the available partitions
java.lang.String	getID() ID of the data object.
default DataPartition<T>	getLowestPartition() Returns the partition with the lowest ID, i.e partition from the lowest task index in this worker
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

Method Detail

addPartition

void addPartition(DataPartition<T> partition)

Add a partition to the data object

Parameters:

partition - the partition

getPartitions

DataPartition<T>[] getPartitions()

Get the list of partitions for a process

Returns:

the partitions

getPartition

DataPartition<T> getPartition(int partitionId)

Get the partition with the specific partition id

Parameters:

partitionId - partition id

Returns:

DataPartition

getAnyPartition

default DataPartition<T> getAnyPartition()

Return any of the available partitions

getLowestPartition

default DataPartition<T> getLowestPartition()

Returns the partition with the lowest ID, i.e partition from the lowest task index in this worker

getPartitionCount

int getPartitionCount()

Get the number of partitions currently in the DataObject

Returns:

the number of partitions

getID

java.lang.String getID()

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

Returns:

ID