SinkWrapper
approach which doesn't require the use of dynamic proxies.@Deprecated public class PipelineSink extends Object implements InvocationHandler
SinkWrapper
Constructor and Description |
---|
PipelineSink(List<Sink> pipeline)
Deprecated.
Constructs a PipelineSink for a given List of Sinks.
|
Modifier and Type | Method and Description |
---|---|
void |
addSink(Sink sink)
Deprecated.
Add a Sink to the List of Sinks.
|
Object |
invoke(Object proxy,
Method method,
Object[] args)
Deprecated.
Invoke a Method on this PipelineSink.
|
static Sink |
newInstance(List<Sink> pipeline)
Deprecated.
Returns an instance of a PipelineSink as a Sink.
|
public PipelineSink(List<Sink> pipeline)
pipeline
- A List of Sinks.public void addSink(Sink sink)
sink
- the Sink to add.public Object invoke(Object proxy, Method method, Object[] args) throws IllegalAccessException, InvocationTargetException
invoke
in interface InvocationHandler
proxy
- a Object
object.method
- a Method
object.args
- an array of Object
objects.Object
object.IllegalAccessException
- if any.InvocationTargetException
- if any.public static Sink newInstance(List<Sink> pipeline)
pipeline
- A List of Sinks.Sink
object.Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.