You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by re...@apache.org on 2014/11/21 01:22:27 UTC
[3/4] incubator-streams git commit: Removed unimplemented methods
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 <ry...@gmail.com>
Authored: Thu Nov 20 18:02:26 2014 -0600
Committer: Ryan Ebanks <ry...@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 {