| Methods in org.galagosearch.tupleflow with parameters of type Order |
static
|
SequentialCombiner.combineFromFiles(java.util.List<java.lang.String> filenames,
Order<S> order)
|
static
|
OrderedCombiner.combineFromFiles(java.util.List<java.lang.String> filenames,
Order<S> order)
|
static
|
OrderedCombiner.combineFromFiles(java.util.List<java.lang.String> filenames,
Order<S> order,
Processor<S> processor)
|
static
|
OrderedCombiner.combineFromFiles(java.util.List<java.lang.String> filenames,
Order<S> order,
Processor<S> processor,
boolean closeOnExit,
int bufferSize)
|
static Step |
Utility.getSorter(Order sortOrder)
Builds a simple Sorter step that can be added to a TupleFlow stage. |
static
|
Splitter.splitToFiles(java.lang.String[] filenames,
Order<S> sortOrder,
Order<S> hashOrder)
|
static
|
Splitter.splitToFiles(java.lang.String[] filenames,
Order<S> sortOrder,
Order<S> hashOrder)
|
static
|
Splitter.splitToFiles(java.lang.String[] filenames,
Order<S> sortOrder,
Order<S> hashOrder,
java.lang.Class reducerClass)
|
static
|
Splitter.splitToFiles(java.lang.String[] filenames,
Order<S> sortOrder,
Order<S> hashOrder,
java.lang.Class reducerClass)
|
static
|
Splitter.splitToFiles(java.lang.String prefix,
int limit,
Type<S> type,
Order<S> order,
int count)
|
| Constructors in org.galagosearch.tupleflow with parameters of type Order |
FileOrderedReader(java.lang.String filename,
Order<T> order)
|
FileOrderedReader(java.lang.String filename,
Order<T> order,
int bufferSize)
|
FileOrderedReader(java.lang.String filename,
Order<T> order,
int bufferSize,
boolean compressed)
Creates a new instance of FileOrderedReader |
FileOrderedWriter(java.io.File file,
Order<T> order)
|
FileOrderedWriter(java.lang.String filename,
Order<T> order)
|
FileOrderedWriter(java.lang.String filename,
Order<T> order,
boolean compressed)
|
OrderedCombiner(TypeReader<T>[] inputs,
FileOrderedReader<T>[] files,
Order<T> order,
Processor<T> processor,
boolean closeOnExit)
|
OrderedCombiner(TypeReader<T>[] inputs,
Order<T> order)
|
OrderedCombiner(TypeReader<T>[] inputs,
Order<T> order,
Processor<T> processor)
|
SequentialCombiner(java.util.List<java.lang.String> filenames,
Order<T> order)
Creates a new instance of SequentialCombiner |
Sorter(int limit,
Order<T> order)
|
Sorter(int limit,
Order<T> order,
Reducer<T> reducer)
|
Sorter(int limit,
Order<T> order,
Reducer<T> reducer,
Processor<T> processor)
|
Sorter(Order<T> order)
|
Sorter(Order<T> order,
Reducer<T> reducer)
|
Splitter(Processor<T>[] processors,
Order<T> order)
|