GlobalWindows在Flink中的同一个GlobalWindows中指定具有相同键的元素？

Question

根据下面的文档“全局窗口赋值器将具有相同密钥的所有元素分配给同一个全局窗口”

https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/windows.html

然后我检查了源代码，发现GlobalWindows的assignWindows方法只返回全局窗口，没有对参数元素执行任何操作，那么如何将具有相同键的所有元素都返回到同一个全局窗口呢？

https://github.com/apache/flink/blob/12b4185c6c09101b64e12a84c33dc4d28f95cff9/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/GlobalWindows.java

@Override
public Collection<GlobalWindow> assignWindows(Object element, long timestamp, WindowAssignerContext context) {
    return Collections.singletonList(GlobalWindow.get());
}

Answer 1

在Flink，窗户和钥匙在很大程度上是相互独立的。流元素可以按键和窗口分组，这是正交维度。（当我们要讨论窗口与键的组合时，这称为窗格。）

窗口实例没有键，窗口赋值器也没有。相反，键和键分区状态是评估窗口的运行时上下文的一部分。

当我试图理解键与窗口分配符的关系时，我发现通读WindowOP的Process Element实现很有帮助。当每个流元素到达一个窗口运算符时，都会调用此代码。注意键的作用，同时省略许多其他细节，我们看到了这一点：

public void processElement(StreamRecord<IN> element) throws Exception {
    final Collection<W> elementWindows = windowAssigner.assignWindows(
        element.getValue(), element.getTimestamp(), windowAssignerContext);

    ...

    final K key = this.<K>getKeyedStateBackend().getCurrentKey();

    ...

    for (W window: elementWindows) {

        ...

        windowState.add(element.getValue());

        triggerContext.key = key;
        triggerContext.window = window;

        TriggerResult triggerResult = triggerContext.onElement(element);
        if (triggerResult.isFire()) {
            ...
            emitWindowContents(window, contents);
        }

        ...
    }
}

在这里，您可以看到，该键可通过getKeyedStateBend（）供窗口操作符使用，但直到从窗口赋值器中获取该元素的窗口之后，该键才被检索。窗口赋值器执行其工作时不需要考虑任何键。

不过，稍后会提取密钥，以便可以通过触发器上下文将其提供给触发器。