private class OfflineSorter.MergePartitionsTask extends java.lang.Object implements java.util.concurrent.Callable<OfflineSorter.Partition>
Modifier and Type | Field and Description |
---|---|
private Directory |
dir |
private java.util.List<java.util.concurrent.Future<OfflineSorter.Partition>> |
segmentsToMerge |
Constructor and Description |
---|
MergePartitionsTask(Directory dir,
java.util.List<java.util.concurrent.Future<OfflineSorter.Partition>> segmentsToMerge) |
Modifier and Type | Method and Description |
---|---|
OfflineSorter.Partition |
call() |
private final Directory dir
private final java.util.List<java.util.concurrent.Future<OfflineSorter.Partition>> segmentsToMerge
public MergePartitionsTask(Directory dir, java.util.List<java.util.concurrent.Future<OfflineSorter.Partition>> segmentsToMerge)
public OfflineSorter.Partition call() throws java.io.IOException
call
in interface java.util.concurrent.Callable<OfflineSorter.Partition>
java.io.IOException