IN
- The type of the input.@PublicEvolving public abstract class StateBootstrapFunction<IN> extends AbstractRichFunction implements CheckpointedFunction
Modifier and Type | Class and Description |
---|---|
static interface |
StateBootstrapFunction.Context
Context that
StateBootstrapFunction 's can use for getting additional data about an
input record. |
Constructor and Description |
---|
StateBootstrapFunction() |
Modifier and Type | Method and Description |
---|---|
abstract void |
processElement(IN value,
StateBootstrapFunction.Context ctx)
Writes the given value to operator state.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeState, snapshotState
open
public abstract void processElement(IN value, StateBootstrapFunction.Context ctx) throws Exception
value
- The input record.Exception
- This method may throw exceptions. Throwing an exception will cause the
operation to fail and may trigger recovery.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.