public class PipelineSink
extends java.lang.Object
implements java.lang.reflect.InvocationHandler
| Constructor and Description |
|---|
PipelineSink(java.util.List<Sink> pipeline)
Constructs a PipelineSink for a given List of Sinks.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addSink(Sink sink)
Add a Sink to the List of Sinks.
|
java.lang.Object |
invoke(java.lang.Object proxy,
java.lang.reflect.Method method,
java.lang.Object[] args)
Invoke a Method on this PipelineSink.
|
static Sink |
newInstance(java.util.List<Sink> pipeline)
Returns an instance of a PipelineSink as a Sink.
|
private java.util.List<Sink> pipeline
public PipelineSink(java.util.List<Sink> pipeline)
pipeline - A List of Sinks.public void addSink(Sink sink)
sink - the Sink to add.public java.lang.Object invoke(java.lang.Object proxy,
java.lang.reflect.Method method,
java.lang.Object[] args)
throws java.lang.IllegalAccessException,
java.lang.reflect.InvocationTargetException
invoke in interface java.lang.reflect.InvocationHandlerjava.lang.IllegalAccessException - if any.java.lang.reflect.InvocationTargetException - if any.