This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 7cc4e0209 Improve Log info in Processor Test (#1445)
7cc4e0209 is described below
commit 7cc4e0209c00d8b1c02cf4d7943e36e2fa09426c
Author: Liu Xiao <[email protected]>
AuthorDate: Fri Mar 24 18:04:15 2023 +0800
Improve Log info in Processor Test (#1445)
---
.../processor/booloperator/counter/TestBooleanCounterProcessor.java | 4 ++--
.../processor/booloperator/inverter/TestBooleanInverterProcessor.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
index 55fc52996..a97da99ca 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
@@ -135,12 +135,12 @@ public class TestBooleanCounterProcessor {
assertEquals(expectedBooleanCount, counter);
}
-
private Integer sendEvents(BooleanCounterProcessor booleanCounter,
SpOutputCollector spOut) {
int counter = 0;
List<Event> events = makeEvents();
for (Event event : events) {
- LOG.info("Sending event with value " + event.getFieldBySelector("s0::" +
invertFieldName));
+ LOG.info("Sending event with value "
+ + event.getFieldBySelector("s0::" +
invertFieldName).getAsPrimitive().getAsBoolean());
booleanCounter.onEvent(event, spOut);
try {
Thread.sleep(100);
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
index 2a46a4308..e753903a8 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
@@ -124,12 +124,12 @@ public class TestBooleanInverterProcessor {
assertEquals(expectedBooleanCount, result);
}
-
private boolean sendEvents(BooleanInverterProcessor trend, SpOutputCollector
spOut) {
boolean result = false;
List<Event> events = makeEvents();
for (Event event : events) {
- LOG.info("Sending event with value " + event.getFieldBySelector("s0::" +
invertFieldName));
+ LOG.info("Sending event with value "
+ + event.getFieldBySelector("s0::" +
invertFieldName).getAsPrimitive().getAsBoolean());
trend.onEvent(event, spOut);
try {
Thread.sleep(100);