incubator-s4-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mmo...@apache.org
Subject [50/50] [abbrv] git commit: removed trigger on WordCounterPE since triggers are tested elsewhere
Date Tue, 03 Jan 2012 14:03:29 GMT
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 <matthieu@yahoo-inc.com>
Authored: Fri Oct 21 18:52:22 2011 +0200
Committer: Matthieu Morel <matthieu@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...     


Mime
View raw message