<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ThinkChat2.0新版上線,更智能更精彩,支持會話、畫圖、視頻、閱讀、搜索等,送10W Token,即刻開啟你的AI之旅 廣告
                # 離散流(DStreams) 離散流或者DStreams是Spark Streaming提供的基本的抽象,它代表一個連續的數據流。它要么是從源中獲取的輸入流,要么是輸入流通過轉換算子生成的處理后的數據流。在內部,DStreams由一系列連續的 RDD組成。DStreams中的每個RDD都包含確定時間間隔內的數據,如下圖所示: ![DStreams](https://box.kancloud.cn/2016-07-11_578308d9e6d67.png) 任何對DStreams的操作都轉換成了對DStreams隱含的RDD的操作。在前面的[例子](../a-quick-example.md)中,`flatMap`操作應用于`lines`這個DStreams的每個RDD,生成`words`這個DStreams的 RDD。過程如下圖所示: ![DStreams](https://box.kancloud.cn/2016-07-11_578308da0b0d1.png) 通過Spark引擎計算這些隱含RDD的轉換算子。DStreams操作隱藏了大部分的細節,并且為了更便捷,為開發者提供了更高層的API。下面幾節將具體討論這些操作的細節。
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看