Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id AE09318626 for ; Tue, 23 Feb 2016 07:39:23 +0000 (UTC) Received: (qmail 46444 invoked by uid 500); 23 Feb 2016 07:39:18 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 46308 invoked by uid 500); 23 Feb 2016 07:39:18 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 46201 invoked by uid 99); 23 Feb 2016 07:39:18 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 23 Feb 2016 07:39:18 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 0B68A2C14F0 for ; Tue, 23 Feb 2016 07:39:18 +0000 (UTC) Date: Tue, 23 Feb 2016 07:39:18 +0000 (UTC) From: "Chengxiang Li (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-3473) Add partial aggregate support in Flink MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Chengxiang Li created FLINK-3473: ------------------------------------ Summary: Add partial aggregate support in Flink Key: FLINK-3473 URL: https://issues.apache.org/jira/browse/FLINK-3473 Project: Flink Issue Type: Improvement Components: Table API Reporter: Chengxiang Li Assignee: Chengxiang Li For decomposable aggregate function, partial aggregate is more efficient as it significantly reduce the network traffic during shuffle and parallelize part of the aggregate calculation. This is an umbrella task for partial aggregate. -- This message was sent by Atlassian JIRA (v6.3.4#6332)