org.apache.flink.streaming.tests.artificialstate.builder

Class ArtificialMapStateBuilder<IN,K,V>

java.lang.Object

org.apache.flink.streaming.tests.artificialstate.builder.ArtificialStateBuilder<IN>

org.apache.flink.streaming.tests.artificialstate.builder.ArtificialMapStateBuilder<IN,K,V>

All Implemented Interfaces:

Serializable

public class ArtificialMapStateBuilder<IN,K,V>
extends ArtificialStateBuilder<IN>

An ArtificialStateBuilder for user MapStates.

See Also:

Serialized Form

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	artificialStateForElement(IN event) Manipulate the state for an input element.
void	initialize(FunctionInitializationContext initializationContext) Registers the state.

Methods inherited from class org.apache.flink.streaming.tests.artificialstate.builder.ArtificialStateBuilder

getStateName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ArtificialMapStateBuilder

public ArtificialMapStateBuilder(String stateName,
                                 JoinFunction<IN,Iterator<Map.Entry<K,V>>,Iterator<Map.Entry<K,V>>> stateValueGenerator,
                                 TypeSerializer<K> keySerializer,
                                 TypeSerializer<V> valueSerializer)

Method Detail

artificialStateForElement

public void artificialStateForElement(IN event)
                               throws Exception

Description copied from class: ArtificialStateBuilder

Manipulate the state for an input element.

Specified by:

artificialStateForElement in class ArtificialStateBuilder<IN>

Parameters:

event - the current input element.

Throws:

Exception

initialize

public void initialize(FunctionInitializationContext initializationContext)

Description copied from class: ArtificialStateBuilder

Registers the state.

Specified by:

initialize in class ArtificialStateBuilder<IN>

Parameters:

initializationContext - the state initialization context, provided by the user function.