public class ArtificialMapStateBuilder<IN,K,V> extends ArtificialStateBuilder<IN>
ArtificialStateBuilder
for user MapState
s.Constructor and Description |
---|
ArtificialMapStateBuilder(String stateName,
JoinFunction<IN,Iterator<Map.Entry<K,V>>,Iterator<Map.Entry<K,V>>> stateValueGenerator,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
Modifier and Type | Method and Description |
---|---|
void |
artificialStateForElement(IN event)
Manipulate the state for an input element.
|
void |
initialize(FunctionInitializationContext initializationContext)
Registers the state.
|
getStateName
public ArtificialMapStateBuilder(String stateName, JoinFunction<IN,Iterator<Map.Entry<K,V>>,Iterator<Map.Entry<K,V>>> stateValueGenerator, TypeSerializer<K> keySerializer, TypeSerializer<V> valueSerializer)
public void artificialStateForElement(IN event) throws Exception
ArtificialStateBuilder
artificialStateForElement
in class ArtificialStateBuilder<IN>
event
- the current input element.Exception
public void initialize(FunctionInitializationContext initializationContext)
ArtificialStateBuilder
initialize
in class ArtificialStateBuilder<IN>
initializationContext
- the state initialization context, provided by the user function.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.