edu.iu.dsc.tws.dataset.partition

Class CollectionPartition<T>

java.lang.Object

edu.iu.dsc.tws.dataset.partition.CollectionPartition<T>

All Implemented Interfaces:

DataPartition<T>, java.io.Serializable

Direct Known Subclasses:

BufferedCollectionPartition

public class CollectionPartition<T>
extends java.lang.Object
implements DataPartition<T>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<T>	dataList

Fields inherited from interface edu.iu.dsc.tws.api.dataset.DataPartition

DEFAULT_REF

Constructor Summary

Constructors

Constructor and Description
CollectionPartition()
CollectionPartition(int id) Deprecated. use default constructor instead

Method Summary

Modifier and Type	Method and Description
void	add(T val)
void	addAll(java.util.Collection<T> vals)
void	clear()
DataPartitionConsumer<T>	getConsumer() Get the data consumer
int	getPartitionId() Get the id of the partition
void	setId(int id)

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

first, firstOrDefault, getReference

Field Detail

dataList

protected java.util.List<T> dataList

Constructor Detail

CollectionPartition

@Deprecated
public CollectionPartition(int id)

Deprecated. use default constructor instead

This constructor is deprecated

CollectionPartition

public CollectionPartition()

Method Detail

setId

public void setId(int id)

Specified by:

setId in interface DataPartition<T>

add

public void add(T val)

addAll

public void addAll(java.util.Collection<T> vals)

getConsumer

public DataPartitionConsumer<T> getConsumer()

Description copied from interface: DataPartition

Get the data consumer

Specified by:

getConsumer in interface DataPartition<T>

Returns:

the consumer

clear

public void clear()

Specified by:

clear in interface DataPartition<T>

getPartitionId

public int getPartitionId()

Description copied from interface: DataPartition

Get the id of the partition

Specified by:

getPartitionId in interface DataPartition<T>

Returns:

the id of the partition