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

Class ArtificialListStateBuilder<IN,STATE>

java.lang.Object

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

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

All Implemented Interfaces:

Serializable

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

An ArtificialListStateBuilder for user operator and keyed state.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ArtificialListStateBuilder(String stateName, JoinFunction<IN,Iterable<STATE>,List<STATE>> keyedStateGenerator, JoinFunction<IN,Iterable<STATE>,List<STATE>> operatorStateGenerator, ListStateDescriptor<STATE> listStateDescriptor)

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

ArtificialListStateBuilder

public ArtificialListStateBuilder(String stateName,
                                  JoinFunction<IN,Iterable<STATE>,List<STATE>> keyedStateGenerator,
                                  JoinFunction<IN,Iterable<STATE>,List<STATE>> operatorStateGenerator,
                                  ListStateDescriptor<STATE> listStateDescriptor)

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)
                throws Exception

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.

Throws:

Exception