public class SweepReducer.SweepPartition
extends java.lang.Object
Constructor and Description |
---|
SweepPartition(PartitionedMobCompactionRequest.CompactionPartitionId id,
Context context) |
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,
java.lang.Iterable<KeyValue> values)
Merges the small mob files into bigger ones.
|
PartitionedMobCompactionRequest.CompactionPartitionId |
getId() |
public SweepPartition(PartitionedMobCompactionRequest.CompactionPartitionId id, Context context) throws java.io.IOException
java.io.IOException
public PartitionedMobCompactionRequest.CompactionPartitionId getId()
public void close() throws java.io.IOException
java.io.IOException
public void execute(Text fileName, java.lang.Iterable<KeyValue> values) throws java.io.IOException
fileName
- The current mob file name.values
- The collection of KeyValues in this mob file.java.io.IOException