public class SinkWrapper<T> extends Object implements Sink<T>
SinkSplit
SinkWrapper(Sink<T> sink)
void
close()
flush()
send(T item)
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public SinkWrapper(Sink<T> sink)
public void flush()
flush
Sink<T>
public void send(T item)
send
public void close()
close
Closeable
Licenced under the Apache License, Version 2.0