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

Class JobStateView

java.lang.Object

org.apache.flink.autoscaler.jdbc.state.JobStateView

@NotThreadSafe
public class JobStateView
extends java.lang.Object

The view of job state.

Constructor Summary

Constructors

Constructor	Description
JobStateView(JdbcStateInteractor jdbcStateInteractor, java.lang.String jobKey)

Method Summary

Modifier and Type	Method	Description
void	clear()
void	flush()
java.lang.String	get(StateType stateType)
java.util.Map<StateType,java.lang.String>	getDataReadOnly()
void	put(StateType stateType, java.lang.String value)
void	remove(StateType stateType)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobStateView

public JobStateView(JdbcStateInteractor jdbcStateInteractor,
                    java.lang.String jobKey)
             throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

get

public java.lang.String get(StateType stateType)

put

public void put(StateType stateType,
                java.lang.String value)

remove

public void remove(StateType stateType)

clear

public void clear()

flush

public void flush()
           throws java.lang.Exception

Throws:

java.lang.Exception

getDataReadOnly

@VisibleForTesting
public java.util.Map<StateType,java.lang.String> getDataReadOnly()