org.apache.reef.io.data.loading.api

Class DistributedDataSet

java.lang.Object

org.apache.reef.io.data.loading.api.DistributedDataSet

All Implemented Interfaces:

Iterable<DistributedDataSetPartition>

public final class DistributedDataSet
extends Object
implements Iterable<DistributedDataSetPartition>

Represents a distributed data set that is split across data centers. It contains a set of distributed data set partitions DistributedDataSetPartition this data to be loaded into.

Constructor Summary

Constructors

Constructor and Description
DistributedDataSet()

Method Summary

Methods

Modifier and Type	Method and Description
void	addPartition(DistributedDataSetPartition partition) Adds the given partition to the set.
void	addPartitions(Collection<DistributedDataSetPartition> partitions) Adds the given partitions to the set.
boolean	isEmpty() Returns true if it does not contain any partition.
Iterator<DistributedDataSetPartition>	iterator()

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedDataSet

public DistributedDataSet()

Method Detail

addPartition

public void addPartition(DistributedDataSetPartition partition)

Adds the given partition to the set.

Parameters:

partition - the partition to add

addPartitions

public void addPartitions(Collection<DistributedDataSetPartition> partitions)

Adds the given partitions to the set.

Parameters:

partitions - the partitions to add

isEmpty

public boolean isEmpty()

Returns true if it does not contain any partition.

Returns:

a boolean indicating whether it contains partitions or not

iterator

public Iterator<DistributedDataSetPartition> iterator()

Specified by:

iterator in interface Iterable<DistributedDataSetPartition>