95-136-041-源碼-Operator-AbstractStreamOperator

1.視界

2.前文回顧

​ AbstractStreamOperator

該抽象類為實作一個具體的operator提供基本的支援，Flink内置提供的operator全部都直接或間接繼承自AbstractStreamOperator。

它内部包含了三大類的屬性：

配置屬性
運作時屬性
鍵值對狀态屬性
           

大都數方法都是輔助方法，值得一提的是setup方法。從這裡我們可以看到所有operator辨別符的生成方式：

String operatorIdentifier = getClass().getSimpleName() + "_" + config.getVertexID() + "_" + runtimeContext.getIndexOfThisSubtask();
           

可以看到辨別是由”_”間隔的三段拼接而成。三段分别是：類名，vertex id，以及目前subtask的索引。

然後基于此辨別，建立了用于存儲狀态的stateBackend：

stateBackend = container.createStateBackend(operatorIdentifier, keySerializ