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