From dev-return-9864-archive-asf-public=cust-asf.ponee.io@samza.apache.org Tue Dec 11 17:06:46 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 62E56180671 for ; Tue, 11 Dec 2018 17:06:46 +0100 (CET) Received: (qmail 12347 invoked by uid 500); 11 Dec 2018 16:06:45 -0000 Mailing-List: contact dev-help@samza.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@samza.apache.org Delivered-To: mailing list dev@samza.apache.org Received: (qmail 12334 invoked by uid 99); 11 Dec 2018 16:06:44 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 11 Dec 2018 16:06:44 +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 3FE6B180C9B for ; Tue, 11 Dec 2018 16:06:44 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.797 X-Spam-Level: * X-Spam-Status: No, score=1.797 tagged_above=-999 required=6.31 tests=[DKIMWL_WL_MED=-0.001, DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-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 (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 9mG0Afx4jIo3 for ; Tue, 11 Dec 2018 16:06:43 +0000 (UTC) Received: from mail-vs1-f45.google.com (mail-vs1-f45.google.com [209.85.217.45]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id EF7A860F5C for ; Tue, 11 Dec 2018 16:06:42 +0000 (UTC) Received: by mail-vs1-f45.google.com with SMTP id e7so9183976vsc.2 for ; Tue, 11 Dec 2018 08:06:42 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=anmwK/tgUmaC5NRFEiNfgPHnyCwF1E84iIe/x6Ze3bM=; b=grN7ts/iA+VcEkIzysv+Vcw0DPJn7/bS9Q/EFxpBVG6ZftvHeB5c2WhEXQl5hOGvEK NlJsDQIKJOv/N3Jwun2j9qmuVnIqgcZW/klAgcB7SdFkbTvOtMxN+yLfQe85JPmOCmGI qvMCC7nk8iVfsVRtAcu0rHhqnH6Wk2/p1tg8HBXtbGvXbtShsEZuCSGZ3V63gcqPc2zZ cDSn0xfnnTeL90ujHiVx2A32FSo/objwguspP8BpQ5TXX4csppSX6xF9AkSmVV/MgsLx yMSfJALCtfm7X2biHlvN8EcTzs6Bt50GLN4PkbQTkKjxMwLAz3PJwX3AtRZsOBVSZeTe CgSA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=anmwK/tgUmaC5NRFEiNfgPHnyCwF1E84iIe/x6Ze3bM=; b=SDPaAO/CVB2K0CE/Vvx17L1erxCvx8j8SmBgiGPIav6Z+29dNrISDREBTSdTMfpNwM VZh1QfDuZJY9Phy1HDp5WyIGQzkwh/bOUGLMijQwTQX31datkHlF9qSgmCnbu9C4rLmW /cDbNioGNqnjZZzuXp1xvPzOklAUoqe5x/8BOJC+ziAmoBbpCwNYtFvr+D3d6x+HF7Dm ru+JonqIyLoF2572Ex5llLhk/npIay65XWAwGTK1niHHn/uX7QfUnd2pnsjDxd/emTh1 0b9L09P7aL829ceN/gTFr/8h833d+8oDNCuqppqWqLKYSZK1mCfCOYCw+bq7vT07QjVc 5nlg== X-Gm-Message-State: AA+aEWaVT6Lr50Kl7BcVl9Nv2XulKBcnXgVszk4fV+XUT0yO3FJPv7jn luOSBLoduyHnIzHgd7k8KaNRQuuPRmEqfhJw1dDfQJEP X-Google-Smtp-Source: AFSGD/XvCZlZTVtde+OZZUsk7mphBoadf2l962o/cVkTXMs5JrIVmZRl24PNzNJld1QkJy3++hOG8mklifYQxERIcks= X-Received: by 2002:a67:7ad3:: with SMTP id v202mr7528785vsc.49.1544544401821; Tue, 11 Dec 2018 08:06:41 -0800 (PST) MIME-Version: 1.0 From: Daniel Nishimura Date: Tue, 11 Dec 2018 08:06:05 -0800 Message-ID: Subject: [DISCUSS] SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams To: dev@samza.apache.org Content-Type: multipart/alternative; boundary="0000000000006915cc057cc14423" --0000000000006915cc057cc14423 Content-Type: text/plain; charset="UTF-8" Hi all, I am proposing SEP-18 which provides a more generic interface to rewind and fast-forward input offsets. This will allow manipulating offsets not only by specific offsets, but also by timestamp and other position types. Please see the document linked below. The document is evolving as we explore the feature through implementation, so please keep an eye out for changes. https://cwiki.apache.org/confluence/display/SAMZA/SEP-18%3A+Startpoints+-+Manipulating+Starting+Offsets+for+Input+Streams Thanks! Dan Nishimura --0000000000006915cc057cc14423--