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/STREAMS-212 Commit: e162ed62b80ca31ce27220e2b72ece445b865570 Parents: 26d7ece Author: Ryan Ebanks <ryaneba...@gmail.com> Authored: Thu Nov 20 18:02:26 2014 -0600 Committer: Ryan Ebanks <ryaneba...@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 {