Return-Path: X-Original-To: apmail-apex-dev-archive@minotaur.apache.org Delivered-To: apmail-apex-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 E4E33184C7 for ; Mon, 9 Nov 2015 06:58:12 +0000 (UTC) Received: (qmail 9102 invoked by uid 500); 9 Nov 2015 06:58:12 -0000 Delivered-To: apmail-apex-dev-archive@apex.apache.org Received: (qmail 9040 invoked by uid 500); 9 Nov 2015 06:58:12 -0000 Mailing-List: contact dev-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list dev@apex.incubator.apache.org Received: (qmail 9018 invoked by uid 99); 9 Nov 2015 06:58:12 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 09 Nov 2015 06:58:12 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id DD243180440 for ; Mon, 9 Nov 2015 06:58:11 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.979 X-Spam-Level: ** X-Spam-Status: No, score=2.979 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=datatorrent_com.20150623.gappssmtp.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id DZua-fOhM2ea for ; Mon, 9 Nov 2015 06:58:10 +0000 (UTC) Received: from mail-ob0-f173.google.com (mail-ob0-f173.google.com [209.85.214.173]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id D593820C18 for ; Mon, 9 Nov 2015 06:58:09 +0000 (UTC) Received: by obdgf3 with SMTP id gf3so133097852obd.3 for ; Sun, 08 Nov 2015 22:58:02 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=datatorrent_com.20150623.gappssmtp.com; s=20150623; h=mime-version:from:date:message-id:subject:to:content-type; bh=V0VWaohM6f1DvDluQSzY51L9EpWYAxgiijAXw38n4n4=; b=yRtduz35BUKNAlHOvWVx07J73cAf4e5eM1Dhrzz8OMycodlz+zJaLDbRxPdR8Wzub+ ZhqOlDiz321HAG54j4asVxWHkWPggv/3JRzp3VNCwXvCiuBcuOxqobgCIjIiV6au/KpN 20cflZ8lUhsZ4O4wlbx4csbg2AmVPz5+N/7p1MDmOs4hrpVWaV7e2mI7Nwsh6hw/VHhv P596aAJTYjJWWJ6URUDKDfFhqYSiF8NdWwYphvv3XvWjiVkjU+yVb5nR0XTRAodpLKzu /NGmT9xbSq8z2EoosirS4KUnTFBaCQ/XHhDpgdHfQeV//WmG4GXXy4DvX7WxvxZRBABV uGiw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:from:date:message-id:subject:to :content-type; bh=V0VWaohM6f1DvDluQSzY51L9EpWYAxgiijAXw38n4n4=; b=DWJ0cFqXgqOQhi02m269DniWFFp48qZpjk5SX6jVrm46HSfYPfVpkXr3fvrA3DmTZs MYmbT8QGaOWQleYqmafq1uf9XOGpOKf6bj1I2m1vuWIGTRgP/yDql7UMHyvo57A3uV55 Kj+d87aur3sG/A1P6c0S2PkdnDitPcgsmD+NoZStRs/tn4BduNYfG6lrtck4PxzLsr+9 EBquOwAF6AkTlffUKDOLrbj8ikQfzAqyRCfdbSGlea1FIO4uTtvBHH5nN79dKY0IH4kI fEKG3B1B+YiQFsFtL3oTdK61GlSFkB+lXIi/XzykQfICvhQ46XfrVvgglREDEMLMUhoU zxAg== X-Gm-Message-State: ALoCoQlC55AV2wsXTCkJXKrJppNwC+JU2k0RSLqbPFvprPWDol5tZO3BPbO9hV5meOKam2EiJjP7 X-Received: by 10.60.15.201 with SMTP id z9mr4603303oec.84.1447052282553; Sun, 08 Nov 2015 22:58:02 -0800 (PST) MIME-Version: 1.0 Received: by 10.182.236.73 with HTTP; Sun, 8 Nov 2015 22:57:43 -0800 (PST) From: Bhupesh Chawda Date: Mon, 9 Nov 2015 12:27:43 +0530 Message-ID: Subject: Managing state within an application window To: dev@apex.incubator.apache.org Content-Type: multipart/alternative; boundary=089e012950e6460b900524161dd1 --089e012950e6460b900524161dd1 Content-Type: text/plain; charset=UTF-8 Hi All, I have a question regarding maintaining state of a variable within a single application window. If I have a variable which is just needed for a single application window (just between beginWindow and endWindow calls), do I need to serialize and checkpoint it? or can I make it transient? I understand that in case of checkpoint windows being aligned with the application windows, we can do so. Since in this case, the variable will start afresh immediately after the checkpoint. However in case of checkpoints happening in between application windows, this might not be the case. In the second case, is there any mechanism using which I can conditionally make it transient and non-transient based on when the checkpoints happen with respect to the application windows? Thanks. Bhupesh --089e012950e6460b900524161dd1--