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 2ED1E200B6B for ; Fri, 9 Sep 2016 20:46:27 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 2D75A160AC2; Fri, 9 Sep 2016 18:46:27 +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 75332160AA3 for ; Fri, 9 Sep 2016 20:46:26 +0200 (CEST) Received: (qmail 32722 invoked by uid 500); 9 Sep 2016 18:46:25 -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 32710 invoked by uid 99); 9 Sep 2016 18:46:25 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 09 Sep 2016 18:46:25 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id D7ADA1A60AC for ; Fri, 9 Sep 2016 18:46:24 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.299 X-Spam-Level: * X-Spam-Status: No, score=1.299 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id PD9_x-_EzQWb for ; Fri, 9 Sep 2016 18:46:24 +0000 (UTC) Received: from mail-pf0-f178.google.com (mail-pf0-f178.google.com [209.85.192.178]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 957F25F1EF for ; Fri, 9 Sep 2016 18:46:23 +0000 (UTC) Received: by mail-pf0-f178.google.com with SMTP id w87so31923006pfk.2 for ; Fri, 09 Sep 2016 11:46:23 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:sender:from:date:message-id:subject:to:cc; bh=irsF7YMl0yV1vwdjHhZq129tm5a4tVOKvEhBkk5sjm8=; b=SnrW5dIBIuhi0wMP8cG8ux+dGPSg4hNqt+nWRv8NtwTVNZ0YS3TEP14ooDWrJbdO+k 0ZbQjH0MyZvtPvOKF2SqhYd4eUWlOCjChJCfxWEJNGO5eAQ7+SF1+TWAzjHJA1CBSZa9 kjw6Pt5r+LmSx0KKXfJCPw9d1+sfjNEA+COiyHaM1HKsf/8zPHOAMBvSlchDcd+ejts8 bl69dOfhu9xiG8IbulftloGiZDX1lG5+moON8BNolaV3WBbMpqCQB8lyOSH4/vGlrF9k vDhigUHjpjrn+L1uejNL6Ib97HGVEIvIe5ewnr9GR0z2BjTnPA1/jP+i5ZLX7iuK8Ezv 44zg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:sender:from:date:message-id:subject :to:cc; bh=irsF7YMl0yV1vwdjHhZq129tm5a4tVOKvEhBkk5sjm8=; b=HCVeBOkCUXJRdI/lOe7RUfjOqQuvzMQY0ni2aQJXhHX828D0UE92NjdmflLSfXGsRh fyhSq0/vGe6THZXSiYqNdq4yR3FDOrFBIGC4GyMBmldujApl0Qq9beQW+SHwzYCV8ikk sSqL0lGdO34AQ/McX8CBwq8USNhgzXFAZuO5ftycxQFR36nJnI+wnyLjMgoopRoPp5Ia uaxl75xAxqx4W9DaUSfVzG5lrtju3dpD1pZBJ3F9b9ZPg0h55iA/mqH97S6jIWYBbJ9r hmufrgpljUyg/zxFELVSHg7ew9ELh+C8KSm76EcUA8IR/3DgX4eeDRRjZVOU7bs7MIJX EQaw== X-Gm-Message-State: AE9vXwPadrh3AW3kWc2+SO3wKlnOnL1EWSuOdwyc9LjkH78G1YqPXkwpGsQp9R1vhuTsyfWfGdDG6UkMORFviw== X-Received: by 10.98.73.22 with SMTP id w22mr9146771pfa.62.1473446782721; Fri, 09 Sep 2016 11:46:22 -0700 (PDT) MIME-Version: 1.0 Sender: drfloob@gmail.com Received: by 10.66.253.169 with HTTP; Fri, 9 Sep 2016 11:46:02 -0700 (PDT) From: AJ Heller Date: Fri, 9 Sep 2016 11:46:02 -0700 X-Google-Sender-Auth: m1EmKYJ9T_8MKqbDH31XkQRE5Co Message-ID: Subject: Implementing FLIP-2 and FLIP-4 To: dev@flink.apache.org Cc: Aljoscha Krettek , Vishnu Viswanath Content-Type: multipart/alternative; boundary=94eb2c0b7ad814651a053c17907e archived-at: Fri, 09 Sep 2016 18:46:27 -0000 --94eb2c0b7ad814651a053c17907e Content-Type: text/plain; charset=UTF-8 Thank you for offering your support, I'm excited to dig in! I have some work to do getting up to speed on the windowing internals. And I still need to get my bearing on the Evictor changes, I plan to read through the list archive and documents today. Vishnu, are your changes already publicly viewable? Regarding the window modifications in FLIP-2, I see Vishnu that you've suggested an interface for the EvictorContext object, and Aljoscha, you suggested an abstract Context class. Does it make sense for them to agree? The other big difference I've seen in the signatures is wheter the Window is contained in the context or not. Have you considered modifying the signature of the methods to accept `` or ``? At least in terms of FLIP-2, this would allow each process window function to define and work with its own context (without downcasting, anyway), and similarly in the future, there'd be less work in changing Context subclasses when new abstract methods are added to Context. But I may be getting ahead of myself. Could you point me towards where contexts are/would be created? I'm not clear on the ownership and lifecycle of these objects yet. --94eb2c0b7ad814651a053c17907e--