public final class DistributedDataSet extends Object implements Iterable<DistributedDataSetPartition>
DistributedDataSetPartition
this data to be loaded into.Constructor and Description |
---|
DistributedDataSet() |
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() |
public DistributedDataSet()
public void addPartition(DistributedDataSetPartition partition)
partition
- the partition to addpublic void addPartitions(Collection<DistributedDataSetPartition> partitions)
partitions
- the partitions to addpublic boolean isEmpty()
public Iterator<DistributedDataSetPartition> iterator()
iterator
in interface Iterable<DistributedDataSetPartition>
Copyright © 2017 The Apache Software Foundation. All rights reserved.