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

Class ArtificialValueStateBuilder<IN,STATE>

java.lang.Object

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

org.apache.flink.streaming.tests.artificialstate.builder.ArtificialValueStateBuilder<IN,STATE>

All Implemented Interfaces:

Serializable

public class ArtificialValueStateBuilder<IN,STATE>
extends ArtificialStateBuilder<IN>

An ArtificialStateBuilder for user ValueStates.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ArtificialValueStateBuilder(String stateName, JoinFunction<IN,STATE,STATE> stateValueGenerator, ValueStateDescriptor<STATE> valueStateDescriptor)

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

ArtificialValueStateBuilder

public ArtificialValueStateBuilder(String stateName,
                                   JoinFunction<IN,STATE,STATE> stateValueGenerator,
                                   ValueStateDescriptor<STATE> valueStateDescriptor)

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.