org.apache.flink.table.planner.plan.nodes.exec

Class StateMetadata

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.StateMetadata

@Internal
public class StateMetadata
extends Object

It is used to describe the state metadata of a stateful operator, which is serialized/deserialized into/from those StreamExecNodes that can generate stateful operators. For ExecNodes that generates TwoInputStreamOperator or MultipleInputStreamOperator, there will be multiple metadata describing information about each input's state.

The metadata describes the following attributes.

• stateIndex: annotates the state is from the i-th input, index based on zero
• ttl: annotates the state retention time for the i-th input's state, the time unit is ms.
• name: annotates the state description, such as deduplicate-state, join-left-state.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_STATE_INDEX
static String	FIELD_NAME_STATE_NAME
static String	FIELD_NAME_STATE_TTL

Constructor Summary

Constructors

Constructor and Description
StateMetadata(int stateIndex, Duration stateTtl, String stateName)
StateMetadata(int stateIndex, String stateTtl, String stateName)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static List<StateMetadata>	getMultiInputOperatorDefaultMeta(Map<Integer,Long> stateTtlFromHint, org.apache.flink.configuration.ReadableConfig tableConfig, String... stateNameList)
static List<StateMetadata>	getOneInputOperatorDefaultMeta(Long stateTtlFromHint, org.apache.flink.configuration.ReadableConfig tableConfig, String stateName)
static List<StateMetadata>	getOneInputOperatorDefaultMeta(org.apache.flink.configuration.ReadableConfig tableConfig, String stateName)
int	getStateIndex()
String	getStateTtl()
static List<Long>	getStateTtlForMultiInputOperator(ExecNodeConfig config, int inputNumOfOperator, List<StateMetadata> stateMetadataList)
static long	getStateTtlForOneInputOperator(ExecNodeConfig config, List<StateMetadata> stateMetadataList)
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_STATE_INDEX

public static final String FIELD_NAME_STATE_INDEX

See Also:

Constant Field Values

FIELD_NAME_STATE_TTL

public static final String FIELD_NAME_STATE_TTL

See Also:

Constant Field Values

FIELD_NAME_STATE_NAME

public static final String FIELD_NAME_STATE_NAME

See Also:

Constant Field Values

Constructor Detail

StateMetadata

public StateMetadata(int stateIndex,
                     String stateTtl,
                     String stateName)

StateMetadata

public StateMetadata(int stateIndex,
                     Duration stateTtl,
                     String stateName)

Method Detail

getStateIndex

public int getStateIndex()

getStateTtl

public String getStateTtl()

getOneInputOperatorDefaultMeta

public static List<StateMetadata> getOneInputOperatorDefaultMeta(org.apache.flink.configuration.ReadableConfig tableConfig,
                                                                 String stateName)

getOneInputOperatorDefaultMeta

public static List<StateMetadata> getOneInputOperatorDefaultMeta(@Nullable
                                                                 Long stateTtlFromHint,
                                                                 org.apache.flink.configuration.ReadableConfig tableConfig,
                                                                 String stateName)

getMultiInputOperatorDefaultMeta

public static List<StateMetadata> getMultiInputOperatorDefaultMeta(Map<Integer,Long> stateTtlFromHint,
                                                                   org.apache.flink.configuration.ReadableConfig tableConfig,
                                                                   String... stateNameList)

getStateTtlForOneInputOperator

public static long getStateTtlForOneInputOperator(ExecNodeConfig config,
                                                  @Nullable
                                                  List<StateMetadata> stateMetadataList)

getStateTtlForMultiInputOperator

public static List<Long> getStateTtlForMultiInputOperator(ExecNodeConfig config,
                                                          int inputNumOfOperator,
                                                          @Nullable
                                                          List<StateMetadata> stateMetadataList)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object