streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From reba...@apache.org
Subject [3/4] incubator-streams git commit: Removed unimplemented methods
Date Fri, 21 Nov 2014 00:22:27 GMT
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 <ryanebanks@gmail.com>
Authored: Thu Nov 20 18:02:26 2014 -0600
Committer: Ryan Ebanks <ryanebanks@gmail.com>
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 {


Mime
View raw message