Return-Path: 
 <dev-return-13871-apmail-spark-dev-archive=spark.apache.org@spark.apache.org>
X-Original-To: apmail-spark-dev-archive@minotaur.apache.org
Delivered-To: apmail-spark-dev-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 8D87118770
	for <apmail-spark-dev-archive@minotaur.apache.org>;
 Tue, 30 Jun 2015 14:59:59 +0000 (UTC)
Received: (qmail 82659 invoked by uid 500); 30 Jun 2015 14:59:58 -0000
Delivered-To: apmail-spark-dev-archive@spark.apache.org
Received: (qmail 82569 invoked by uid 500); 30 Jun 2015 14:59:57 -0000
Mailing-List: contact dev-help@spark.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@spark.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@spark.apache.org>
List-Post: <mailto:dev@spark.apache.org>
List-Id: <dev.spark.apache.org>
Delivered-To: mailing list dev@spark.apache.org
Received: (qmail 82558 invoked by uid 99); 30 Jun 2015 14:59:57 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 30 Jun 2015 14:59:57 +0000
X-ASF-Spam-Status: No, hits=1.5 required=10.0
	tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of zoltan.zvara@gmail.com
 designates 209.85.218.52 as permitted sender)
Received: from [209.85.218.52] (HELO mail-oi0-f52.google.com) (209.85.218.52)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 30 Jun 2015 14:57:42 +0000
Received: by oiyy130 with SMTP id y130so9366698oiy.0
        for <dev@spark.apache.org>; Tue, 30 Jun 2015 07:59:30 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=20120113;
        h=mime-version:from:date:message-id:subject:to:content-type;
        bh=1uR0e9oQyCxQDDquhBECaZPRN+atilDFD01Ad/XWbjw=;
        b=KITMwntqhuLB5FZm8DvzgoTp+nSZMBgzu9Q+vfLGWEXAHzet0p472/oFnXT8W+SuuQ
         ppcnWFUXt2l0S7PnGRGAoi+X3BY+UTGACLjM1LDjURnWi1w5weL5aRO7i70qidDFPt/5
         pqJsIdfZOfNEgDwuXy86BNFTsdgb/5nXHvwlNlwaxCeT609RszpR0MHe3cq5Ngs+OMe2
         IbP4r/fpHvkC+4gZ8EusqGE1TSs/++NT3xhCzvmU1YdlFx5KTxbOI9yHNzt/lwWjROb0
         +e8imRV4QABUUgYjPj+1hD0jSZfgi8GPBUK92cfZ4yxxDJLrhYsXip6u1caJ1PdzZQ9w
         kkJw==
X-Received: by 10.202.4.212 with SMTP id 203mr19319539oie.93.1435676370699;
 Tue, 30 Jun 2015 07:59:30 -0700 (PDT)
MIME-Version: 1.0
From: =?UTF-8?Q?Zolt=C3=A1n_Zvara?= <zoltan.zvara@gmail.com>
Date: Tue, 30 Jun 2015 14:59:21 +0000
Message-ID: 
 <CAO=evYfn3JRk2bV-QHAOqkfqa50CqjjFXLe0SDyPCd_KLNyRtw@mail.gmail.com>
Subject: DStream.reduce
To: "dev@spark.apache.org" <dev@spark.apache.org>
Content-Type: multipart/alternative; boundary=001a113b28b8168d060519bd7405
X-Virus-Checked: Checked by ClamAV on apache.org

--001a113b28b8168d060519bd7405
Content-Type: text/plain; charset=UTF-8

Why is reduce in DStream implemented with a map, reduceByKey and another
map, given that we have an RDD.reduce?

--001a113b28b8168d060519bd7405
Content-Type: text/html; charset=UTF-8

<div dir="ltr">Why is reduce in DStream implemented with a map, reduceByKey and another map, given that we have an RDD.reduce?</div>

--001a113b28b8168d060519bd7405--