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
IOException
public void emit(T element) throws IOException
IOException
public void end(boolean parallelize, Consumer<T> consumer) throws IOException
IOException
public void close()
close
in interface AutoCloseable
protected abstract void encode(Sorter.Output output, T element) throws IOException
IOException
protected abstract T decode(Sorter.Input input) throws IOException
IOException
Copyright © 2015–2016 FBK-irst. All rights reserved.