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.
|
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.InvocationHandler
java.lang.IllegalAccessException
- if any.java.lang.reflect.InvocationTargetException
- if any.Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.