Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 158DC200B61 for ; Mon, 25 Jul 2016 14:03:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 142C5160A7D; Mon, 25 Jul 2016 12:03:22 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 65F56160A78 for ; Mon, 25 Jul 2016 14:03:21 +0200 (CEST) Received: (qmail 88667 invoked by uid 500); 25 Jul 2016 12:03:20 -0000 Mailing-List: contact issues-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 issues@flink.apache.org Received: (qmail 88634 invoked by uid 99); 25 Jul 2016 12:03:20 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 25 Jul 2016 12:03:20 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 81CFD2C0059 for ; Mon, 25 Jul 2016 12:03:20 +0000 (UTC) Date: Mon, 25 Jul 2016 12:03:20 +0000 (UTC) From: "vishnu viswanath (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (FLINK-4174) Enhance Window Evictor MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Mon, 25 Jul 2016 12:03:22 -0000 [ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath updated FLINK-4174: ------------------------------------ Description: Enhance the current functionality of Evictor as per this [design document|https://docs.google.com/document/d/1Rr7xzlItYqvFXLyyy-Yv0vvw8f29QYAjm5i9E4A_JlU/edit]. This includes: - Allow eviction of elements from the window in any order (not only from the beginning). To do this Evictor must go through the list of elements and remove the elements that have to be evicted instead of the current approach of : returning the count of elements to be removed from beginning. - Allow eviction to be done before/after applying the window function. FLIP page for this enhancement : [FLIP-4|https://cwiki.apache.org/confluence/display/FLINK/FLIP-4+%3A+Enhance+Window+Evictor] was: Enhance the current functionality of Evictor as per this [design document|https://docs.google.com/document/d/1Rr7xzlItYqvFXLyyy-Yv0vvw8f29QYAjm5i9E4A_JlU/edit]. This includes: - Allow eviction of elements from the window in any order (not only from the beginning). To do this Evictor must go through the list of elements and remove the elements that have to be evicted instead of the current approach of : returning the count of elements to be removed from beginning. - Allow eviction to be done before/after applying the window function. > Enhance Window Evictor > ---------------------- > > Key: FLINK-4174 > URL: https://issues.apache.org/jira/browse/FLINK-4174 > Project: Flink > Issue Type: Sub-task > Components: Streaming > Reporter: vishnu viswanath > > Enhance the current functionality of Evictor as per this [design document|https://docs.google.com/document/d/1Rr7xzlItYqvFXLyyy-Yv0vvw8f29QYAjm5i9E4A_JlU/edit]. > This includes: > - Allow eviction of elements from the window in any order (not only from the beginning). To do this Evictor must go through the list of elements and remove the elements that have to be evicted instead of the current approach of : returning the count of elements to be removed from beginning. > - Allow eviction to be done before/after applying the window function. > FLIP page for this enhancement : [FLIP-4|https://cwiki.apache.org/confluence/display/FLINK/FLIP-4+%3A+Enhance+Window+Evictor] -- This message was sent by Atlassian JIRA (v6.3.4#6332)