org.apache.flink.streaming.tests.verify

Interface TtlStateVerifier<UV,GV>

public interface TtlStateVerifier<UV,GV>

TTL state verifier interface.

Field Summary

Fields

Modifier and Type	Field and Description
static List<TtlStateVerifier<?,?>>	VERIFIERS

Method Summary

Modifier and Type	Method and Description
State	createState(FunctionInitializationContext context, StateTtlConfig ttlConfig)
UV	generateRandomUpdate()
GV	get(State state)
default String	getId()
TypeSerializer<UV>	getUpdateSerializer()
void	update(State state, Object update)
boolean	verify(TtlVerificationContext<?,?> verificationContext)

Field Detail

VERIFIERS

static final List<TtlStateVerifier<?,?>> VERIFIERS

Method Detail

getId

@Nonnull
default String getId()

createState

@Nonnull
State createState(@Nonnull
                           FunctionInitializationContext context,
                           @Nonnull
                           StateTtlConfig ttlConfig)

getUpdateSerializer

@Nonnull
TypeSerializer<UV> getUpdateSerializer()

generateRandomUpdate

UV generateRandomUpdate()

get

GV get(@Nonnull
       State state)
throws Exception

Throws:

Exception

update

void update(@Nonnull
            State state,
            Object update)
     throws Exception

Throws:

Exception

verify

boolean verify(@Nonnull
               TtlVerificationContext<?,?> verificationContext)