public class SinkSplit<T> extends Object implements Sink<T>
SinkWrapper
SinkSplit(Sink<T> sink1, Sink<T> sink2)
void
close()
flush()
send(T item)
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public SinkSplit(Sink<T> sink1, Sink<T> sink2)
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