请忽略这个问题，显然时态表函数可以接受（对我来说）正在收回的表。
大意是：

SELECT b, AVG(a) "average", MAX(proctime) max_proctime FROM source_data GROUP BY b

可以接受为一个时态表函数，其中b作为键，max\u proctime作为时间属性。我猜max（proctime）在某种程度上使它认为新行被发出，而它们只是被覆盖？我想我需要更多的时间来理解这一点。
编辑：
通过对源代码的深入研究，我们发现时态表函数似乎接受收回定义，但仅当它处于处理时间下时：
temporalprocesstimejoinoperator.java:

@Override
public void processElement2(StreamRecord<BaseRow> element) throws Exception {
    if (BaseRowUtil.isAccumulateMsg(element.getValue())) {
        rightState.update(element.getValue());
        registerProcessingCleanupTimer();
    } else {
        rightState.clear();
        cleanupLastTimer();
    }
}

temporalrowtimejoinoperator.java:时间行

@Override
public void processElement2(StreamRecord<BaseRow> element) throws Exception {
    ...
    checkNotRetraction(row);
    ...
}
private void checkNotRetraction(BaseRow row) {
    if (BaseRowUtil.isRetractMsg(row)) {
        String className = getClass().getSimpleName();
        throw new IllegalStateException(
            "Retractions are not supported by " + className +
                ". If this can happen it should be validated during planning!");
    }
}

这是无证的；我不知道这是否是永久性的，文件是否会更新。