org.apache.hadoop.hbase.mob.mapreduce

Class SweepReducer.SweepPartition

java.lang.Object

org.apache.hadoop.hbase.mob.mapreduce.SweepReducer.SweepPartition

Enclosing class:

SweepReducer

public class SweepReducer.SweepPartition
extends Object

The mob files which have the same start key and date are in the same partition. The files in the same partition are merged together into bigger ones.

Constructor Summary

Constructors

Constructor and Description
SweepPartition(PartitionedMobCompactionRequest.CompactionPartitionId id, Context context)

Method Summary

Modifier and Type	Method and Description
void	close() Flushes the data into mob files and store files, and archives the small files after they're merged.
void	execute(Text fileName, Iterable<KeyValue> values) Merges the small mob files into bigger ones.
PartitionedMobCompactionRequest.CompactionPartitionId	getId()

Methods inherited from class java.lang.Object

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

Constructor Detail

SweepPartition

public SweepPartition(PartitionedMobCompactionRequest.CompactionPartitionId id,
                      Context context)
               throws IOException

Throws:

IOException

Method Detail

getId

public PartitionedMobCompactionRequest.CompactionPartitionId getId()

close

public void close()
           throws IOException

Flushes the data into mob files and store files, and archives the small files after they're merged.

Throws:

IOException

execute

public void execute(Text fileName,
                    Iterable<KeyValue> values)
             throws IOException

Merges the small mob files into bigger ones.

Parameters:

fileName - The current mob file name.

values - The collection of KeyValues in this mob file.

Throws:

IOException