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 9726B200828 for ; Fri, 13 May 2016 17:31:16 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 95B3116099F; Fri, 13 May 2016 15:31:16 +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 DB6C41602BE for ; Fri, 13 May 2016 17:31:15 +0200 (CEST) Received: (qmail 90923 invoked by uid 500); 13 May 2016 15:31:15 -0000 Mailing-List: contact dev-help@gearpump.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@gearpump.incubator.apache.org Delivered-To: mailing list dev@gearpump.incubator.apache.org Received: (qmail 90912 invoked by uid 99); 13 May 2016 15:31:15 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 May 2016 15:31:15 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id AF160C21C2 for ; Fri, 13 May 2016 15:31:14 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.648 X-Spam-Level: X-Spam-Status: No, score=-4.648 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-1.428] autolearn=disabled Received: from mx2-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id L2DDTDcSJWab for ; Fri, 13 May 2016 15:31:14 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx2-lw-us.apache.org (ASF Mail Server at mx2-lw-us.apache.org) with SMTP id B27715F4EA for ; Fri, 13 May 2016 15:31:13 +0000 (UTC) Received: (qmail 90703 invoked by uid 99); 13 May 2016 15:31:13 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 May 2016 15:31:13 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id D5B7C2C1F5D for ; Fri, 13 May 2016 15:31:12 +0000 (UTC) Date: Fri, 13 May 2016 15:31:12 +0000 (UTC) From: "Kam Kasravi (JIRA)" To: dev@gearpump.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Assigned] (GEARPUMP-105) Provide non-persistent Sink Task so that examples like word count can materialize Sum results within the Client MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 13 May 2016 15:31:16 -0000 [ https://issues.apache.org/jira/browse/GEARPUMP-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kam Kasravi reassigned GEARPUMP-105: ------------------------------------ Assignee: Kam Kasravi > Provide non-persistent Sink Task so that examples like word count can materialize Sum results within the Client > --------------------------------------------------------------------------------------------------------------- > > Key: GEARPUMP-105 > URL: https://issues.apache.org/jira/browse/GEARPUMP-105 > Project: Apache Gearpump > Issue Type: New Feature > Components: streaming > Affects Versions: 0.8.0 > Reporter: Kam Kasravi > Assignee: Kam Kasravi > Fix For: 0.8.1 > > > Gearpump's application model is to submit a DAG to master for execution but doesn't really provide a way to materialize any Sink nodes within the application (client). We should provide this capability and add it to wordcount so that it has functionality similar to flink and spark (interactive mode). -- This message was sent by Atlassian JIRA (v6.3.4#6332)