THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public static List<StateMetadata> getMultiInputOperatorDefaultMeta( + Map<Integer, Long> stateTtlFromHint, ReadableConfig tableConfig, String... stateNameList) { Duration ttlFromTableConf = tableConfig.get(ExecutionConfigOptions.IDLE_STATE_RETENTION); List<StateMetadata> stateMetadataList = new ArrayList<>(stateNameList.length); for (int i = 0; i < stateNameList.length; i++) { + Duration stateTtl = + stateTtlFromHint.containsKey(i) + ? Duration.ofMillis(stateTtlFromHint.get(i)) + : ttlFromTableConf; stateMetadataList.add(new StateMetadata(i, stateTtl, stateNameList[i])); } return stateMetadataList; } |
Affected StreamPhysicalRels
- StreamPhysicalJoin
- StreamPhysicalGroupAggregate
- StreamPhysicalGlobalGroupAggregate (to support two-phase optimization)
- StreamPhysicalIncrementalGroupAggregate (to support partial-global-agg and final-local-agg combine optimization)
Parameter Granularity and Priority
...