【HDFS】EditLogTailer功能及原理（二）-- selectInputStreams细节详解

【HDFS】EditLogTailer功能及原理（一）-- 整体流程

【HDFS】EditLogTailer功能及原理（二）-- selectInputStreams细节详解
【HDFS】EditLogTailer功能及原理（三）-- loadEdits方法细节详解

在系列文章的第一篇中，我们用通俗的语言描述了EditLogTailer的基本工作过程，然后也留了一些坑待填。今天我们来填第一个坑，selectInputStreams方法细节详解。

本文不会大段的复制源码逐行讲解，而是用图文的方式将自己的理解给描述出来。通过本文你将获得了解如下内容：

① 社区hadoop-3.3.0版本新增observer namenode read特性后，选择editlog的inputStream的细节。

② selectRpcInputStreams：hadoop-3.3.0后新增的通过RPC的方式获取editlog输入流数据，RPC的实现是从journal node的cache里获取的editlog数据。

③ selectStreamingInputStreams：原始版本就有的通过http获取editlog数据输入流的实现。