You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/09/05 21:02:48 UTC
git commit: STREAMS-162
Repository: incubator-streams
Updated Branches:
refs/heads/master d8a3380bf -> 3ee517573
STREAMS-162
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/3ee51757
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/3ee51757
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/3ee51757
Branch: refs/heads/master
Commit: 3ee517573f10f3b20223000e6bebcfbffb8402b6
Parents: d8a3380
Author: Renato Marroquin <rm...@apache.org>
Authored: Fri Sep 5 00:28:55 2014 +0200
Committer: Renato Marroquin <rm...@apache.org>
Committed: Fri Sep 5 00:28:55 2014 +0200
----------------------------------------------------------------------
.../local/builders/LocalStreamBuilderTest.java | 37 ++++++++++++--------
.../local/builders/ToyLocalBuilderExample.java | 6 ++--
.../streams/local/tasks/BasicTasksTest.java | 6 ++--
.../test/processors/DoNothingProcessor.java | 2 +-
.../PassthroughDatumCounterProcessor.java | 2 +-
.../test/providers/NumericMessageProvider.java | 2 +-
.../local/test/writer/DatumCounterWriter.java | 2 +-
.../local/test/writer/DoNothingWriter.java | 2 +-
.../local/test/writer/SystemOutWriter.java | 2 +-
9 files changed, 34 insertions(+), 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/LocalStreamBuilderTest.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/LocalStreamBuilderTest.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/LocalStreamBuilderTest.java
index 5a40865..c02f704 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/LocalStreamBuilderTest.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/LocalStreamBuilderTest.java
@@ -18,18 +18,16 @@
package org.apache.streams.local.builders;
-import com.google.common.collect.Maps;
-import com.google.common.collect.Queues;
-import org.apache.streams.core.StreamBuilder;
-import org.apache.streams.core.StreamsDatum;
-import org.apache.streams.core.test.processors.PassthroughDatumCounterProcessor;
-import org.apache.streams.core.test.providers.NumericMessageProvider;
-import org.apache.streams.core.test.writer.SystemOutWriter;
-import org.apache.streams.local.tasks.StreamsTask;
-import org.apache.streams.local.test.processors.SlowProcessor;
-import org.apache.streams.local.test.providers.EmptyResultSetProvider;
-import org.junit.Before;
-import org.junit.Test;
+import static org.hamcrest.Matchers.allOf;
+import static org.hamcrest.Matchers.equalTo;
+import static org.hamcrest.Matchers.greaterThan;
+import static org.hamcrest.Matchers.greaterThanOrEqualTo;
+import static org.hamcrest.Matchers.is;
+import static org.hamcrest.Matchers.lessThanOrEqualTo;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertThat;
+import static org.junit.Assert.assertTrue;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
@@ -39,11 +37,20 @@ import java.util.Map;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
-import static org.junit.Assert.*;
-import static org.hamcrest.Matchers.*;
+import org.apache.streams.core.StreamBuilder;
+import org.apache.streams.core.StreamsDatum;
+import org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor;
+import org.apache.streams.local.test.processors.SlowProcessor;
+import org.apache.streams.local.test.providers.EmptyResultSetProvider;
+import org.apache.streams.local.test.providers.NumericMessageProvider;
+import org.apache.streams.local.test.writer.SystemOutWriter;
+import org.junit.Before;
+import org.junit.Test;
+
+import com.google.common.collect.Maps;
+import com.google.common.collect.Queues;
/**
* Basic Tests for the LocalStreamBuilder.
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/ToyLocalBuilderExample.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/ToyLocalBuilderExample.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/ToyLocalBuilderExample.java
index fb44038..f2bccef 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/ToyLocalBuilderExample.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/builders/ToyLocalBuilderExample.java
@@ -20,9 +20,9 @@ package org.apache.streams.local.builders;
import org.apache.streams.core.StreamBuilder;
import org.apache.streams.core.StreamsDatum;
-import org.apache.streams.core.test.processors.DoNothingProcessor;
-import org.apache.streams.core.test.providers.NumericMessageProvider;
-import org.apache.streams.core.test.writer.DoNothingWriter;
+import org.apache.streams.local.test.processors.DoNothingProcessor;
+import org.apache.streams.local.test.providers.NumericMessageProvider;
+import org.apache.streams.local.test.writer.DoNothingWriter;
import java.util.concurrent.LinkedBlockingQueue;
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/tasks/BasicTasksTest.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/tasks/BasicTasksTest.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/tasks/BasicTasksTest.java
index 023fa4a..4ec4acc 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/tasks/BasicTasksTest.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/tasks/BasicTasksTest.java
@@ -19,9 +19,9 @@
package org.apache.streams.local.tasks;
import org.apache.streams.core.StreamsDatum;
-import org.apache.streams.core.test.processors.PassthroughDatumCounterProcessor;
-import org.apache.streams.core.test.providers.NumericMessageProvider;
-import org.apache.streams.core.test.writer.DatumCounterWriter;
+import org.apache.streams.local.test.processors.PassthroughDatumCounterProcessor;
+import org.apache.streams.local.test.providers.NumericMessageProvider;
+import org.apache.streams.local.test.writer.DatumCounterWriter;
import org.junit.Test;
import java.util.Queue;
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/DoNothingProcessor.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/DoNothingProcessor.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/DoNothingProcessor.java
index 78ae07f..ab9249c 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/DoNothingProcessor.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/DoNothingProcessor.java
@@ -16,7 +16,7 @@
* under the License.
*/
-package org.apache.streams.core.test.processors;
+package org.apache.streams.local.test.processors;
import org.apache.streams.core.StreamsDatum;
import org.apache.streams.core.StreamsProcessor;
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/PassthroughDatumCounterProcessor.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/PassthroughDatumCounterProcessor.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/PassthroughDatumCounterProcessor.java
index e7c08e0..423c05a 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/PassthroughDatumCounterProcessor.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/processors/PassthroughDatumCounterProcessor.java
@@ -16,7 +16,7 @@
* under the License.
*/
-package org.apache.streams.core.test.processors;
+package org.apache.streams.local.test.processors;
import org.apache.streams.core.StreamsDatum;
import org.apache.streams.core.StreamsProcessor;
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
index 379459f..f076e4b 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
@@ -16,7 +16,7 @@
* under the License.
*/
-package org.apache.streams.core.test.providers;
+package org.apache.streams.local.test.providers;
import com.google.common.collect.Queues;
import org.apache.streams.core.StreamsDatum;
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DatumCounterWriter.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DatumCounterWriter.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DatumCounterWriter.java
index 4412df9..af86044 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DatumCounterWriter.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DatumCounterWriter.java
@@ -16,7 +16,7 @@
* under the License.
*/
-package org.apache.streams.core.test.writer;
+package org.apache.streams.local.test.writer;
import org.apache.streams.core.StreamsDatum;
import org.apache.streams.core.StreamsPersistWriter;
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DoNothingWriter.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DoNothingWriter.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DoNothingWriter.java
index fdcda36..9cc89e7 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DoNothingWriter.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/DoNothingWriter.java
@@ -16,7 +16,7 @@
* under the License.
*/
-package org.apache.streams.core.test.writer;
+package org.apache.streams.local.test.writer;
import org.apache.streams.core.StreamsDatum;
import org.apache.streams.core.StreamsPersistWriter;
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3ee51757/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/SystemOutWriter.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/SystemOutWriter.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/SystemOutWriter.java
index 7658fd0..b2b5112 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/SystemOutWriter.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/writer/SystemOutWriter.java
@@ -16,7 +16,7 @@
* under the License.
*/
-package org.apache.streams.core.test.writer;
+package org.apache.streams.local.test.writer;
import org.apache.streams.core.StreamsDatum;
import org.apache.streams.core.StreamsPersistWriter;