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/01/03 14:03:29 UTC
[50/50] [abbrv] git commit: removed trigger on WordCounterPE since
triggers are tested elsewhere
removed trigger on WordCounterPE since triggers are tested elsewhere
Project: http://git-wip-us.apache.org/repos/asf/incubator-s4/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-s4/commit/e694064e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-s4/tree/e694064e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-s4/diff/e694064e
Branch: refs/heads/piper
Commit: e694064e972bb7286b6d0937d6d287c45fa81e2b
Parents: c87fa07
Author: Matthieu Morel <ma...@yahoo-inc.com>
Authored: Fri Oct 21 18:52:22 2011 +0200
Committer: Matthieu Morel <ma...@yahoo-inc.com>
Committed: Fri Oct 21 18:55:21 2011 +0200
----------------------------------------------------------------------
.../test/java/test/s4/wordcount/WordCountApp.java | 2 +-
.../test/java/test/s4/wordcount/WordCounterPE.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-s4/blob/e694064e/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCountApp.java
----------------------------------------------------------------------
diff --git a/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCountApp.java b/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCountApp.java
index 2609dc0..c4cf573 100644
--- a/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCountApp.java
+++ b/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCountApp.java
@@ -33,7 +33,7 @@ public class WordCountApp extends App {
Stream<WordCountEvent> wordCountStream = createStream("words counts stream", new WordCountKeyFinder(),
wordClassifierPrototype);
WordCounterPE wordCounterPrototype = createPE(WordCounterPE.class);
- wordCounterPrototype.setTrigger(WordSeenEvent.class, 1, 0, null);
+// wordCounterPrototype.setTrigger(WordSeenEvent.class, 1, 0, null);
wordCounterPrototype.setWordClassifierStream(wordCountStream);
Stream<WordSeenEvent> wordSeenStream = createStream("words seen stream", new WordSeenKeyFinder(),
wordCounterPrototype);
http://git-wip-us.apache.org/repos/asf/incubator-s4/blob/e694064e/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCounterPE.java
----------------------------------------------------------------------
diff --git a/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCounterPE.java b/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCounterPE.java
index a3a7e30..d5cacc7 100644
--- a/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCounterPE.java
+++ b/subprojects/s4-core/src/test/java/test/s4/wordcount/WordCounterPE.java
@@ -19,7 +19,7 @@ public class WordCounterPE extends ProcessingElement {
this.wordClassifierStream = stream;
}
- public void onTrigger(WordSeenEvent event) {
+ public void onEvent(WordSeenEvent event) {
wordCounter++;
System.out.println("seen word " + event.getWord());
// NOTE: it seems the id is the key for now...