Return-Path: X-Original-To: apmail-streams-commits-archive@minotaur.apache.org Delivered-To: apmail-streams-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D1DFC17932 for ; Fri, 21 Nov 2014 00:22:49 +0000 (UTC) Received: (qmail 57875 invoked by uid 500); 21 Nov 2014 00:22:49 -0000 Delivered-To: apmail-streams-commits-archive@streams.apache.org Received: (qmail 57855 invoked by uid 500); 21 Nov 2014 00:22:49 -0000 Mailing-List: contact commits-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list commits@streams.incubator.apache.org Received: (qmail 57846 invoked by uid 99); 21 Nov 2014 00:22:49 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 21 Nov 2014 00:22:49 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Fri, 21 Nov 2014 00:22:27 +0000 Received: (qmail 57630 invoked by uid 99); 21 Nov 2014 00:22:25 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 21 Nov 2014 00:22:25 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 740EF947103; Fri, 21 Nov 2014 00:22:25 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: rebanks@apache.org To: commits@streams.incubator.apache.org Date: Fri, 21 Nov 2014 00:22:27 -0000 Message-Id: <34bd60efb66d4d16adb2efe2421de9ee@git.apache.org> In-Reply-To: <912e2016ae6b4d8dba4c0e93de879c36@git.apache.org> References: <912e2016ae6b4d8dba4c0e93de879c36@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [3/4] incubator-streams git commit: Removed unimplemented methods X-Virus-Checked: Checked by ClamAV on apache.org Removed unimplemented methods Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/e162ed62 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/e162ed62 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/e162ed62 Branch: refs/heads/master Commit: e162ed62b80ca31ce27220e2b72ece445b865570 Parents: 26d7ece Author: Ryan Ebanks Authored: Thu Nov 20 18:02:26 2014 -0600 Committer: Ryan Ebanks Committed: Thu Nov 20 18:02:26 2014 -0600 ---------------------------------------------------------------------- .../streams/local/builders/LocalStreamBuilder.java | 12 ------------ 1 file changed, 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/e162ed62/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java index 778407a..7938247 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java @@ -379,19 +379,7 @@ public class LocalStreamBuilder implements StreamBuilder { stopInternal(false); } - /** - * Attempts to shut down the stream and let all data in flight finish processing. When shutdown(long) is called, it - * immediately stops all {@link org.apache.streams.core.StreamsProvider}s and will attempt to let all {@link org.apache.streams.core.StreamsProcessor}s - * and all {@link org.apache.streams.core.StreamsPersistWriter}s finish processing. - * @param waitInMs - */ - public void shutdown(Long waitInMs) { - - } - - public void shutdownNow() { - } protected void stopInternal(boolean systemExiting) { try {