public interface OutputWriter<T>
extends java.io.Serializable
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the writer, flush everything
|
void |
configure(Config config)
Configure the output writer
|
void |
write(int partition,
T out)
Add value to output
|
void |
write(T out) |