Uses of Class
org.apache.flink.table.planner.plan.nodes.exec.StateMetadata

Packages that use StateMetadata

Package	Description
org.apache.flink.table.planner.plan.nodes.exec
org.apache.flink.table.planner.plan.nodes.exec.stream

Uses of StateMetadata in org.apache.flink.table.planner.plan.nodes.exec

Methods in org.apache.flink.table.planner.plan.nodes.exec that return types with arguments of type StateMetadata

Modifier and Type	Method and Description
static List<StateMetadata>	StateMetadata.getMultiInputOperatorDefaultMeta(Map<Integer,Long> stateTtlFromHint, org.apache.flink.configuration.ReadableConfig tableConfig, String... stateNameList)
static List<StateMetadata>	StateMetadata.getOneInputOperatorDefaultMeta(Long stateTtlFromHint, org.apache.flink.configuration.ReadableConfig tableConfig, String stateName)
static List<StateMetadata>	StateMetadata.getOneInputOperatorDefaultMeta(org.apache.flink.configuration.ReadableConfig tableConfig, String stateName)

Method parameters in org.apache.flink.table.planner.plan.nodes.exec with type arguments of type StateMetadata

Modifier and Type	Method and Description
static List<Long>	StateMetadata.getStateTtlForMultiInputOperator(ExecNodeConfig config, int inputNumOfOperator, List<StateMetadata> stateMetadataList)
static long	StateMetadata.getStateTtlForOneInputOperator(ExecNodeConfig config, List<StateMetadata> stateMetadataList)

Uses of StateMetadata in org.apache.flink.table.planner.plan.nodes.exec.stream

Constructor parameters in org.apache.flink.table.planner.plan.nodes.exec.stream with type arguments of type StateMetadata

Constructor and Description
StreamExecChangelogNormalize(Integer id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, int[] uniqueKeys, boolean generateUpdateBefore, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecDeduplicate(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, int[] uniqueKeys, boolean isRowtime, boolean keepLastRow, boolean generateUpdateBefore, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecGlobalGroupAggregate(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, boolean[] aggCallNeedRetractions, org.apache.flink.table.types.logical.RowType localAggInputRowType, boolean generateUpdateBefore, boolean needRetraction, Integer indexOfCountStar, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecGroupAggregate(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, int[] grouping, org.apache.calcite.rel.core.AggregateCall[] aggCalls, boolean[] aggCallNeedRetractions, boolean generateUpdateBefore, boolean needRetraction, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecIncrementalGroupAggregate(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, int[] partialAggGrouping, int[] finalAggGrouping, org.apache.calcite.rel.core.AggregateCall[] partialOriginalAggCalls, boolean[] partialAggCallNeedRetractions, org.apache.flink.table.types.logical.RowType partialLocalAggInputType, boolean partialAggNeedRetraction, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecJoin(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, JoinSpec joinSpec, List<int[]> leftUpsertKeys, List<int[]> rightUpsertKeys, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecLimit(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, org.apache.flink.table.runtime.operators.rank.ConstantRankRange rankRange, RankProcessStrategy rankStrategy, boolean generateUpdateBefore, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecLookupJoin(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType, org.apache.calcite.rex.RexNode preFilterCondition, org.apache.calcite.rex.RexNode remainingJoinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, boolean lookupKeyContainsPrimaryKey, boolean upsertMaterialize, LookupJoinUtil.AsyncLookupOptions asyncLookupOptions, LookupJoinUtil.RetryLookupOptions retryOptions, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecRank(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, org.apache.flink.table.runtime.operators.rank.RankType rankType, PartitionSpec partitionSpec, SortSpec sortSpec, org.apache.flink.table.runtime.operators.rank.RankRange rankRange, RankProcessStrategy rankStrategy, boolean outputRankNumber, boolean generateUpdateBefore, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecSink(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, DynamicTableSinkSpec tableSinkSpec, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, boolean upsertMaterialize, List<StateMetadata> stateMetadataList, int[] inputUpsertKey, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.LogicalType outputType, String description)
StreamExecSortLimit(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, SortSpec sortSpec, org.apache.flink.table.runtime.operators.rank.ConstantRankRange rankRange, RankProcessStrategy rankStrategy, boolean generateUpdateBefore, List<StateMetadata> stateMetadataList, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)