@Public public abstract class RichSinkFunction<IN> extends AbstractRichFunction implements SinkFunction<IN>
RichFunction
version of SinkFunction
.Constructor and Description |
---|
RichSinkFunction() |
Modifier and Type | Method and Description |
---|---|
abstract void |
invoke(IN value)
Function for standard sink behaviour.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract void invoke(IN value) throws Exception
SinkFunction
invoke
in interface SinkFunction<IN>
value
- The input record.Exception
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.