public abstract class Sorter<T> extends Object implements AutoCloseable
| Modifier and Type | Class and Description |
|---|---|
static class |
Sorter.Input |
static class |
Sorter.Output |
| Modifier | Constructor and Description |
|---|---|
protected |
Sorter() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
protected abstract T |
decode(Sorter.Input input) |
void |
emit(T element) |
protected abstract void |
encode(Sorter.Output output,
T element) |
void |
end(boolean parallelize,
Consumer<T> consumer) |
static Sorter<org.openrdf.model.Statement> |
newStatementSorter(boolean compress) |
static Sorter<Object[]> |
newTupleSorter(boolean compress,
Class<?>... schema) |
void |
start(boolean deduplicate) |
public static Sorter<org.openrdf.model.Statement> newStatementSorter(boolean compress)
public void start(boolean deduplicate)
throws IOException
IOExceptionpublic void emit(T element) throws IOException
IOExceptionpublic void end(boolean parallelize,
Consumer<T> consumer)
throws IOException
IOExceptionpublic void close()
close in interface AutoCloseableprotected abstract void encode(Sorter.Output output, T element) throws IOException
IOExceptionprotected abstract T decode(Sorter.Input input) throws IOException
IOExceptionCopyright © 2015–2016 FBK-irst. All rights reserved.