public abstract class ProcessFunctionWithCleanupState<IN,OUT> extends ProcessFunction<IN,OUT>
ProcessFunction.Context, ProcessFunction.OnTimerContext
Constructor and Description |
---|
ProcessFunctionWithCleanupState(StreamQueryConfig queryConfig) |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanupState(scala.collection.Seq<State> states) |
protected void |
initCleanupTimeState(String stateName) |
protected boolean |
isProcessingTimeTimer(ProcessFunction.OnTimerContext ctx) |
protected long |
maxRetentionTime() |
protected long |
minRetentionTime() |
protected boolean |
needToCleanupState(long timestamp) |
protected void |
registerProcessingCleanupTimer(ProcessFunction.Context ctx,
long currentTime) |
protected boolean |
stateCleaningEnabled() |
onTimer, processElement
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public ProcessFunctionWithCleanupState(StreamQueryConfig queryConfig)
protected long minRetentionTime()
protected long maxRetentionTime()
protected boolean stateCleaningEnabled()
protected void initCleanupTimeState(String stateName)
protected void registerProcessingCleanupTimer(ProcessFunction.Context ctx, long currentTime)
protected boolean isProcessingTimeTimer(ProcessFunction.OnTimerContext ctx)
protected boolean needToCleanupState(long timestamp)
protected void cleanupState(scala.collection.Seq<State> states)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.