You are viewing a plain text version of this content. The canonical link for it is here.
Posted to s4-commits@incubator.apache.org by mm...@apache.org on 2012/07/13 14:36:59 UTC
[3/4] git commit: Register stream in app using app reference passed
to the constructor
Register stream in app using app reference passed to the constructor
Project: http://git-wip-us.apache.org/repos/asf/incubator-s4/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-s4/commit/75706ebe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-s4/tree/75706ebe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-s4/diff/75706ebe
Branch: refs/heads/piper
Commit: 75706ebe6c837f726e3b05ff76216686d8de2237
Parents: 317d8b1
Author: Matthieu Morel <mm...@apache.org>
Authored: Fri Jul 13 12:44:16 2012 +0200
Committer: Matthieu Morel <mm...@apache.org>
Committed: Fri Jul 13 12:44:16 2012 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/s4/core/App.java | 3 ++-
.../src/main/java/org/apache/s4/core/Stream.java | 2 +-
2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-s4/blob/75706ebe/subprojects/s4-core/src/main/java/org/apache/s4/core/App.java
----------------------------------------------------------------------
diff --git a/subprojects/s4-core/src/main/java/org/apache/s4/core/App.java b/subprojects/s4-core/src/main/java/org/apache/s4/core/App.java
index f5de855..0beec16 100644
--- a/subprojects/s4-core/src/main/java/org/apache/s4/core/App.java
+++ b/subprojects/s4-core/src/main/java/org/apache/s4/core/App.java
@@ -26,6 +26,7 @@ import org.apache.s4.base.KeyFinder;
import org.apache.s4.base.SerializerDeserializer;
import org.apache.s4.comm.serialize.KryoSerDeser;
import org.apache.s4.comm.topology.RemoteStreams;
+import org.apache.s4.core.App.ClockType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -283,7 +284,7 @@ public abstract class App {
ProcessingElement... processingElements) {
return new Stream<T>(this).setName(name).setKey(finder).setPEs(processingElements).setEventType(eventType)
- .register(this);
+ .register();
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-s4/blob/75706ebe/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java
----------------------------------------------------------------------
diff --git a/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java b/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java
index 3089cb6..e01191b 100644
--- a/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java
+++ b/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java
@@ -310,7 +310,7 @@ public class Stream<T extends Event> implements Runnable, Streamable {
}
}
- public Stream<T> register(App app) {
+ public Stream<T> register() {
app.addStream(this);
return this;
}