public class BufferingSinkProxyFactory extends Object implements SinkWrapperFactory
Sink.flush()
is called.Modifier and Type | Class and Description |
---|---|
static interface |
BufferingSinkProxyFactory.BufferingSink |
Constructor and Description |
---|
BufferingSinkProxyFactory() |
Modifier and Type | Method and Description |
---|---|
static BufferingSinkProxyFactory.BufferingSink |
castAsBufferingSink(Sink sink) |
Sink |
createWrapper(Sink delegate)
By default all wrappers just delegate each method to the wrapped sink's method.
|
int |
getPriority()
Determines the order of sink wrappers.
|
public BufferingSinkProxyFactory()
public Sink createWrapper(Sink delegate)
SinkWrapperFactory
createWrapper
in interface SinkWrapperFactory
delegate
- the delegatepublic static BufferingSinkProxyFactory.BufferingSink castAsBufferingSink(Sink sink)
public int getPriority()
SinkWrapperFactory
getPriority
in interface SinkWrapperFactory
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.