splitenumerator专题

Flink1.14 SplitEnumerator概念入门讲解与源码解析 (二)

目录  SplitEnumerator概念 SplitEnumerator源码 void start() void handleSplitRequest(int subtaskId, @Nullable String requesterHostname); void addSplitsBack(List splits, int subtaskId); void addReader(in