Package org.apache.flink.autoscaler.jdbc.state

Class JdbcStateStore

java.lang.Object

org.apache.flink.autoscaler.jdbc.state.JdbcStateStore

public class JdbcStateStore
extends java.lang.Object

The jdbc state store.

Constructor Summary

Constructors

Constructor	Description
JdbcStateStore(JdbcStateInteractor jdbcStateInteractor)

Method Summary

Modifier and Type	Method	Description
void	clearAll(java.lang.String jobKey)
void	flush(java.lang.String jobKey)
protected java.util.Optional<java.lang.String>	getSerializedState(java.lang.String jobKey, StateType stateType)
protected void	putSerializedState(java.lang.String jobKey, StateType stateType, java.lang.String value)
void	removeInfoFromCache(java.lang.String jobKey)
protected void	removeSerializedState(java.lang.String jobKey, StateType stateType)

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcStateStore

public JdbcStateStore(JdbcStateInteractor jdbcStateInteractor)

Method Detail

putSerializedState

protected void putSerializedState(java.lang.String jobKey,
                                  StateType stateType,
                                  java.lang.String value)

getSerializedState

protected java.util.Optional<java.lang.String> getSerializedState(java.lang.String jobKey,
                                                                  StateType stateType)

removeSerializedState

protected void removeSerializedState(java.lang.String jobKey,
                                     StateType stateType)

flush

public void flush(java.lang.String jobKey)
           throws java.lang.Exception

Throws:

java.lang.Exception

removeInfoFromCache

public void removeInfoFromCache(java.lang.String jobKey)

clearAll

public void clearAll(java.lang.String jobKey)