Package cz.o2.proxima.direct.io.hadoop

Class HadoopPartition

java.lang.Object

cz.o2.proxima.direct.core.batch.BoundedPartition

cz.o2.proxima.direct.io.hadoop.HadoopPartition

All Implemented Interfaces:

Partition, java.io.Serializable, java.lang.Comparable<Partition>

public class HadoopPartition
extends BoundedPartition

Partition of files in HDFS.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface cz.o2.proxima.core.storage.Partition

Partition.IntegerPartition

Constructor Summary

Constructors

Constructor	Description
HadoopPartition(int id)

Method Summary

Modifier and Type	Method	Description
void	add(cz.o2.proxima.direct.io.hadoop.HadoopPath path)
long	size()	Estimate size of this partition.

Methods inherited from class cz.o2.proxima.direct.core.batch.BoundedPartition

getId, isBounded, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface cz.o2.proxima.core.storage.Partition

compareTo, getMaxTimestamp, getMinTimestamp, isSplittable, split

Constructor Detail

HadoopPartition

public HadoopPartition(int id)

Method Detail

add

public void add(cz.o2.proxima.direct.io.hadoop.HadoopPath path)

size

public long size()

Description copied from interface: Partition

Estimate size of this partition.

Specified by:

size in interface Partition

Overrides:

size in class BoundedPartition

Returns:

estimated size of this partition or -1 if unknown