Package org.apache.flink.table.runtime.operators.process

Class RuntimeStateInfo

java.lang.Object

org.apache.flink.table.runtime.operators.process.RuntimeStateInfo

All Implemented Interfaces:

Serializable

public class RuntimeStateInfo
extends Object
implements Serializable

Serializable representation of TypeInferenceUtil.StateInfo that will translate into state descriptors and state access.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RuntimeStateInfo(String stateName, org.apache.flink.table.types.DataType dataType, long timeToLive)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.types.DataType	getDataType()
String	getStateName()
long	getTimeToLive()

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeStateInfo

public RuntimeStateInfo(String stateName,
                        org.apache.flink.table.types.DataType dataType,
                        long timeToLive)

Method Detail

getStateName

public String getStateName()

getDataType

public org.apache.flink.table.types.DataType getDataType()

getTimeToLive

public long getTimeToLive()