From 41dc4b9d4e221ae6cb3175988542b04d4f5c6fda Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Fri, 5 Dec 2014 11:08:34 +0100
Subject: [PATCH] removed sysout from CollectorSink
---
.../java/teetime/stage/CollectorSink.java | 20 ++++++++-----------
1 file changed, 8 insertions(+), 12 deletions(-)
diff --git a/src/main/java/teetime/stage/CollectorSink.java b/src/main/java/teetime/stage/CollectorSink.java
index 6797fbde..a18f597d 100644
--- a/src/main/java/teetime/stage/CollectorSink.java
+++ b/src/main/java/teetime/stage/CollectorSink.java
@@ -22,16 +22,10 @@ import teetime.framework.AbstractConsumerStage;
/**
* @author Christian Wulf
*
- * @since 1.10
+ * @since 1.0
*/
public class CollectorSink<T> extends AbstractConsumerStage<T> {
- // private final InputPort<T> inputPort = this.createInputPort();
- //
- // public final InputPort<T> getInputPort() {
- // return this.inputPort;
- // }
-
private final List<T> elements;
private final int threshold;
@@ -46,7 +40,7 @@ public class CollectorSink<T> extends AbstractConsumerStage<T> {
@Override
public void onTerminating() throws Exception {
- System.out.println("size: " + this.elements.size());
+ logNumElements();
super.onTerminating();
}
@@ -55,12 +49,14 @@ public class CollectorSink<T> extends AbstractConsumerStage<T> {
this.elements.add(element);
if ((this.elements.size() % this.threshold) == 0) {
- System.out.println("size: " + this.elements.size());
+ logNumElements();
}
+ }
- // if (this.elements.size() > 90000) {
- // // System.out.println("size > 90000: " + this.elements.size());
- // }
+ private void logNumElements() {
+ if (logger.isInfoEnabled()) {
+ logger.info("size: " + this.elements.size());
+ }
}
}
--
GitLab