public class MultipleExternalSortedFilesTableInput extends Object implements TableInput
Constructor and Description |
---|
MultipleExternalSortedFilesTableInput(List<File> files,
NewRowComparator newRowComparator) |
Modifier and Type | Method and Description |
---|---|
void |
close()
empty implementation
|
boolean |
hasMoreRows()
returns true if the priority queue with the external sorted files is empty
|
List<Object> |
nextRow()
next row is taken from the priority queue by polling the priority queue which returns the top FileWrapper.
|
void |
open()
empty implementation
|
public MultipleExternalSortedFilesTableInput(List<File> files, NewRowComparator newRowComparator)
externalSortedFiles
- the list of files (each file having the values sorted)newRowComparator
- a comparator for new rowspublic void open()
open
in interface TableInput
public void close()
close
in interface TableInput
public List<Object> nextRow()
nextRow
in interface TableInput
public boolean hasMoreRows()
hasMoreRows
in interface TableInput
Copyright © 2006–2015. All rights reserved.